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://[%s]%U/%d", unformat_transport_proto,
  55                      &transport_proto, &sep->hostname, unformat_ip4_address,
  56                      &sep->ip.ip4, &port))
  57     {
  58       sep->transport_proto = transport_proto;
  59       sep->port = clib_host_to_net_u16 (port);
  60       sep->is_ip4 = 1;
  61       return 1;
  62     }
  63   else if (unformat (input, "%U://%U/%d", unformat_transport_proto,
  64                      &transport_proto, unformat_ip6_address, &sep->ip.ip6,
  65                      &port))
  66     {
  67       sep->transport_proto = transport_proto;
  68       sep->port = clib_host_to_net_u16 (port);
  69       sep->is_ip4 = 0;
  70       return 1;
  71     }
  72   else if (unformat (input, "%U://[%s]%U/%d", unformat_transport_proto,
  73                      &transport_proto, &sep->hostname, unformat_ip6_address,
  74                      &sep->ip.ip6, &port))
  75     {
  76       sep->transport_proto = transport_proto;
  77       sep->port = clib_host_to_net_u16 (port);
  78       sep->is_ip4 = 0;
  79       return 1;
  80     }
  81   return 0;
  82 }
  83
  84 static u8 *cache_uri;
  85 static session_endpoint_cfg_t *cache_sep;
  86
  87 int
  88 parse_uri (char *uri, session_endpoint_cfg_t * sep)
  89 {
  90   unformat_input_t _input, *input = &_input;
  91
  92   if (cache_uri && !strncmp (uri, (char *) cache_uri, vec_len (cache_uri)))
  93     {
  94       *sep = *cache_sep;
  95       return 0;
  96     }
  97
  98   /* Make sure */
  99   uri = (char *) format (0, "%s%c", uri, 0);
 100
 101   /* Parse uri */
 102   unformat_init_string (input, uri, strlen (uri));
 103   if (!unformat (input, "%U", unformat_vnet_uri, sep))
 104     {
 105       unformat_free (input);
 106       return VNET_API_ERROR_INVALID_VALUE;
 107     }
 108   unformat_free (input);
 109
 110   vec_free (cache_uri);
 111   cache_uri = (u8 *) uri;
 112   if (cache_sep)
 113     clib_mem_free (cache_sep);
 114   cache_sep = clib_mem_alloc (sizeof (*sep));
 115   *cache_sep = *sep;
 116
 117   return 0;
 118 }
 119
 120 int
 121 vnet_bind_uri (vnet_listen_args_t * a)
 122 {
 123   session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
 124   int rv;
 125
 126   rv = parse_uri (a->uri, &sep);
 127   if (rv)
 128     return rv;
 129   sep.app_wrk_index = 0;
 130   clib_memcpy (&a->sep_ext, &sep, sizeof (sep));
 131   return vnet_listen (a);
 132 }
 133
 134 int
 135 vnet_unbind_uri (vnet_unlisten_args_t * a)
 136 {
 137   session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
 138   session_t *listener;
 139   u32 table_index;
 140   int rv;
 141
 142   if ((rv = parse_uri (a->uri, &sep)))
 143     return rv;
 144
 145   /* NOTE: only default fib tables supported for uri apis */
 146   table_index = session_lookup_get_index_for_fib (fib_ip_proto (!sep.is_ip4),
 147                                                   0);
 148   listener = session_lookup_listener (table_index,
 149                                       (session_endpoint_t *) & sep);
 150   if (!listener)
 151     return VNET_API_ERROR_ADDRESS_NOT_IN_USE;
 152   a->handle = listen_session_get_handle (listener);
 153   return vnet_unlisten (a);
 154 }
 155
 156 int
 157 vnet_connect_uri (vnet_connect_args_t * a)
 158 {
 159   session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
 160   int rv;
 161
 162   if ((rv = parse_uri (a->uri, &sep)))
 163     return rv;
 164
 165   clib_memcpy (&a->sep_ext, &sep, sizeof (sep));
 166   if ((rv = vnet_connect (a)))
 167     return rv;
 168   return 0;
 169 }
 170
 171 /*
 172  * fd.io coding-style-patch-verification: ON
 173  *
 174  * Local Variables:
 175  * eval: (c-set-style "gnu")
 176  * End:
 177  */