interface: fix check in set_interface_name api
[vpp.git] / src / vnet / interface_api.c
1 /*
2  *------------------------------------------------------------------
3  * interface_api.c - vnet interface api
4  *
5  * Copyright (c) 2016 Cisco and/or its affiliates.
6  * Licensed under the Apache License, Version 2.0 (the "License");
7  * you may not use this file except in compliance with the License.
8  * You may obtain a copy of the License at:
9  *
10  *     http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  *------------------------------------------------------------------
18  */
19
20 #define _GNU_SOURCE
21 #include <string.h>
22
23 #include <vnet/vnet.h>
24 #include <vlibmemory/api.h>
25
26 #include <vnet/interface.h>
27 #include <vnet/interface/rx_queue_funcs.h>
28 #include <vnet/interface/tx_queue_funcs.h>
29 #include <vnet/api_errno.h>
30 #include <vnet/ethernet/ethernet.h>
31 #include <vnet/ip/ip.h>
32 #include <vnet/fib/fib_table.h>
33 #include <vnet/mfib/mfib_table.h>
34 #include <vnet/l2/l2_vtr.h>
35 #include <vnet/fib/fib_api.h>
36 #include <vnet/mfib/mfib_table.h>
37 #include <vlibapi/api_types.h>
38
39 #include <vnet/format_fns.h>
40 #include <vnet/ip/ip_types_api.h>
41 #include <vnet/ethernet/ethernet_types_api.h>
42
43 #include <interface.api_enum.h>
44 #include <interface.api_types.h>
45
46 #define REPLY_MSG_ID_BASE msg_id_base
47 #include <vlibapi/api_helper_macros.h>
48
49 static u16 msg_id_base;
50
51 vpe_api_main_t vpe_api_main;
52
53 #define foreach_vpe_api_msg                                                   \
54   _ (SW_INTERFACE_SET_FLAGS, sw_interface_set_flags)                          \
55   _ (SW_INTERFACE_SET_PROMISC, sw_interface_set_promisc)                      \
56   _ (HW_INTERFACE_SET_MTU, hw_interface_set_mtu)                              \
57   _ (SW_INTERFACE_SET_MTU, sw_interface_set_mtu)                              \
58   _ (WANT_INTERFACE_EVENTS, want_interface_events)                            \
59   _ (SW_INTERFACE_DUMP, sw_interface_dump)                                    \
60   _ (SW_INTERFACE_ADD_DEL_ADDRESS, sw_interface_add_del_address)              \
61   _ (SW_INTERFACE_SET_RX_MODE, sw_interface_set_rx_mode)                      \
62   _ (SW_INTERFACE_RX_PLACEMENT_DUMP, sw_interface_rx_placement_dump)          \
63   _ (SW_INTERFACE_TX_PLACEMENT_GET, sw_interface_tx_placement_get)            \
64   _ (SW_INTERFACE_SET_RX_PLACEMENT, sw_interface_set_rx_placement)            \
65   _ (SW_INTERFACE_SET_TX_PLACEMENT, sw_interface_set_tx_placement)            \
66   _ (SW_INTERFACE_SET_TABLE, sw_interface_set_table)                          \
67   _ (SW_INTERFACE_GET_TABLE, sw_interface_get_table)                          \
68   _ (SW_INTERFACE_SET_UNNUMBERED, sw_interface_set_unnumbered)                \
69   _ (SW_INTERFACE_CLEAR_STATS, sw_interface_clear_stats)                      \
70   _ (SW_INTERFACE_TAG_ADD_DEL, sw_interface_tag_add_del)                      \
71   _ (SW_INTERFACE_ADD_DEL_MAC_ADDRESS, sw_interface_add_del_mac_address)      \
72   _ (SW_INTERFACE_SET_MAC_ADDRESS, sw_interface_set_mac_address)              \
73   _ (SW_INTERFACE_GET_MAC_ADDRESS, sw_interface_get_mac_address)              \
74   _ (CREATE_VLAN_SUBIF, create_vlan_subif)                                    \
75   _ (CREATE_SUBIF, create_subif)                                              \
76   _ (DELETE_SUBIF, delete_subif)                                              \
77   _ (CREATE_LOOPBACK, create_loopback)                                        \
78   _ (CREATE_LOOPBACK_INSTANCE, create_loopback_instance)                      \
79   _ (DELETE_LOOPBACK, delete_loopback)                                        \
80   _ (INTERFACE_NAME_RENUMBER, interface_name_renumber)                        \
81   _ (COLLECT_DETAILED_INTERFACE_STATS, collect_detailed_interface_stats)      \
82   _ (SW_INTERFACE_SET_IP_DIRECTED_BROADCAST,                                  \
83      sw_interface_set_ip_directed_broadcast)                                  \
84   _ (SW_INTERFACE_ADDRESS_REPLACE_BEGIN, sw_interface_address_replace_begin)  \
85   _ (SW_INTERFACE_ADDRESS_REPLACE_END, sw_interface_address_replace_end)
86
87 static void
88 vl_api_sw_interface_set_flags_t_handler (vl_api_sw_interface_set_flags_t * mp)
89 {
90   vl_api_sw_interface_set_flags_reply_t *rmp;
91   vnet_main_t *vnm = vnet_get_main ();
92   int rv = 0;
93   clib_error_t *error;
94   u16 flags;
95
96   VALIDATE_SW_IF_INDEX (mp);
97
98   flags =
99     ((ntohl (mp->flags)) & IF_STATUS_API_FLAG_ADMIN_UP) ?
100     VNET_SW_INTERFACE_FLAG_ADMIN_UP : 0;
101
102   error = vnet_sw_interface_set_flags (vnm, ntohl (mp->sw_if_index), flags);
103   if (error)
104     {
105       rv = -1;
106       clib_error_report (error);
107     }
108
109   BAD_SW_IF_INDEX_LABEL;
110   REPLY_MACRO (VL_API_SW_INTERFACE_SET_FLAGS_REPLY);
111 }
112
113 static void
114 vl_api_sw_interface_set_promisc_t_handler (
115   vl_api_sw_interface_set_promisc_t *mp)
116 {
117   vl_api_sw_interface_set_promisc_reply_t *rmp;
118   vnet_main_t *vnm = vnet_get_main ();
119   ethernet_main_t *em = &ethernet_main;
120   int rv = 0;
121   ethernet_interface_t *eif;
122   vnet_sw_interface_t *swif;
123   u32 flags, sw_if_index;
124
125   VALIDATE_SW_IF_INDEX (mp);
126
127   sw_if_index = ntohl (mp->sw_if_index);
128   swif = vnet_get_sw_interface (vnm, sw_if_index);
129   eif = ethernet_get_interface (em, swif->hw_if_index);
130   if (!eif)
131     {
132       rv = VNET_API_ERROR_INVALID_VALUE;
133       goto done;
134     }
135
136   flags = mp->promisc_on ? ETHERNET_INTERFACE_FLAG_ACCEPT_ALL : 0;
137   rv = ethernet_set_flags (vnm, swif->hw_if_index, flags);
138
139 done:
140   BAD_SW_IF_INDEX_LABEL;
141   REPLY_MACRO (VL_API_SW_INTERFACE_SET_PROMISC_REPLY);
142 }
143
144 static void
145 vl_api_hw_interface_set_mtu_t_handler (vl_api_hw_interface_set_mtu_t * mp)
146 {
147   vl_api_hw_interface_set_mtu_reply_t *rmp;
148   vnet_main_t *vnm = vnet_get_main ();
149   u32 sw_if_index = ntohl (mp->sw_if_index);
150   u16 mtu = ntohs (mp->mtu);
151   ethernet_main_t *em = &ethernet_main;
152   clib_error_t *err;
153   int rv = 0;
154
155   VALIDATE_SW_IF_INDEX (mp);
156
157   vnet_sw_interface_t *si = vnet_get_sw_interface (vnm, sw_if_index);
158   if (si->type != VNET_SW_INTERFACE_TYPE_HARDWARE)
159     {
160       rv = VNET_API_ERROR_INVALID_VALUE;
161       goto bad_sw_if_index;
162     }
163
164   ethernet_interface_t *eif = ethernet_get_interface (em, si->hw_if_index);
165
166   if (!eif)
167     {
168       rv = VNET_API_ERROR_FEATURE_DISABLED;
169       goto bad_sw_if_index;
170     }
171
172   if ((err = vnet_hw_interface_set_mtu (vnm, si->hw_if_index, mtu)))
173     {
174       rv = vnet_api_error (err);
175       clib_error_free (err);
176       goto bad_sw_if_index;
177     }
178
179   BAD_SW_IF_INDEX_LABEL;
180   REPLY_MACRO (VL_API_HW_INTERFACE_SET_MTU_REPLY);
181 }
182
183 static void
184 vl_api_sw_interface_set_mtu_t_handler (vl_api_sw_interface_set_mtu_t * mp)
185 {
186   vl_api_sw_interface_set_mtu_reply_t *rmp;
187   vnet_main_t *vnm = vnet_get_main ();
188   u32 sw_if_index = ntohl (mp->sw_if_index);
189   int rv = 0;
190   int i;
191   u32 per_protocol_mtu[VNET_N_MTU];
192
193   VALIDATE_SW_IF_INDEX (mp);
194
195   for (i = 0; i < VNET_N_MTU; i++)
196     {
197       per_protocol_mtu[i] = ntohl (mp->mtu[i]);
198     }
199   vnet_sw_interface_set_protocol_mtu (vnm, sw_if_index, per_protocol_mtu);
200
201   BAD_SW_IF_INDEX_LABEL;
202   REPLY_MACRO (VL_API_SW_INTERFACE_SET_MTU_REPLY);
203 }
204
205 static void
206   vl_api_sw_interface_set_ip_directed_broadcast_t_handler
207   (vl_api_sw_interface_set_ip_directed_broadcast_t * mp)
208 {
209   vl_api_sw_interface_set_ip_directed_broadcast_reply_t *rmp;
210   u32 sw_if_index = ntohl (mp->sw_if_index);
211   int rv = 0;
212
213   VALIDATE_SW_IF_INDEX (mp);
214
215   vnet_sw_interface_ip_directed_broadcast (vnet_get_main (),
216                                            sw_if_index, mp->enable);
217
218   BAD_SW_IF_INDEX_LABEL;
219   REPLY_MACRO (VL_API_SW_INTERFACE_SET_IP_DIRECTED_BROADCAST_REPLY);
220 }
221
222 static void
223 send_sw_interface_details (vpe_api_main_t * am,
224                            vl_api_registration_t * rp,
225                            vnet_sw_interface_t * swif,
226                            u8 * interface_name, u32 context)
227 {
228   vnet_hw_interface_t *hi =
229     vnet_get_sup_hw_interface (am->vnet_main, swif->sw_if_index);
230   vnet_device_class_t *dev_class =
231     vnet_get_device_class (am->vnet_main, hi->dev_class_index);
232
233   vl_api_sw_interface_details_t *mp = vl_msg_api_alloc (sizeof (*mp));
234   clib_memset (mp, 0, sizeof (*mp));
235   mp->_vl_msg_id = ntohs (REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_DETAILS);
236   mp->sw_if_index = ntohl (swif->sw_if_index);
237   mp->sup_sw_if_index = ntohl (swif->sup_sw_if_index);
238
239   mp->flags |= (swif->flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP) ?
240     IF_STATUS_API_FLAG_ADMIN_UP : 0;
241   mp->flags |= (hi->flags & VNET_HW_INTERFACE_FLAG_LINK_UP) ?
242     IF_STATUS_API_FLAG_LINK_UP : 0;
243   mp->flags = ntohl (mp->flags);
244
245   switch (swif->type)
246     {
247     case VNET_SW_INTERFACE_TYPE_SUB:
248       mp->type = IF_API_TYPE_SUB;
249       break;
250     case VNET_SW_INTERFACE_TYPE_P2P:
251       mp->type = IF_API_TYPE_P2P;
252       break;
253     case VNET_SW_INTERFACE_TYPE_PIPE:
254       mp->type = IF_API_TYPE_PIPE;
255       break;
256     default:
257       mp->type = IF_API_TYPE_HARDWARE;
258     }
259   mp->type = ntohl (mp->type);
260
261   mp->link_duplex = ntohl (((hi->flags & VNET_HW_INTERFACE_FLAG_DUPLEX_MASK) >>
262                             VNET_HW_INTERFACE_FLAG_DUPLEX_SHIFT));
263   mp->link_speed = ntohl (hi->link_speed);
264   mp->link_mtu = ntohs (hi->max_frame_size - hi->frame_overhead);
265   mp->mtu[VNET_MTU_L3] = ntohl (swif->mtu[VNET_MTU_L3]);
266   mp->mtu[VNET_MTU_IP4] = ntohl (swif->mtu[VNET_MTU_IP4]);
267   mp->mtu[VNET_MTU_IP6] = ntohl (swif->mtu[VNET_MTU_IP6]);
268   mp->mtu[VNET_MTU_MPLS] = ntohl (swif->mtu[VNET_MTU_MPLS]);
269
270   mp->context = context;
271
272   strncpy ((char *) mp->interface_name,
273            (char *) interface_name, ARRAY_LEN (mp->interface_name) - 1);
274
275   if (dev_class && dev_class->name)
276     strncpy ((char *) mp->interface_dev_type, (char *) dev_class->name,
277              ARRAY_LEN (mp->interface_dev_type) - 1);
278
279   /* Send the L2 address for ethernet physical intfcs */
280   if (swif->sup_sw_if_index == swif->sw_if_index
281       && hi->hw_class_index == ethernet_hw_interface_class.index)
282     {
283       ethernet_main_t *em = ethernet_get_main (am->vlib_main);
284       ethernet_interface_t *ei;
285
286       ei = pool_elt_at_index (em->interfaces, hi->hw_instance);
287       ASSERT (sizeof (mp->l2_address) >= sizeof (ei->address.mac));
288       mac_address_encode (&ei->address.mac, mp->l2_address);
289     }
290   else if (swif->sup_sw_if_index != swif->sw_if_index)
291     {
292       vnet_sub_interface_t *sub = &swif->sub;
293       mp->sub_id = ntohl (sub->id);
294       mp->sub_number_of_tags =
295         sub->eth.flags.one_tag + sub->eth.flags.two_tags * 2;
296       mp->sub_outer_vlan_id = ntohs (sub->eth.outer_vlan_id);
297       mp->sub_inner_vlan_id = ntohs (sub->eth.inner_vlan_id);
298       mp->sub_if_flags =
299         ntohl (sub->eth.raw_flags & SUB_IF_API_FLAG_MASK_VNET);
300     }
301
302   /* vlan tag rewrite data */
303   u32 vtr_op = L2_VTR_DISABLED;
304   u32 vtr_push_dot1q = 0, vtr_tag1 = 0, vtr_tag2 = 0;
305
306   if (l2vtr_get (am->vlib_main, am->vnet_main, swif->sw_if_index,
307                  &vtr_op, &vtr_push_dot1q, &vtr_tag1, &vtr_tag2) != 0)
308     {
309       // error - default to disabled
310       mp->vtr_op = ntohl (L2_VTR_DISABLED);
311       clib_warning ("cannot get vlan tag rewrite for sw_if_index %d",
312                     swif->sw_if_index);
313     }
314   else
315     {
316       mp->vtr_op = ntohl (vtr_op);
317       mp->vtr_push_dot1q = ntohl (vtr_push_dot1q);
318       mp->vtr_tag1 = ntohl (vtr_tag1);
319       mp->vtr_tag2 = ntohl (vtr_tag2);
320     }
321
322   /* pbb tag rewrite data */
323   ethernet_header_t eth_hdr;
324   u32 pbb_vtr_op = L2_VTR_DISABLED;
325   u16 outer_tag = 0;
326   u16 b_vlanid = 0;
327   u32 i_sid = 0;
328   clib_memset (&eth_hdr, 0, sizeof (eth_hdr));
329
330   if (!l2pbb_get (am->vlib_main, am->vnet_main, swif->sw_if_index,
331                   &pbb_vtr_op, &outer_tag, &eth_hdr, &b_vlanid, &i_sid))
332     {
333       mp->sub_if_flags |= ntohl (SUB_IF_API_FLAG_DOT1AH);
334       mac_address_encode ((mac_address_t *) eth_hdr.dst_address, mp->b_dmac);
335       mac_address_encode ((mac_address_t *) eth_hdr.src_address, mp->b_smac);
336       mp->b_vlanid = b_vlanid;
337       mp->i_sid = i_sid;
338     }
339
340   u8 *tag = vnet_get_sw_interface_tag (vnet_get_main (), swif->sw_if_index);
341   if (tag)
342     strncpy ((char *) mp->tag, (char *) tag, ARRAY_LEN (mp->tag) - 1);
343
344   vl_api_send_msg (rp, (u8 *) mp);
345 }
346
347 static void
348 vl_api_sw_interface_dump_t_handler (vl_api_sw_interface_dump_t * mp)
349 {
350   vpe_api_main_t *am = &vpe_api_main;
351   vnet_sw_interface_t *swif;
352   vnet_interface_main_t *im = &am->vnet_main->interface_main;
353   vl_api_registration_t *rp;
354   u32 sw_if_index;
355
356   rp = vl_api_client_index_to_registration (mp->client_index);
357
358   if (rp == 0)
359     {
360       clib_warning ("Client %d AWOL", mp->client_index);
361       return;
362     }
363
364   u8 *filter = 0, *name = 0;
365   sw_if_index = ntohl (mp->sw_if_index);
366
367   if (!mp->name_filter_valid && sw_if_index != ~0 && sw_if_index != 0)
368     {
369       /* is it a valid sw_if_index? */
370       if (!vnet_sw_if_index_is_api_valid (sw_if_index))
371         return;
372
373       swif = vec_elt_at_index (im->sw_interfaces, sw_if_index);
374
375       vec_reset_length (name);
376       name =
377         format (name, "%U%c", format_vnet_sw_interface_name, am->vnet_main,
378                 swif, 0);
379       send_sw_interface_details (am, rp, swif, name, mp->context);
380       vec_free (name);
381       return;
382     }
383
384   if (mp->name_filter_valid)
385     {
386       filter = vl_api_from_api_to_new_vec (mp, &mp->name_filter);
387       vec_add1 (filter, 0);     /* Ensure it's a C string for strcasecmp() */
388     }
389
390   pool_foreach (swif, im->sw_interfaces)
391    {
392     if (!vnet_swif_is_api_visible (swif))
393         continue;
394     vec_reset_length(name);
395     name = format (name, "%U%c", format_vnet_sw_interface_name, am->vnet_main,
396                    swif, 0);
397
398     if (filter && !strcasestr((char *) name, (char *) filter))
399         continue;
400
401     send_sw_interface_details (am, rp, swif, name, mp->context);
402   }
403
404   vec_free (name);
405   vec_free (filter);
406 }
407
408 static void
409   vl_api_sw_interface_add_del_address_t_handler
410   (vl_api_sw_interface_add_del_address_t * mp)
411 {
412   vlib_main_t *vm = vlib_get_main ();
413   vnet_main_t *vnm = vnet_get_main ();
414   vl_api_sw_interface_add_del_address_reply_t *rmp;
415   int rv = 0;
416   u32 is_del;
417   clib_error_t *error = 0;
418   ip46_address_t address;
419
420   VALIDATE_SW_IF_INDEX (mp);
421
422   is_del = mp->is_add == 0;
423   vnm->api_errno = 0;
424
425   if (mp->del_all)
426     ip_del_all_interface_addresses (vm, ntohl (mp->sw_if_index));
427   else if (ip_address_decode (&mp->prefix.address, &address) == IP46_TYPE_IP6)
428     error = ip6_add_del_interface_address (vm, ntohl (mp->sw_if_index),
429                                            (void *) &address.ip6,
430                                            mp->prefix.len, is_del);
431   else
432     error = ip4_add_del_interface_address (vm, ntohl (mp->sw_if_index),
433                                            (void *) &address.ip4,
434                                            mp->prefix.len, is_del);
435
436   if (error)
437     {
438       rv = vnm->api_errno;
439       clib_error_report (error);
440       goto done;
441     }
442
443   BAD_SW_IF_INDEX_LABEL;
444
445 done:
446   REPLY_MACRO (VL_API_SW_INTERFACE_ADD_DEL_ADDRESS_REPLY);
447 }
448
449 static void
450 vl_api_sw_interface_set_table_t_handler (vl_api_sw_interface_set_table_t * mp)
451 {
452   vl_api_sw_interface_set_table_reply_t *rmp;
453   u32 sw_if_index = ntohl (mp->sw_if_index);
454   u32 table_id = ntohl (mp->vrf_id);
455   int rv = 0;
456
457   VALIDATE_SW_IF_INDEX (mp);
458
459   if (mp->is_ipv6)
460     rv = ip_table_bind (FIB_PROTOCOL_IP6, sw_if_index, table_id);
461   else
462     rv = ip_table_bind (FIB_PROTOCOL_IP4, sw_if_index, table_id);
463
464   BAD_SW_IF_INDEX_LABEL;
465
466   REPLY_MACRO (VL_API_SW_INTERFACE_SET_TABLE_REPLY);
467 }
468
469 void
470 fib_table_bind (fib_protocol_t fproto, u32 sw_if_index, u32 fib_index)
471 {
472   u32 table_id;
473
474   table_id = fib_table_get_table_id (fib_index, fproto);
475   ASSERT (table_id != ~0);
476
477   if (FIB_PROTOCOL_IP6 == fproto)
478     {
479       /*
480        * tell those that are interested that the binding is changing.
481        */
482       ip6_table_bind_callback_t *cb;
483       vec_foreach (cb, ip6_main.table_bind_callbacks)
484         cb->function (&ip6_main, cb->function_opaque,
485                       sw_if_index,
486                       fib_index,
487                       ip6_main.fib_index_by_sw_if_index[sw_if_index]);
488
489       /* unlock currently assigned tables */
490       if (0 != ip6_main.fib_index_by_sw_if_index[sw_if_index])
491         fib_table_unlock (ip6_main.fib_index_by_sw_if_index[sw_if_index],
492                           FIB_PROTOCOL_IP6, FIB_SOURCE_INTERFACE);
493
494       if (0 != table_id)
495         {
496           /* we need to lock the table now it's inuse */
497           fib_table_lock (fib_index, FIB_PROTOCOL_IP6, FIB_SOURCE_INTERFACE);
498         }
499
500       ip6_main.fib_index_by_sw_if_index[sw_if_index] = fib_index;
501     }
502   else
503     {
504       /*
505        * tell those that are interested that the binding is changing.
506        */
507       ip4_table_bind_callback_t *cb;
508       vec_foreach (cb, ip4_main.table_bind_callbacks)
509         cb->function (&ip4_main, cb->function_opaque,
510                       sw_if_index,
511                       fib_index,
512                       ip4_main.fib_index_by_sw_if_index[sw_if_index]);
513
514       /* unlock currently assigned tables */
515       if (0 != ip4_main.fib_index_by_sw_if_index[sw_if_index])
516         fib_table_unlock (ip4_main.fib_index_by_sw_if_index[sw_if_index],
517                           FIB_PROTOCOL_IP4, FIB_SOURCE_INTERFACE);
518
519       if (0 != table_id)
520         {
521           /* we need to lock the table now it's inuse */
522           fib_index = fib_table_find_or_create_and_lock (
523             FIB_PROTOCOL_IP4, table_id, FIB_SOURCE_INTERFACE);
524         }
525
526       ip4_main.fib_index_by_sw_if_index[sw_if_index] = fib_index;
527     }
528 }
529
530 void
531 mfib_table_bind (fib_protocol_t fproto, u32 sw_if_index, u32 mfib_index)
532 {
533   u32 table_id;
534
535   table_id = mfib_table_get_table_id (mfib_index, fproto);
536   ASSERT (table_id != ~0);
537
538   if (FIB_PROTOCOL_IP6 == fproto)
539     {
540       if (0 != ip6_main.mfib_index_by_sw_if_index[sw_if_index])
541         mfib_table_unlock (ip6_main.mfib_index_by_sw_if_index[sw_if_index],
542                            FIB_PROTOCOL_IP6, MFIB_SOURCE_INTERFACE);
543
544       if (0 != table_id)
545         {
546           /* we need to lock the table now it's inuse */
547           mfib_table_lock (mfib_index, FIB_PROTOCOL_IP6,
548                            MFIB_SOURCE_INTERFACE);
549         }
550
551       ip6_main.mfib_index_by_sw_if_index[sw_if_index] = mfib_index;
552     }
553   else
554     {
555       if (0 != ip4_main.mfib_index_by_sw_if_index[sw_if_index])
556         mfib_table_unlock (ip4_main.mfib_index_by_sw_if_index[sw_if_index],
557                            FIB_PROTOCOL_IP4, MFIB_SOURCE_INTERFACE);
558
559       if (0 != table_id)
560         {
561           /* we need to lock the table now it's inuse */
562           mfib_index = mfib_table_find_or_create_and_lock (
563             FIB_PROTOCOL_IP4, table_id, MFIB_SOURCE_INTERFACE);
564         }
565
566       ip4_main.mfib_index_by_sw_if_index[sw_if_index] = mfib_index;
567     }
568 }
569
570 int
571 ip_table_bind (fib_protocol_t fproto, u32 sw_if_index, u32 table_id)
572 {
573   CLIB_UNUSED (ip_interface_address_t * ia);
574   u32 fib_index, mfib_index;
575
576   /*
577    * This if table does not exist = error is what we want in the end.
578    */
579   fib_index = fib_table_find (fproto, table_id);
580   mfib_index = mfib_table_find (fproto, table_id);
581
582   if (~0 == fib_index || ~0 == mfib_index)
583     {
584       return (VNET_API_ERROR_NO_SUCH_FIB);
585     }
586
587   /*
588    * If the interface already has in IP address, then a change int
589    * VRF is not allowed. The IP address applied must first be removed.
590    * We do not do that automatically here, since VPP has no knowledge
591    * of whether those subnets are valid in the destination VRF.
592    */
593   /* clang-format off */
594   foreach_ip_interface_address (FIB_PROTOCOL_IP6 == fproto ?
595                                 &ip6_main.lookup_main : &ip4_main.lookup_main,
596                                 ia, sw_if_index,
597                                 1 /* honor unnumbered */ ,
598   ({
599     return (VNET_API_ERROR_ADDRESS_FOUND_FOR_INTERFACE);
600   }));
601   /* clang-format on */
602
603   fib_table_bind (fproto, sw_if_index, fib_index);
604   mfib_table_bind (fproto, sw_if_index, mfib_index);
605
606   return (0);
607 }
608
609 static void
610 send_sw_interface_get_table_reply (vl_api_registration_t * reg,
611                                    u32 context, int retval, u32 vrf_id)
612 {
613   vl_api_sw_interface_get_table_reply_t *mp;
614
615   mp = vl_msg_api_alloc (sizeof (*mp));
616   clib_memset (mp, 0, sizeof (*mp));
617   mp->_vl_msg_id =
618     ntohs (REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_GET_TABLE_REPLY);
619   mp->context = context;
620   mp->retval = htonl (retval);
621   mp->vrf_id = htonl (vrf_id);
622
623   vl_api_send_msg (reg, (u8 *) mp);
624 }
625
626 static void
627 vl_api_sw_interface_get_table_t_handler (vl_api_sw_interface_get_table_t * mp)
628 {
629   vl_api_registration_t *reg;
630   fib_table_t *fib_table = 0;
631   u32 sw_if_index = ~0;
632   u32 fib_index = ~0;
633   u32 table_id = ~0;
634   fib_protocol_t fib_proto = FIB_PROTOCOL_IP4;
635   int rv = 0;
636
637   reg = vl_api_client_index_to_registration (mp->client_index);
638   if (!reg)
639     return;
640
641   VALIDATE_SW_IF_INDEX (mp);
642
643   sw_if_index = ntohl (mp->sw_if_index);
644
645   if (mp->is_ipv6)
646     fib_proto = FIB_PROTOCOL_IP6;
647
648   fib_index = fib_table_get_index_for_sw_if_index (fib_proto, sw_if_index);
649   if (fib_index != ~0)
650     {
651       fib_table = fib_table_get (fib_index, fib_proto);
652       table_id = fib_table->ft_table_id;
653     }
654
655   BAD_SW_IF_INDEX_LABEL;
656
657   send_sw_interface_get_table_reply (reg, mp->context, rv, table_id);
658 }
659
660 static void vl_api_sw_interface_set_unnumbered_t_handler
661   (vl_api_sw_interface_set_unnumbered_t * mp)
662 {
663   vl_api_sw_interface_set_unnumbered_reply_t *rmp;
664   int rv = 0;
665   vnet_main_t *vnm = vnet_get_main ();
666   u32 sw_if_index = ntohl (mp->sw_if_index);
667   u32 unnumbered_sw_if_index = ntohl (mp->unnumbered_sw_if_index);
668
669   /*
670    * The API message field names are backwards from
671    * the underlying data structure names.
672    * It's not worth changing them now.
673    */
674   if (!vnet_sw_interface_is_api_valid (vnm, unnumbered_sw_if_index))
675     {
676       rv = VNET_API_ERROR_INVALID_SW_IF_INDEX;
677       goto done;
678     }
679
680   /* Only check the "use loop0" field when setting the binding */
681   if (mp->is_add && !vnet_sw_interface_is_api_valid (vnm, sw_if_index))
682     {
683       rv = VNET_API_ERROR_INVALID_SW_IF_INDEX_2;
684       goto done;
685     }
686
687   rv = vnet_sw_interface_update_unnumbered (unnumbered_sw_if_index,
688                                             sw_if_index, mp->is_add);
689 done:
690   REPLY_MACRO (VL_API_SW_INTERFACE_SET_UNNUMBERED_REPLY);
691 }
692
693 static void
694 vl_api_sw_interface_clear_stats_t_handler (vl_api_sw_interface_clear_stats_t *
695                                            mp)
696 {
697   vl_api_sw_interface_clear_stats_reply_t *rmp;
698
699   vnet_main_t *vnm = vnet_get_main ();
700   vnet_interface_main_t *im = &vnm->interface_main;
701   vlib_simple_counter_main_t *sm;
702   vlib_combined_counter_main_t *cm;
703   int j, n_counters;
704   int rv = 0;
705
706   if (mp->sw_if_index != ~0)
707     VALIDATE_SW_IF_INDEX (mp);
708
709   n_counters = vec_len (im->combined_sw_if_counters);
710
711   for (j = 0; j < n_counters; j++)
712     {
713       im = &vnm->interface_main;
714       cm = im->combined_sw_if_counters + j;
715       if (mp->sw_if_index == (u32) ~ 0)
716         vlib_clear_combined_counters (cm);
717       else
718         vlib_zero_combined_counter (cm, ntohl (mp->sw_if_index));
719     }
720
721   n_counters = vec_len (im->sw_if_counters);
722
723   for (j = 0; j < n_counters; j++)
724     {
725       im = &vnm->interface_main;
726       sm = im->sw_if_counters + j;
727       if (mp->sw_if_index == (u32) ~ 0)
728         vlib_clear_simple_counters (sm);
729       else
730         vlib_zero_simple_counter (sm, ntohl (mp->sw_if_index));
731     }
732
733   BAD_SW_IF_INDEX_LABEL;
734
735   REPLY_MACRO (VL_API_SW_INTERFACE_CLEAR_STATS_REPLY);
736 }
737
738 /*
739  * Events used for sw_interface_events
740  */
741 enum api_events
742 {
743   API_LINK_STATE_UP_EVENT = 1 << 1,
744   API_LINK_STATE_DOWN_EVENT = 1 << 2,
745   API_ADMIN_UP_EVENT = 1 << 3,
746   API_ADMIN_DOWN_EVENT = 1 << 4,
747   API_SW_INTERFACE_ADD_EVENT = 1 << 5,
748   API_SW_INTERFACE_DEL_EVENT = 1 << 6,
749 };
750
751 static void
752 send_sw_interface_event (vpe_api_main_t * am,
753                          vpe_client_registration_t * reg,
754                          vl_api_registration_t * vl_reg,
755                          u32 sw_if_index, enum api_events events)
756 {
757   vl_api_sw_interface_event_t *mp;
758
759   mp = vl_msg_api_alloc (sizeof (*mp));
760   clib_memset (mp, 0, sizeof (*mp));
761   mp->_vl_msg_id = ntohs (REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_EVENT);
762   mp->sw_if_index = ntohl (sw_if_index);
763   mp->client_index = reg->client_index;
764   mp->pid = reg->client_pid;
765   mp->flags = 0;
766   mp->flags |= (events & API_ADMIN_UP_EVENT) ?
767     IF_STATUS_API_FLAG_ADMIN_UP : 0;
768   mp->flags |= (events & API_LINK_STATE_UP_EVENT) ?
769     IF_STATUS_API_FLAG_LINK_UP : 0;
770   mp->flags = ntohl (mp->flags);
771   mp->deleted = events & API_SW_INTERFACE_DEL_EVENT ? true : false;
772   vl_api_send_msg (vl_reg, (u8 *) mp);
773 }
774
775 static uword
776 link_state_process (vlib_main_t * vm,
777                     vlib_node_runtime_t * rt, vlib_frame_t * f)
778 {
779   vpe_api_main_t *vam = &vpe_api_main;
780   uword *event_by_sw_if_index = 0;
781   vpe_client_registration_t *reg;
782   int i;
783   vl_api_registration_t *vl_reg;
784   uword event_type;
785   uword *event_data = 0;
786   u32 sw_if_index;
787
788   vam->link_state_process_up = 1;
789
790   while (1)
791     {
792       vlib_process_wait_for_event (vm);
793
794       /* Batch up events */
795       while ((event_type = vlib_process_get_events (vm, &event_data)) != ~0)
796         {
797           for (i = 0; i < vec_len (event_data); i++)
798             {
799               sw_if_index = event_data[i];
800               vec_validate_init_empty (event_by_sw_if_index, sw_if_index, 0);
801               event_by_sw_if_index[sw_if_index] |= event_type;
802             }
803           vec_reset_length (event_data);
804         }
805
806       for (i = 0; i < vec_len (event_by_sw_if_index); i++)
807         {
808           if (event_by_sw_if_index[i] == 0)
809             continue;
810
811           pool_foreach (reg, vam->interface_events_registrations)
812            {
813             vl_reg = vl_api_client_index_to_registration (reg->client_index);
814             if (vl_reg)
815               send_sw_interface_event (vam, reg, vl_reg, i, event_by_sw_if_index[i]);
816           }
817         }
818       vec_reset_length (event_by_sw_if_index);
819     }
820
821   return 0;
822 }
823
824 static clib_error_t *link_up_down_function (vnet_main_t * vm, u32 hw_if_index,
825                                             u32 flags);
826 static clib_error_t *admin_up_down_function (vnet_main_t * vm,
827                                              u32 hw_if_index, u32 flags);
828 static clib_error_t *sw_interface_add_del_function (vnet_main_t * vm,
829                                                     u32 sw_if_index,
830                                                     u32 flags);
831
832 VLIB_REGISTER_NODE (link_state_process_node,static) = {
833   .function = link_state_process,
834   .type = VLIB_NODE_TYPE_PROCESS,
835   .name = "vpe-link-state-process",
836 };
837
838 VNET_SW_INTERFACE_ADMIN_UP_DOWN_FUNCTION (admin_up_down_function);
839 VNET_HW_INTERFACE_LINK_UP_DOWN_FUNCTION (link_up_down_function);
840 VNET_SW_INTERFACE_ADD_DEL_FUNCTION (sw_interface_add_del_function);
841
842 static clib_error_t *
843 link_up_down_function (vnet_main_t * vm, u32 hw_if_index, u32 flags)
844 {
845   vpe_api_main_t *vam = &vpe_api_main;
846   vnet_hw_interface_t *hi = vnet_get_hw_interface (vm, hw_if_index);
847
848   if (vam->link_state_process_up)
849     {
850       enum api_events event = ((flags & VNET_HW_INTERFACE_FLAG_LINK_UP) ?
851                                API_LINK_STATE_UP_EVENT :
852                                API_LINK_STATE_DOWN_EVENT);
853       vlib_process_signal_event (vam->vlib_main,
854                                  link_state_process_node.index, event,
855                                  hi->sw_if_index);
856     }
857   return 0;
858 }
859
860 static clib_error_t *
861 admin_up_down_function (vnet_main_t * vm, u32 sw_if_index, u32 flags)
862 {
863   vpe_api_main_t *vam = &vpe_api_main;
864
865   /*
866    * Note: it's perfectly fair to set a subif admin up / admin down.
867    * Note the subtle distinction between this routine and the previous
868    * routine.
869    */
870   if (vam->link_state_process_up)
871     {
872       enum api_events event = ((flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP) ?
873                                API_ADMIN_UP_EVENT : API_ADMIN_DOWN_EVENT);
874       vlib_process_signal_event (vam->vlib_main,
875                                  link_state_process_node.index, event,
876                                  sw_if_index);
877     }
878   return 0;
879 }
880
881 static clib_error_t *
882 sw_interface_add_del_function (vnet_main_t * vm, u32 sw_if_index, u32 flags)
883 {
884   vpe_api_main_t *vam = &vpe_api_main;
885
886   if (vam->link_state_process_up)
887     {
888       enum api_events event =
889         flags ? API_SW_INTERFACE_ADD_EVENT : API_SW_INTERFACE_DEL_EVENT;
890       vlib_process_signal_event (vam->vlib_main,
891                                  link_state_process_node.index, event,
892                                  sw_if_index);
893     }
894   return 0;
895 }
896
897 static void vl_api_sw_interface_tag_add_del_t_handler
898   (vl_api_sw_interface_tag_add_del_t * mp)
899 {
900   vnet_main_t *vnm = vnet_get_main ();
901   vl_api_sw_interface_tag_add_del_reply_t *rmp;
902   int rv = 0;
903   u8 *tag;
904   u32 sw_if_index = ntohl (mp->sw_if_index);
905
906   VALIDATE_SW_IF_INDEX (mp);
907
908   if (mp->is_add)
909     {
910       if (mp->tag[0] == 0)
911         {
912           rv = VNET_API_ERROR_INVALID_VALUE;
913           goto out;
914         }
915
916       mp->tag[ARRAY_LEN (mp->tag) - 1] = 0;
917       tag = format (0, "%s%c", mp->tag, 0);
918       vnet_set_sw_interface_tag (vnm, tag, sw_if_index);
919     }
920   else
921     vnet_clear_sw_interface_tag (vnm, sw_if_index);
922
923   BAD_SW_IF_INDEX_LABEL;
924 out:
925   REPLY_MACRO (VL_API_SW_INTERFACE_TAG_ADD_DEL_REPLY);
926 }
927
928 static void vl_api_sw_interface_add_del_mac_address_t_handler
929   (vl_api_sw_interface_add_del_mac_address_t * mp)
930 {
931   vl_api_sw_interface_add_del_mac_address_reply_t *rmp;
932   vnet_main_t *vnm = vnet_get_main ();
933   u32 sw_if_index = ntohl (mp->sw_if_index);
934   vnet_hw_interface_t *hi;
935   clib_error_t *error;
936   int rv = 0;
937
938   VALIDATE_SW_IF_INDEX (mp);
939
940   /* for subifs, the MAC should be changed on the actual hw if */
941   hi = vnet_get_sup_hw_interface (vnm, sw_if_index);
942   error = vnet_hw_interface_add_del_mac_address (vnm, hi->hw_if_index,
943                                                  mp->addr, mp->is_add);
944   if (error)
945     {
946       rv = VNET_API_ERROR_UNIMPLEMENTED;
947       clib_error_report (error);
948       goto out;
949     }
950
951   BAD_SW_IF_INDEX_LABEL;
952 out:
953   REPLY_MACRO (VL_API_SW_INTERFACE_ADD_DEL_MAC_ADDRESS_REPLY);
954 }
955
956 static void vl_api_sw_interface_set_mac_address_t_handler
957   (vl_api_sw_interface_set_mac_address_t * mp)
958 {
959   vl_api_sw_interface_set_mac_address_reply_t *rmp;
960   vnet_main_t *vnm = vnet_get_main ();
961   u32 sw_if_index = ntohl (mp->sw_if_index);
962   vnet_sw_interface_t *si;
963   clib_error_t *error;
964   int rv = 0;
965   mac_address_t mac;
966
967   VALIDATE_SW_IF_INDEX (mp);
968
969   si = vnet_get_sw_interface (vnm, sw_if_index);
970   mac_address_decode (mp->mac_address, &mac);
971   error =
972     vnet_hw_interface_change_mac_address (vnm, si->hw_if_index, (u8 *) & mac);
973   if (error)
974     {
975       rv = VNET_API_ERROR_UNIMPLEMENTED;
976       clib_error_report (error);
977       goto out;
978     }
979
980   BAD_SW_IF_INDEX_LABEL;
981 out:
982   REPLY_MACRO (VL_API_SW_INTERFACE_SET_MAC_ADDRESS_REPLY);
983 }
984
985 static void vl_api_sw_interface_get_mac_address_t_handler
986   (vl_api_sw_interface_get_mac_address_t * mp)
987 {
988   vl_api_sw_interface_get_mac_address_reply_t *rmp;
989   vl_api_registration_t *reg;
990   vnet_main_t *vnm = vnet_get_main ();
991   u32 sw_if_index = ntohl (mp->sw_if_index);
992   vnet_sw_interface_t *si;
993   ethernet_interface_t *eth_if = 0;
994   int rv = 0;
995
996   VALIDATE_SW_IF_INDEX (mp);
997
998   si = vnet_get_sup_sw_interface (vnm, sw_if_index);
999   if (si->type == VNET_SW_INTERFACE_TYPE_HARDWARE)
1000     eth_if = ethernet_get_interface (&ethernet_main, si->hw_if_index);
1001
1002   BAD_SW_IF_INDEX_LABEL;
1003
1004   reg = vl_api_client_index_to_registration (mp->client_index);
1005   if (!reg)
1006     return;
1007   rmp = vl_msg_api_alloc (sizeof (*rmp));
1008   rmp->_vl_msg_id =
1009     htons (REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_GET_MAC_ADDRESS_REPLY);
1010   rmp->context = mp->context;
1011   rmp->retval = htonl (rv);
1012   if (!rv && eth_if)
1013     mac_address_encode (&eth_if->address.mac, rmp->mac_address);
1014   vl_api_send_msg (reg, (u8 *) rmp);
1015 }
1016
1017 static void
1018 vl_api_sw_interface_set_interface_name_t_handler (
1019   vl_api_sw_interface_set_interface_name_t *mp)
1020 {
1021   vl_api_sw_interface_set_interface_name_reply_t *rmp;
1022   vnet_main_t *vnm = vnet_get_main ();
1023   clib_error_t *error;
1024   int rv = 0;
1025
1026   VALIDATE_SW_IF_INDEX (mp);
1027
1028   u32 sw_if_index = ntohl (mp->sw_if_index);
1029   vnet_sw_interface_t *si = vnet_get_sw_interface (vnm, sw_if_index);
1030
1031   if (mp->name[0] == 0)
1032     {
1033       rv = VNET_API_ERROR_INVALID_VALUE;
1034       goto out;
1035     }
1036
1037   error = vnet_rename_interface (vnm, si->hw_if_index, (char *) mp->name);
1038   if (error)
1039     {
1040       clib_error_free (error);
1041       rv = VNET_API_ERROR_INVALID_SW_IF_INDEX;
1042     }
1043
1044 out:
1045   BAD_SW_IF_INDEX_LABEL;
1046   REPLY_MACRO (VL_API_SW_INTERFACE_SET_INTERFACE_NAME_REPLY);
1047 }
1048
1049 static void vl_api_sw_interface_set_rx_mode_t_handler
1050   (vl_api_sw_interface_set_rx_mode_t * mp)
1051 {
1052   vl_api_sw_interface_set_rx_mode_reply_t *rmp;
1053   vnet_main_t *vnm = vnet_get_main ();
1054   u32 sw_if_index = ntohl (mp->sw_if_index);
1055   vnet_sw_interface_t *si;
1056   clib_error_t *error;
1057   int rv = 0;
1058   vnet_hw_if_rx_mode rx_mode;
1059
1060   VALIDATE_SW_IF_INDEX (mp);
1061
1062   si = vnet_get_sw_interface (vnm, sw_if_index);
1063   if (si->type != VNET_SW_INTERFACE_TYPE_HARDWARE)
1064     {
1065       rv = VNET_API_ERROR_INVALID_VALUE;
1066       goto bad_sw_if_index;
1067     }
1068
1069   rx_mode = (vnet_hw_if_rx_mode) ntohl (mp->mode);
1070   error = set_hw_interface_change_rx_mode (vnm, si->hw_if_index,
1071                                            mp->queue_id_valid,
1072                                            ntohl (mp->queue_id),
1073                                            (vnet_hw_if_rx_mode) rx_mode);
1074
1075   if (error)
1076     {
1077       rv = VNET_API_ERROR_UNIMPLEMENTED;
1078       clib_error_report (error);
1079       goto out;
1080     }
1081
1082   BAD_SW_IF_INDEX_LABEL;
1083 out:
1084   REPLY_MACRO (VL_API_SW_INTERFACE_SET_RX_MODE_REPLY);
1085 }
1086
1087 static void
1088 send_interface_rx_placement_details (vpe_api_main_t * am,
1089                                      vl_api_registration_t * rp,
1090                                      u32 sw_if_index, u32 worker_id,
1091                                      u32 queue_id, u8 mode, u32 context)
1092 {
1093   vl_api_sw_interface_rx_placement_details_t *mp;
1094   mp = vl_msg_api_alloc (sizeof (*mp));
1095   clib_memset (mp, 0, sizeof (*mp));
1096
1097   mp->_vl_msg_id =
1098     htons (REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_RX_PLACEMENT_DETAILS);
1099   mp->sw_if_index = htonl (sw_if_index);
1100   mp->queue_id = htonl (queue_id);
1101   mp->worker_id = htonl (worker_id);
1102   mp->mode = htonl (mode);
1103   mp->context = context;
1104
1105   vl_api_send_msg (rp, (u8 *) mp);
1106 }
1107
1108 static void vl_api_sw_interface_rx_placement_dump_t_handler
1109   (vl_api_sw_interface_rx_placement_dump_t * mp)
1110 {
1111   vnet_main_t *vnm = vnet_get_main ();
1112   vpe_api_main_t *am = &vpe_api_main;
1113   u32 sw_if_index = ntohl (mp->sw_if_index);
1114   vl_api_registration_t *reg;
1115
1116   reg = vl_api_client_index_to_registration (mp->client_index);
1117   if (!reg)
1118     return;
1119
1120   if (sw_if_index == ~0)
1121     {
1122       vnet_hw_if_rx_queue_t **all_queues = 0;
1123       vnet_hw_if_rx_queue_t **qptr;
1124       vnet_hw_if_rx_queue_t *q;
1125       pool_foreach (q, vnm->interface_main.hw_if_rx_queues)
1126         vec_add1 (all_queues, q);
1127       vec_sort_with_function (all_queues, vnet_hw_if_rxq_cmp_cli_api);
1128
1129       vec_foreach (qptr, all_queues)
1130         {
1131           u32 current_thread = qptr[0]->thread_index;
1132           u32 hw_if_index = qptr[0]->hw_if_index;
1133           vnet_hw_interface_t *hw_if =
1134             vnet_get_hw_interface (vnm, hw_if_index);
1135           send_interface_rx_placement_details (
1136             am, reg, hw_if->sw_if_index, current_thread, qptr[0]->queue_id,
1137             qptr[0]->mode, mp->context);
1138         }
1139       vec_free (all_queues);
1140     }
1141   else
1142     {
1143       int i;
1144       vnet_sw_interface_t *si;
1145
1146       if (!vnet_sw_if_index_is_api_valid (sw_if_index))
1147         {
1148           clib_warning ("sw_if_index %u does not exist", sw_if_index);
1149           goto bad_sw_if_index;
1150         }
1151
1152       si = vnet_get_sw_interface (vnm, sw_if_index);
1153       if (si->type != VNET_SW_INTERFACE_TYPE_HARDWARE)
1154         {
1155           clib_warning ("interface type is not HARDWARE! P2P, PIPE and SUB"
1156                         " interfaces are not supported");
1157           goto bad_sw_if_index;
1158         }
1159
1160       vnet_hw_interface_t *hw = vnet_get_hw_interface (vnm, si->hw_if_index);
1161
1162       for (i = 0; i < vec_len (hw->rx_queue_indices); i++)
1163         {
1164           vnet_hw_if_rx_queue_t *rxq =
1165             vnet_hw_if_get_rx_queue (vnm, hw->rx_queue_indices[i]);
1166           send_interface_rx_placement_details (
1167             am, reg, hw->sw_if_index, rxq->thread_index, rxq->queue_id,
1168             rxq->mode, mp->context);
1169         }
1170     }
1171
1172   BAD_SW_IF_INDEX_LABEL;
1173 }
1174
1175 static void vl_api_sw_interface_set_rx_placement_t_handler
1176   (vl_api_sw_interface_set_rx_placement_t * mp)
1177 {
1178   vl_api_sw_interface_set_rx_placement_reply_t *rmp;
1179   vnet_main_t *vnm = vnet_get_main ();
1180   u32 sw_if_index = ntohl (mp->sw_if_index);
1181   vnet_sw_interface_t *si;
1182   clib_error_t *error = 0;
1183   int rv = 0;
1184
1185   VALIDATE_SW_IF_INDEX (mp);
1186
1187   si = vnet_get_sw_interface (vnm, sw_if_index);
1188   if (si->type != VNET_SW_INTERFACE_TYPE_HARDWARE)
1189     {
1190       rv = VNET_API_ERROR_INVALID_VALUE;
1191       goto bad_sw_if_index;
1192     }
1193
1194   error = set_hw_interface_rx_placement (si->hw_if_index,
1195                                          ntohl (mp->queue_id),
1196                                          ntohl (mp->worker_id), mp->is_main);
1197   if (error)
1198     {
1199       rv = VNET_API_ERROR_UNIMPLEMENTED;
1200       clib_error_report (error);
1201       goto out;
1202     }
1203
1204   BAD_SW_IF_INDEX_LABEL;
1205 out:
1206   REPLY_MACRO (VL_API_SW_INTERFACE_SET_RX_PLACEMENT_REPLY);
1207 }
1208
1209 static void
1210 send_interface_tx_placement_details (vnet_hw_if_tx_queue_t **all_queues,
1211                                      u32 index, vl_api_registration_t *rp,
1212                                      u32 context)
1213 {
1214   vnet_main_t *vnm = vnet_get_main ();
1215   vl_api_sw_interface_tx_placement_details_t *rmp;
1216   u32 n_bits = 0, v = ~0;
1217   vnet_hw_if_tx_queue_t **q = vec_elt_at_index (all_queues, index);
1218   uword *bitmap = q[0]->threads;
1219   u32 hw_if_index = q[0]->hw_if_index;
1220   vnet_hw_interface_t *hw_if = vnet_get_hw_interface (vnm, hw_if_index);
1221
1222   n_bits = clib_bitmap_count_set_bits (bitmap);
1223   u32 n = n_bits * sizeof (u32);
1224
1225   REPLY_MACRO_DETAILS5_END (VL_API_SW_INTERFACE_TX_PLACEMENT_DETAILS, n, rp,
1226                             context, ({
1227                               rmp->sw_if_index = hw_if->sw_if_index;
1228                               rmp->queue_id = q[0]->queue_id;
1229                               rmp->shared = q[0]->shared_queue;
1230                               rmp->array_size = n_bits;
1231
1232                               v = clib_bitmap_first_set (bitmap);
1233                               for (u32 i = 0; i < n_bits; i++)
1234                                 {
1235                                   rmp->threads[i] = v;
1236                                   v = clib_bitmap_next_set (bitmap, v + 1);
1237                                 }
1238                             }));
1239 }
1240
1241 static void
1242 vl_api_sw_interface_tx_placement_get_t_handler (
1243   vl_api_sw_interface_tx_placement_get_t *mp)
1244 {
1245   vnet_main_t *vnm = vnet_get_main ();
1246   vl_api_sw_interface_tx_placement_get_reply_t *rmp = 0;
1247   vnet_hw_if_tx_queue_t **all_queues = 0;
1248   vnet_hw_if_tx_queue_t *q;
1249   u32 sw_if_index = mp->sw_if_index;
1250   i32 rv = 0;
1251
1252   if (pool_elts (vnm->interface_main.hw_if_tx_queues) == 0)
1253     {
1254       rv = VNET_API_ERROR_NO_SUCH_ENTRY;
1255       goto err;
1256     }
1257
1258   if (sw_if_index == ~0)
1259     {
1260       pool_foreach (q, vnm->interface_main.hw_if_tx_queues)
1261         vec_add1 (all_queues, q);
1262       vec_sort_with_function (all_queues, vnet_hw_if_txq_cmp_cli_api);
1263     }
1264   else
1265     {
1266       u32 qi = ~0;
1267       vnet_sw_interface_t *si;
1268
1269       if (!vnet_sw_if_index_is_api_valid (sw_if_index))
1270         {
1271           clib_warning ("sw_if_index %u does not exist", sw_if_index);
1272           rv = VNET_API_ERROR_INVALID_SW_IF_INDEX;
1273           goto err;
1274         }
1275
1276       si = vnet_get_sw_interface (vnm, sw_if_index);
1277       if (si->type != VNET_SW_INTERFACE_TYPE_HARDWARE)
1278         {
1279           clib_warning ("interface type is not HARDWARE! P2P, PIPE and SUB"
1280                         " interfaces are not supported");
1281           rv = VNET_API_ERROR_INVALID_INTERFACE;
1282           goto err;
1283         }
1284
1285       vnet_hw_interface_t *hw = vnet_get_hw_interface (vnm, si->hw_if_index);
1286       for (qi = 0; qi < vec_len (hw->tx_queue_indices); qi++)
1287         {
1288           q = vnet_hw_if_get_tx_queue (vnm, hw->tx_queue_indices[qi]);
1289           vec_add1 (all_queues, q);
1290         }
1291     }
1292
1293   REPLY_AND_DETAILS_VEC_MACRO_END (VL_API_SW_INTERFACE_TX_PLACEMENT_GET_REPLY,
1294                                    all_queues, mp, rmp, rv, ({
1295                                      send_interface_tx_placement_details (
1296                                        all_queues, cursor, rp, mp->context);
1297                                    }));
1298
1299   vec_free (all_queues);
1300   return;
1301
1302 err:
1303   REPLY_MACRO_END (VL_API_SW_INTERFACE_TX_PLACEMENT_GET_REPLY);
1304 }
1305
1306 static void
1307 vl_api_sw_interface_set_tx_placement_t_handler (
1308   vl_api_sw_interface_set_tx_placement_t *mp)
1309 {
1310   vl_api_sw_interface_set_tx_placement_reply_t *rmp;
1311   vnet_main_t *vnm = vnet_get_main ();
1312   u32 sw_if_index = mp->sw_if_index;
1313   vnet_sw_interface_t *si;
1314   uword *bitmap = 0;
1315   u32 queue_id = ~0;
1316   u32 size = 0;
1317   clib_error_t *error = 0;
1318   int rv = 0;
1319
1320   VALIDATE_SW_IF_INDEX_END (mp);
1321
1322   si = vnet_get_sw_interface (vnm, sw_if_index);
1323   if (si->type != VNET_SW_INTERFACE_TYPE_HARDWARE)
1324     {
1325       rv = VNET_API_ERROR_INVALID_VALUE;
1326       goto bad_sw_if_index;
1327     }
1328
1329   size = mp->array_size;
1330   for (u32 i = 0; i < size; i++)
1331     {
1332       u32 thread_index = mp->threads[i];
1333       bitmap = clib_bitmap_set (bitmap, thread_index, 1);
1334     }
1335
1336   queue_id = mp->queue_id;
1337   rv = set_hw_interface_tx_queue (si->hw_if_index, queue_id, bitmap);
1338
1339   switch (rv)
1340     {
1341     case VNET_API_ERROR_INVALID_VALUE:
1342       error = clib_error_return (
1343         0, "please specify valid thread(s) - last thread index %u",
1344         clib_bitmap_last_set (bitmap));
1345       break;
1346     case VNET_API_ERROR_INVALID_QUEUE:
1347       error = clib_error_return (
1348         0, "unknown queue %u on interface %s", queue_id,
1349         vnet_get_hw_interface (vnet_get_main (), si->hw_if_index)->name);
1350       break;
1351     default:
1352       break;
1353     }
1354
1355   if (error)
1356     {
1357       clib_error_report (error);
1358       goto out;
1359     }
1360
1361   BAD_SW_IF_INDEX_LABEL;
1362 out:
1363   REPLY_MACRO_END (VL_API_SW_INTERFACE_SET_TX_PLACEMENT_REPLY);
1364   clib_bitmap_free (bitmap);
1365 }
1366
1367 static void
1368 vl_api_create_vlan_subif_t_handler (vl_api_create_vlan_subif_t * mp)
1369 {
1370   vl_api_create_vlan_subif_reply_t *rmp;
1371   vnet_main_t *vnm = vnet_get_main ();
1372   u32 sw_if_index = (u32) ~ 0;
1373   vnet_hw_interface_t *hi;
1374   int rv = 0;
1375   u32 id;
1376   vnet_sw_interface_t template;
1377   uword *p;
1378   vnet_interface_main_t *im = &vnm->interface_main;
1379   u64 sup_and_sub_key;
1380   vl_api_registration_t *reg;
1381   clib_error_t *error;
1382
1383   VALIDATE_SW_IF_INDEX (mp);
1384
1385   hi = vnet_get_sup_hw_interface (vnm, ntohl (mp->sw_if_index));
1386
1387   if (hi->bond_info == VNET_HW_INTERFACE_BOND_INFO_SLAVE)
1388     {
1389       rv = VNET_API_ERROR_BOND_SLAVE_NOT_ALLOWED;
1390       goto out;
1391     }
1392
1393   id = ntohl (mp->vlan_id);
1394   if (id == 0 || id > 4095)
1395     {
1396       rv = VNET_API_ERROR_INVALID_VLAN;
1397       goto out;
1398     }
1399
1400   sup_and_sub_key = ((u64) (hi->sw_if_index) << 32) | (u64) id;
1401
1402   p = hash_get_mem (im->sw_if_index_by_sup_and_sub, &sup_and_sub_key);
1403   if (p)
1404     {
1405       rv = VNET_API_ERROR_VLAN_ALREADY_EXISTS;
1406       goto out;
1407     }
1408
1409   clib_memset (&template, 0, sizeof (template));
1410   template.type = VNET_SW_INTERFACE_TYPE_SUB;
1411   template.flood_class = VNET_FLOOD_CLASS_NORMAL;
1412   template.sup_sw_if_index = hi->sw_if_index;
1413   template.sub.id = id;
1414   template.sub.eth.raw_flags = 0;
1415   template.sub.eth.flags.one_tag = 1;
1416   template.sub.eth.outer_vlan_id = id;
1417   template.sub.eth.flags.exact_match = 1;
1418
1419   error = vnet_create_sw_interface (vnm, &template, &sw_if_index);
1420   if (error)
1421     {
1422       clib_error_report (error);
1423       rv = VNET_API_ERROR_INVALID_REGISTRATION;
1424       goto out;
1425     }
1426
1427   u64 *kp = clib_mem_alloc (sizeof (*kp));
1428   *kp = sup_and_sub_key;
1429
1430   hash_set (hi->sub_interface_sw_if_index_by_id, id, sw_if_index);
1431   hash_set_mem (im->sw_if_index_by_sup_and_sub, kp, sw_if_index);
1432
1433   BAD_SW_IF_INDEX_LABEL;
1434
1435 out:
1436   reg = vl_api_client_index_to_registration (mp->client_index);
1437   if (!reg)
1438     return;
1439
1440   rmp = vl_msg_api_alloc (sizeof (*rmp));
1441   rmp->_vl_msg_id = htons (REPLY_MSG_ID_BASE + VL_API_CREATE_VLAN_SUBIF_REPLY);
1442   rmp->context = mp->context;
1443   rmp->retval = htonl (rv);
1444   rmp->sw_if_index = htonl (sw_if_index);
1445   vl_api_send_msg (reg, (u8 *) rmp);
1446 }
1447
1448 static void
1449 vl_api_create_subif_t_handler (vl_api_create_subif_t * mp)
1450 {
1451   vl_api_create_subif_reply_t *rmp;
1452   vnet_main_t *vnm = vnet_get_main ();
1453   u32 sub_sw_if_index = ~0;
1454   vnet_hw_interface_t *hi;
1455   int rv = 0;
1456
1457   VALIDATE_SW_IF_INDEX (mp);
1458
1459   hi = vnet_get_sup_hw_interface (vnm, ntohl (mp->sw_if_index));
1460
1461   if (hi->bond_info == VNET_HW_INTERFACE_BOND_INFO_SLAVE)
1462     rv = VNET_API_ERROR_BOND_SLAVE_NOT_ALLOWED;
1463   else
1464     rv = vnet_create_sub_interface (ntohl (mp->sw_if_index),
1465                                     ntohl (mp->sub_id),
1466                                     ntohl (mp->sub_if_flags),
1467                                     ntohs (mp->inner_vlan_id),
1468                                     ntohs (mp->outer_vlan_id),
1469                                     &sub_sw_if_index);
1470
1471   BAD_SW_IF_INDEX_LABEL;
1472
1473   REPLY_MACRO2(VL_API_CREATE_SUBIF_REPLY,
1474   ({
1475     rmp->sw_if_index = ntohl(sub_sw_if_index);
1476   }));
1477 }
1478
1479 static void
1480 vl_api_delete_subif_t_handler (vl_api_delete_subif_t * mp)
1481 {
1482   vl_api_delete_subif_reply_t *rmp;
1483   int rv;
1484
1485   rv = vnet_delete_sub_interface (ntohl (mp->sw_if_index));
1486
1487   REPLY_MACRO (VL_API_DELETE_SUBIF_REPLY);
1488 }
1489
1490 static void
1491 vl_api_interface_name_renumber_t_handler (vl_api_interface_name_renumber_t *
1492                                           mp)
1493 {
1494   vl_api_interface_name_renumber_reply_t *rmp;
1495   int rv = 0;
1496
1497   VALIDATE_SW_IF_INDEX (mp);
1498
1499   rv = vnet_interface_name_renumber
1500     (ntohl (mp->sw_if_index), ntohl (mp->new_show_dev_instance));
1501
1502   BAD_SW_IF_INDEX_LABEL;
1503
1504   REPLY_MACRO (VL_API_INTERFACE_NAME_RENUMBER_REPLY);
1505 }
1506
1507 static void
1508 vl_api_create_loopback_t_handler (vl_api_create_loopback_t * mp)
1509 {
1510   vl_api_create_loopback_reply_t *rmp;
1511   u32 sw_if_index;
1512   int rv;
1513   mac_address_t mac;
1514
1515   mac_address_decode (mp->mac_address, &mac);
1516   rv = vnet_create_loopback_interface (&sw_if_index, (u8 *) & mac, 0, 0);
1517
1518   REPLY_MACRO2(VL_API_CREATE_LOOPBACK_REPLY,
1519   ({
1520     rmp->sw_if_index = ntohl (sw_if_index);
1521   }));
1522 }
1523
1524 static void vl_api_create_loopback_instance_t_handler
1525   (vl_api_create_loopback_instance_t * mp)
1526 {
1527   vl_api_create_loopback_instance_reply_t *rmp;
1528   u32 sw_if_index;
1529   u8 is_specified = mp->is_specified;
1530   u32 user_instance = ntohl (mp->user_instance);
1531   int rv;
1532   mac_address_t mac;
1533
1534   mac_address_decode (mp->mac_address, &mac);
1535   rv = vnet_create_loopback_interface (&sw_if_index, (u8 *) & mac,
1536                                        is_specified, user_instance);
1537
1538   REPLY_MACRO2(VL_API_CREATE_LOOPBACK_INSTANCE_REPLY,
1539   ({
1540     rmp->sw_if_index = ntohl (sw_if_index);
1541   }));
1542 }
1543
1544 static void
1545 vl_api_delete_loopback_t_handler (vl_api_delete_loopback_t * mp)
1546 {
1547   vl_api_delete_loopback_reply_t *rmp;
1548   u32 sw_if_index;
1549   int rv;
1550
1551   sw_if_index = ntohl (mp->sw_if_index);
1552   rv = vnet_delete_loopback_interface (sw_if_index);
1553
1554   REPLY_MACRO (VL_API_DELETE_LOOPBACK_REPLY);
1555 }
1556
1557 static void
1558   vl_api_collect_detailed_interface_stats_t_handler
1559   (vl_api_collect_detailed_interface_stats_t * mp)
1560 {
1561   vl_api_collect_detailed_interface_stats_reply_t *rmp;
1562   int rv = 0;
1563
1564   rv =
1565     vnet_sw_interface_stats_collect_enable_disable (ntohl (mp->sw_if_index),
1566                                                     mp->enable_disable);
1567
1568   REPLY_MACRO (VL_API_COLLECT_DETAILED_INTERFACE_STATS_REPLY);
1569 }
1570
1571 static void
1572   vl_api_sw_interface_address_replace_begin_t_handler
1573   (vl_api_sw_interface_address_replace_begin_t * mp)
1574 {
1575   vl_api_sw_interface_address_replace_begin_reply_t *rmp;
1576   int rv = 0;
1577
1578   ip_interface_address_mark ();
1579
1580   REPLY_MACRO (VL_API_SW_INTERFACE_ADDRESS_REPLACE_BEGIN_REPLY);
1581 }
1582
1583 static void
1584   vl_api_sw_interface_address_replace_end_t_handler
1585   (vl_api_sw_interface_address_replace_end_t * mp)
1586 {
1587   vl_api_sw_interface_address_replace_end_reply_t *rmp;
1588   int rv = 0;
1589
1590   ip_interface_address_sweep ();
1591
1592   REPLY_MACRO (VL_API_SW_INTERFACE_ADDRESS_REPLACE_END_REPLY);
1593 }
1594
1595 static void
1596 vl_api_pcap_set_filter_function_t_handler (
1597   vl_api_pcap_set_filter_function_t *mp)
1598 {
1599   vnet_main_t *vnm = vnet_get_main ();
1600   vnet_pcap_t *pp = &vnm->pcap;
1601   vl_api_pcap_set_filter_function_reply_t *rmp;
1602   unformat_input_t input = { 0 };
1603   vlib_is_packet_traced_fn_t *f;
1604   char *filter_name;
1605   int rv = 0;
1606   filter_name = vl_api_from_api_to_new_c_string (&mp->filter_function_name);
1607   unformat_init_cstring (&input, filter_name);
1608   if (unformat (&input, "%U", unformat_vlib_trace_filter_function, &f) == 0)
1609     {
1610       rv = -1;
1611       goto done;
1612     }
1613
1614   pp->current_filter_function = f;
1615
1616 done:
1617   unformat_free (&input);
1618   vec_free (filter_name);
1619   REPLY_MACRO (VL_API_PCAP_SET_FILTER_FUNCTION_REPLY);
1620 }
1621
1622 static void
1623 vl_api_pcap_trace_on_t_handler (vl_api_pcap_trace_on_t *mp)
1624 {
1625   vl_api_pcap_trace_on_reply_t *rmp;
1626   unformat_input_t filename, drop_err_name;
1627   vnet_pcap_dispatch_trace_args_t capture_args;
1628   int rv = 0;
1629
1630   VALIDATE_SW_IF_INDEX (mp);
1631
1632   unformat_init_cstring (&filename, (char *) mp->filename);
1633   if (!unformat_user (&filename, unformat_vlib_tmpfile,
1634                       &capture_args.filename))
1635     {
1636       rv = VNET_API_ERROR_ILLEGAL_NAME;
1637       goto out;
1638     }
1639
1640   capture_args.rx_enable = mp->capture_rx;
1641   capture_args.tx_enable = mp->capture_tx;
1642   capture_args.preallocate_data = mp->preallocate_data;
1643   capture_args.free_data = mp->free_data;
1644   capture_args.drop_enable = mp->capture_drop;
1645   capture_args.status = 0;
1646   capture_args.packets_to_capture = ntohl (mp->max_packets);
1647   capture_args.sw_if_index = ntohl (mp->sw_if_index);
1648   capture_args.filter = mp->filter;
1649   capture_args.max_bytes_per_pkt = ntohl (mp->max_bytes_per_packet);
1650   capture_args.drop_err = ~0;
1651
1652   unformat_init_cstring (&drop_err_name, (char *) mp->error);
1653   unformat_user (&drop_err_name, unformat_vlib_error, vlib_get_main (),
1654                  &capture_args.drop_err);
1655
1656   rv = vnet_pcap_dispatch_trace_configure (&capture_args);
1657
1658   BAD_SW_IF_INDEX_LABEL;
1659
1660 out:
1661   unformat_free (&filename);
1662   unformat_free (&drop_err_name);
1663
1664   REPLY_MACRO (VL_API_PCAP_TRACE_ON_REPLY);
1665 }
1666
1667 static void
1668 vl_api_pcap_trace_off_t_handler (vl_api_pcap_trace_off_t *mp)
1669 {
1670   vl_api_pcap_trace_off_reply_t *rmp;
1671   vnet_pcap_dispatch_trace_args_t capture_args;
1672   int rv = 0;
1673
1674   clib_memset (&capture_args, 0, sizeof (capture_args));
1675
1676   rv = vnet_pcap_dispatch_trace_configure (&capture_args);
1677
1678   REPLY_MACRO (VL_API_PCAP_TRACE_OFF_REPLY);
1679 }
1680
1681 /*
1682  * vpe_api_hookup
1683  * Add vpe's API message handlers to the table.
1684  * vlib has already mapped shared memory and
1685  * added the client registration handlers.
1686  * See .../vlib-api/vlibmemory/memclnt_vlib.c:memclnt_process()
1687  */
1688
1689 pub_sub_handler (interface_events, INTERFACE_EVENTS);
1690
1691 #include <vnet/interface.api.c>
1692 static clib_error_t *
1693 interface_api_hookup (vlib_main_t * vm)
1694 {
1695   api_main_t *am = vlibapi_get_main ();
1696
1697   /*
1698    * Set up the (msg_name, crc, message-id) table
1699    */
1700   REPLY_MSG_ID_BASE = setup_message_id_table ();
1701
1702   /* Mark these APIs as mp safe */
1703   vl_api_set_msg_thread_safe (am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_DUMP,
1704                               1);
1705   vl_api_set_msg_thread_safe (
1706     am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_DETAILS, 1);
1707   vl_api_set_msg_thread_safe (
1708     am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_TAG_ADD_DEL, 1);
1709   vl_api_set_msg_thread_safe (
1710     am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_SET_INTERFACE_NAME, 1);
1711
1712   /* Do not replay VL_API_SW_INTERFACE_DUMP messages */
1713   vl_api_allow_msg_replay (am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_DUMP,
1714                            0);
1715
1716   /* Mark these APIs as autoendian */
1717   vl_api_set_msg_autoendian (
1718     am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_SET_TX_PLACEMENT, 1);
1719   vl_api_set_msg_autoendian (
1720     am, REPLY_MSG_ID_BASE + VL_API_SW_INTERFACE_TX_PLACEMENT_GET, 1);
1721
1722   return 0;
1723 }
1724
1725 VLIB_API_INIT_FUNCTION (interface_api_hookup);
1726
1727 /*
1728  * fd.io coding-style-patch-verification: ON
1729  *
1730  * Local Variables:
1731  * eval: (c-set-style "gnu")
1732  * End:
1733  */