src/vnet/session/application_interface.c

   1 /*
   2  * Copyright (c) 2016-2019 Cisco and/or its affiliates.
   3  * Licensed under the Apache License, Version 2.0 (the "License");
   4  * you may not use this file except in compliance with the License.
   5  * You may obtain a copy of the License at:
   6  *
   7  *     http://www.apache.org/licenses/LICENSE-2.0
   8  *
   9  * Unless required by applicable law or agreed to in writing, software
  10  * distributed under the License is distributed on an "AS IS" BASIS,
  11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12  * See the License for the specific language governing permissions and
  13  * limitations under the License.
  14  */
  15 #include <vnet/session/application_interface.h>
  16 #include <vnet/session/application.h>
  17 #include <vnet/session/session.h>
  18
  19 /** @file
  20     VPP's application/session API bind/unbind/connect/disconnect calls
  21 */
  22
  23 /**
  24  * unformat a vnet URI
  25  *
  26  * transport-proto://[hostname]ip46-addr:port
  27  * eg.  tcp://ip46-addr:port
  28  *      tls://[testtsl.fd.io]ip46-addr:port
  29  *
  30  * u8 ip46_address[16];
  31  * u16  port_in_host_byte_order;
  32  * stream_session_type_t sst;
  33  * u8 *fifo_name;
  34  *
  35  * if (unformat (input, "%U", unformat_vnet_uri, &ip46_address,
  36  *              &sst, &port, &fifo_name))
  37  *  etc...
  38  *
  39  */
  40 uword
  41 unformat_vnet_uri (unformat_input_t * input, va_list * args)
  42 {
  43   session_endpoint_cfg_t *sep = va_arg (*args, session_endpoint_cfg_t *);
  44   u32 transport_proto = 0, port;
  45
  46   if (unformat (input, "%U://%U/%d", unformat_transport_proto,
  47                 &transport_proto, unformat_ip4_address, &sep->ip.ip4, &port))
  48     {
  49       sep->transport_proto = transport_proto;
  50       sep->port = clib_host_to_net_u16 (port);
  51       sep->is_ip4 = 1;
  52       return 1;
  53     }
  54   else if (unformat (input, "%U://%U/%d", unformat_transport_proto,
  55                      &transport_proto, unformat_ip6_address, &sep->ip.ip6,
  56                      &port))
  57     {
  58       sep->transport_proto = transport_proto;
  59       sep->port = clib_host_to_net_u16 (port);
  60       sep->is_ip4 = 0;
  61       return 1;
  62     }
  63   else if (unformat (input, "%U://session/%lu", unformat_transport_proto,
  64                      &transport_proto, &sep->parent_handle))
  65     {
  66       sep->transport_proto = transport_proto;
  67       sep->ip.ip4.as_u32 = 1;   /* ip need to be non zero in vnet */
  68       return 1;
  69     }
  70   return 0;
  71 }
  72
  73 static u8 *cache_uri;
  74 static session_endpoint_cfg_t *cache_sep;
  75
  76 session_error_t
  77 parse_uri (char *uri, session_endpoint_cfg_t *sep)
  78 {
  79   unformat_input_t _input, *input = &_input;
  80
  81   if (cache_uri && !strncmp (uri, (char *) cache_uri, vec_len (cache_uri)))
  82     {
  83       *sep = *cache_sep;
  84       return 0;
  85     }
  86
  87   /* Make sure */
  88   uri = (char *) format (0, "%s%c", uri, 0);
  89
  90   /* Parse uri */
  91   unformat_init_string (input, uri, strlen (uri));
  92   if (!unformat (input, "%U", unformat_vnet_uri, sep))
  93     {
  94       unformat_free (input);
  95       return SESSION_E_INVALID;
  96     }
  97   unformat_free (input);
  98
  99   vec_free (cache_uri);
 100   cache_uri = (u8 *) uri;
 101   if (cache_sep)
 102     clib_mem_free (cache_sep);
 103   cache_sep = clib_mem_alloc (sizeof (*sep));
 104   *cache_sep = *sep;
 105
 106   return 0;
 107 }
 108
 109 session_error_t
 110 vnet_bind_uri (vnet_listen_args_t *a)
 111 {
 112   session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
 113   int rv;
 114
 115   rv = parse_uri (a->uri, &sep);
 116   if (rv)
 117     return rv;
 118   sep.app_wrk_index = 0;
 119   clib_memcpy (&a->sep_ext, &sep, sizeof (sep));
 120   return vnet_listen (a);
 121 }
 122
 123 session_error_t
 124 vnet_unbind_uri (vnet_unlisten_args_t *a)
 125 {
 126   session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
 127   application_t *app;
 128   session_t *listener;
 129   u32 table_index;
 130   session_error_t rv;
 131
 132   if ((rv = parse_uri (a->uri, &sep)))
 133     return rv;
 134
 135   app = application_get (a->app_index);
 136   if (!app)
 137     return SESSION_E_INVALID;
 138
 139   table_index = application_session_table (app, fib_ip_proto (!sep.is_ip4));
 140   listener = session_lookup_listener (table_index,
 141                                       (session_endpoint_t *) & sep);
 142   if (!listener)
 143     return SESSION_E_ADDR_NOT_IN_USE;
 144   a->handle = listen_session_get_handle (listener);
 145   return vnet_unlisten (a);
 146 }
 147
 148 session_error_t
 149 vnet_connect_uri (vnet_connect_args_t *a)
 150 {
 151   session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
 152   session_error_t rv;
 153
 154   if ((rv = parse_uri (a->uri, &sep)))
 155     return rv;
 156
 157   clib_memcpy (&a->sep_ext, &sep, sizeof (sep));
 158   if ((rv = vnet_connect (a)))
 159     return rv;
 160   return 0;
 161 }
 162
 163 /*
 164  * fd.io coding-style-patch-verification: ON
 165  *
 166  * Local Variables:
 167  * eval: (c-set-style "gnu")
 168  * End:
 169  */