src/plugins/l2tp/l2tp_test.c

   1 /*
   2  * Copyright (c) 2020 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
  16 #include <vat/vat.h>
  17 #include <vlibapi/api.h>
  18 #include <vlibmemory/api.h>
  19 #include <vppinfra/error.h>
  20
  21 #include <vnet/ip/ip_format_fns.h>
  22 #include <vnet/ip/ip.h>
  23 #include <vnet/ethernet/ethernet_format_fns.h>
  24 #include <l2tp/l2tp.h>
  25
  26 /* define message IDs */
  27 #include <l2tp/l2tp.api_enum.h>
  28 #include <l2tp/l2tp.api_types.h>
  29 #include <vlibmemory/vlib.api_types.h>
  30
  31 typedef struct
  32 {
  33   /* API message ID base */
  34   u16 msg_id_base;
  35   u32 ping_id;
  36   vat_main_t *vat_main;
  37 } l2tp_test_main_t;
  38
  39 l2tp_test_main_t l2tp_test_main;
  40
  41 #define __plugin_msg_base l2tp_test_main.msg_id_base
  42 #include <vlibapi/vat_helper_macros.h>
  43
  44 /* Macro to finish up custom dump fns */
  45 #define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__)
  46 #define FINISH                                  \
  47     vec_add1 (s, 0);                            \
  48     vl_print (handle, (char *)s);               \
  49     vec_free (s);                               \
  50     return handle;
  51
  52 static void vl_api_l2tpv3_create_tunnel_reply_t_handler
  53   (vl_api_l2tpv3_create_tunnel_reply_t * mp)
  54 {
  55   vat_main_t *vam = &vat_main;
  56   i32 retval = ntohl (mp->retval);
  57   if (vam->async_mode)
  58     {
  59       vam->async_errors += (retval < 0);
  60     }
  61   else
  62     {
  63       vam->retval = retval;
  64       vam->sw_if_index = ntohl (mp->sw_if_index);
  65       vam->result_ready = 1;
  66     }
  67 }
  68
  69 static int
  70 api_l2tpv3_create_tunnel (vat_main_t * vam)
  71 {
  72   unformat_input_t *i = vam->input;
  73   ip6_address_t client_address, our_address;
  74   int client_address_set = 0;
  75   int our_address_set = 0;
  76   u32 local_session_id = 0;
  77   u32 remote_session_id = 0;
  78   u64 local_cookie = 0;
  79   u64 remote_cookie = 0;
  80   u8 l2_sublayer_present = 0;
  81   vl_api_l2tpv3_create_tunnel_t *mp;
  82   int ret;
  83
  84   while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
  85     {
  86       if (unformat (i, "client_address %U", unformat_ip6_address,
  87                     &client_address))
  88         client_address_set = 1;
  89       else if (unformat (i, "our_address %U", unformat_ip6_address,
  90                          &our_address))
  91         our_address_set = 1;
  92       else if (unformat (i, "local_session_id %d", &local_session_id))
  93         ;
  94       else if (unformat (i, "remote_session_id %d", &remote_session_id))
  95         ;
  96       else if (unformat (i, "local_cookie %lld", &local_cookie))
  97         ;
  98       else if (unformat (i, "remote_cookie %lld", &remote_cookie))
  99         ;
 100       else if (unformat (i, "l2-sublayer-present"))
 101         l2_sublayer_present = 1;
 102       else
 103         break;
 104     }
 105
 106   if (client_address_set == 0)
 107     {
 108       errmsg ("client_address required");
 109       return -99;
 110     }
 111
 112   if (our_address_set == 0)
 113     {
 114       errmsg ("our_address required");
 115       return -99;
 116     }
 117
 118   M (L2TPV3_CREATE_TUNNEL, mp);
 119
 120   clib_memcpy (mp->client_address.un.ip6, client_address.as_u8,
 121                sizeof (ip6_address_t));
 122
 123   clib_memcpy (mp->our_address.un.ip6, our_address.as_u8,
 124                sizeof (ip6_address_t));
 125
 126   mp->local_session_id = ntohl (local_session_id);
 127   mp->remote_session_id = ntohl (remote_session_id);
 128   mp->local_cookie = clib_host_to_net_u64 (local_cookie);
 129   mp->remote_cookie = clib_host_to_net_u64 (remote_cookie);
 130   mp->l2_sublayer_present = l2_sublayer_present;
 131
 132   S (mp);
 133   W (ret);
 134   return ret;
 135 }
 136
 137 static int
 138 api_l2tpv3_set_tunnel_cookies (vat_main_t * vam)
 139 {
 140   unformat_input_t *i = vam->input;
 141   u32 sw_if_index;
 142   u8 sw_if_index_set = 0;
 143   u64 new_local_cookie = 0;
 144   u64 new_remote_cookie = 0;
 145   vl_api_l2tpv3_set_tunnel_cookies_t *mp;
 146   int ret;
 147
 148   while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
 149     {
 150       if (unformat (i, "%U", unformat_sw_if_index, vam, &sw_if_index))
 151         sw_if_index_set = 1;
 152       else if (unformat (i, "sw_if_index %d", &sw_if_index))
 153         sw_if_index_set = 1;
 154       else if (unformat (i, "new_local_cookie %lld", &new_local_cookie))
 155         ;
 156       else if (unformat (i, "new_remote_cookie %lld", &new_remote_cookie))
 157         ;
 158       else
 159         break;
 160     }
 161
 162   if (sw_if_index_set == 0)
 163     {
 164       errmsg ("missing interface name or sw_if_index");
 165       return -99;
 166     }
 167
 168   M (L2TPV3_SET_TUNNEL_COOKIES, mp);
 169
 170   mp->sw_if_index = ntohl (sw_if_index);
 171   mp->new_local_cookie = clib_host_to_net_u64 (new_local_cookie);
 172   mp->new_remote_cookie = clib_host_to_net_u64 (new_remote_cookie);
 173
 174   S (mp);
 175   W (ret);
 176   return ret;
 177 }
 178
 179 static int
 180 api_l2tpv3_interface_enable_disable (vat_main_t * vam)
 181 {
 182   unformat_input_t *i = vam->input;
 183   vl_api_l2tpv3_interface_enable_disable_t *mp;
 184   u32 sw_if_index;
 185   u8 sw_if_index_set = 0;
 186   u8 enable_disable = 1;
 187   int ret;
 188
 189   while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
 190     {
 191       if (unformat (i, "%U", unformat_sw_if_index, vam, &sw_if_index))
 192         sw_if_index_set = 1;
 193       else if (unformat (i, "sw_if_index %d", &sw_if_index))
 194         sw_if_index_set = 1;
 195       else if (unformat (i, "enable"))
 196         enable_disable = 1;
 197       else if (unformat (i, "disable"))
 198         enable_disable = 0;
 199       else
 200         break;
 201     }
 202
 203   if (sw_if_index_set == 0)
 204     {
 205       errmsg ("missing interface name or sw_if_index");
 206       return -99;
 207     }
 208
 209   M (L2TPV3_INTERFACE_ENABLE_DISABLE, mp);
 210
 211   mp->sw_if_index = ntohl (sw_if_index);
 212   mp->enable_disable = enable_disable;
 213
 214   S (mp);
 215   W (ret);
 216   return ret;
 217 }
 218
 219 static int
 220 api_l2tpv3_set_lookup_key (vat_main_t * vam)
 221 {
 222   unformat_input_t *i = vam->input;
 223   vl_api_l2tpv3_set_lookup_key_t *mp;
 224   u8 key = ~0;
 225   int ret;
 226
 227   while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
 228     {
 229       if (unformat (i, "lookup_v6_src"))
 230         key = L2T_LOOKUP_SRC_ADDRESS;
 231       else if (unformat (i, "lookup_v6_dst"))
 232         key = L2T_LOOKUP_DST_ADDRESS;
 233       else if (unformat (i, "lookup_session_id"))
 234         key = L2T_LOOKUP_SESSION_ID;
 235       else
 236         break;
 237     }
 238
 239   if (key == (u8) ~ 0)
 240     {
 241       errmsg ("l2tp session lookup key unset");
 242       return -99;
 243     }
 244
 245   M (L2TPV3_SET_LOOKUP_KEY, mp);
 246
 247   mp->key = key;
 248
 249   S (mp);
 250   W (ret);
 251   return ret;
 252 }
 253
 254 static void vl_api_sw_if_l2tpv3_tunnel_details_t_handler
 255   (vl_api_sw_if_l2tpv3_tunnel_details_t * mp)
 256 {
 257   vat_main_t *vam = &vat_main;
 258
 259   print (vam->ofp, "* %U (our) %U (client) (sw_if_index %d)",
 260          format_ip6_address, mp->our_address,
 261          format_ip6_address, mp->client_address,
 262          clib_net_to_host_u32 (mp->sw_if_index));
 263
 264   print (vam->ofp,
 265          "   local cookies %016llx %016llx remote cookie %016llx",
 266          clib_net_to_host_u64 (mp->local_cookie[0]),
 267          clib_net_to_host_u64 (mp->local_cookie[1]),
 268          clib_net_to_host_u64 (mp->remote_cookie));
 269
 270   print (vam->ofp, "   local session-id %d remote session-id %d",
 271          clib_net_to_host_u32 (mp->local_session_id),
 272          clib_net_to_host_u32 (mp->remote_session_id));
 273
 274   print (vam->ofp, "   l2 specific sublayer %s\n",
 275          mp->l2_sublayer_present ? "preset" : "absent");
 276
 277 }
 278
 279 static int
 280 api_sw_if_l2tpv3_tunnel_dump (vat_main_t * vam)
 281 {
 282   vl_api_sw_if_l2tpv3_tunnel_dump_t *mp;
 283   vl_api_control_ping_t *mp_ping;
 284   int ret;
 285
 286   /* Get list of l2tpv3-tunnel interfaces */
 287   M (SW_IF_L2TPV3_TUNNEL_DUMP, mp);
 288   S (mp);
 289
 290   /* Use a control ping for synchronization */
 291   if (!l2tp_test_main.ping_id)
 292     l2tp_test_main.ping_id =
 293       vl_msg_api_get_msg_index ((u8 *) (VL_API_CONTROL_PING_CRC));
 294   mp_ping = vl_msg_api_alloc_as_if_client (sizeof (*mp_ping));
 295   mp_ping->_vl_msg_id = htons (l2tp_test_main.ping_id);
 296   mp_ping->client_index = vam->my_client_index;
 297
 298   fformat (vam->ofp, "Sending ping id=%d\n", l2tp_test_main.ping_id);
 299
 300   vam->result_ready = 0;
 301   S (mp_ping);
 302
 303   W (ret);
 304   return ret;
 305 }
 306
 307 #include <l2tp/l2tp.api_test.c>
 308
 309 /*
 310  * fd.io coding-style-patch-verification: ON
 311  *
 312  * Local Variables:
 313  * eval: (c-set-style "gnu")
 314  * End:
 315  */