2 * Copyright (c) 2015 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:
7 * http://www.apache.org/licenses/LICENSE-2.0
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.
16 #include <vnet/ip/ip.h>
17 #include <vnet/ip/ip_punt_drop.h>
18 #include <vnet/fib/fib_path_list.h>
20 ip_punt_redirect_cfg_t ip_punt_redirect_cfg;
23 format_ip_punt_redirect_trace (u8 * s, va_list * args)
25 CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
26 CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
27 ip_punt_redirect_trace_t *t = va_arg (*args, ip_punt_redirect_trace_t *);
29 if (INDEX_INVALID == t->rrxi)
30 s = format (s, "ignore");
32 s = format (s, "via redirect:%d", t->rrxi);
38 ip_punt_redirect_stack (ip_punt_redirect_rx_t * ipr)
40 dpo_id_t dpo = DPO_INVALID;
43 fib_path_list_contribute_forwarding (ipr->pl,
45 FIB_PATH_LIST_FWD_FLAG_COLLAPSE, &dpo);
47 if (FIB_PROTOCOL_IP4 == ipr->fproto)
49 vlib_get_node_by_name (vlib_get_main (), (u8 *) "ip4-punt-redirect");
52 vlib_get_node_by_name (vlib_get_main (), (u8 *) "ip6-punt-redirect");
54 dpo_stack_from_node (pnode->index, &ipr->dpo, &dpo);
59 ip_punt_redirect_find (fib_protocol_t fproto, u32 rx_sw_if_index)
63 rxs = ip_punt_redirect_cfg.redirect_by_rx_sw_if_index[fproto];
65 if (vec_len (rxs) <= rx_sw_if_index)
66 return (INDEX_INVALID);
68 return rxs[rx_sw_if_index];
72 ip_punt_redirect_add (fib_protocol_t fproto, u32 rx_sw_if_index,
73 fib_forward_chain_type_t ct,
74 const fib_route_path_t *rpaths)
76 ip_punt_redirect_rx_t *ipr;
79 if (~0 == rx_sw_if_index)
82 vec_validate_init_empty (ip_punt_redirect_cfg.redirect_by_rx_sw_if_index
83 [fproto], rx_sw_if_index, INDEX_INVALID);
85 pool_get (ip_punt_redirect_cfg.pool, ipr);
86 ipri = ipr - ip_punt_redirect_cfg.pool;
88 ip_punt_redirect_cfg.redirect_by_rx_sw_if_index[fproto][rx_sw_if_index] =
91 fib_node_init (&ipr->node, FIB_NODE_TYPE_IP_PUNT_REDIRECT);
93 ipr->payload_type = ct;
95 ipr->pl = fib_path_list_create (FIB_PATH_LIST_FLAG_NO_URPF, rpaths);
97 ipr->sibling = fib_path_list_child_add (ipr->pl,
98 FIB_NODE_TYPE_IP_PUNT_REDIRECT,
101 ip_punt_redirect_stack (ipr);
105 ip_punt_redirect_del (fib_protocol_t fproto, u32 rx_sw_if_index)
107 ip_punt_redirect_rx_t *ipr;
110 if (~0 == rx_sw_if_index)
113 rxs = ip_punt_redirect_cfg.redirect_by_rx_sw_if_index[fproto];
115 if ((vec_len (rxs) <= rx_sw_if_index) ||
116 (INDEX_INVALID == rxs[rx_sw_if_index]))
119 ipr = ip_punt_redirect_get (rxs[rx_sw_if_index]);
121 fib_path_list_child_remove (ipr->pl, ipr->sibling);
122 dpo_reset (&ipr->dpo);
123 pool_put (ip_punt_redirect_cfg.pool, ipr);
125 rxs[rx_sw_if_index] = INDEX_INVALID;
129 format_ip_punt_redirect (u8 * s, va_list * args)
131 fib_protocol_t fproto = va_arg (*args, int);
132 ip_punt_redirect_rx_t *rx;
135 vnet_main_t *vnm = vnet_get_main ();
137 rxs = ip_punt_redirect_cfg.redirect_by_rx_sw_if_index[fproto];
139 vec_foreach_index (rx_sw_if_index, rxs)
141 if (INDEX_INVALID == rxs[rx_sw_if_index])
144 rx = ip_punt_redirect_get (rxs[rx_sw_if_index]);
146 s = format (s, " rx %U via:\n",
147 format_vnet_sw_interface_name, vnm,
148 vnet_get_sw_interface (vnm, rx_sw_if_index));
149 s = format (s, " %U", format_fib_path_list, rx->pl, 2);
150 s = format (s, " forwarding\n", format_dpo_id, &rx->dpo, 0);
151 s = format (s, " %U\n", format_dpo_id, &rx->dpo, 0);
158 ip_punt_redirect_walk (fib_protocol_t fproto,
159 ip_punt_redirect_walk_cb_t cb, void *ctx)
161 ip_punt_redirect_rx_t *rx;
162 u32 ii, rx_sw_if_index;
165 rxs = ip_punt_redirect_cfg.redirect_by_rx_sw_if_index[fproto];
167 vec_foreach_index (ii, rxs)
169 if (INDEX_INVALID == rxs[ii])
172 rx = ip_punt_redirect_get (rxs[ii]);
174 rx_sw_if_index = (ii == 0 ? ~0 : ii);
175 cb (rx_sw_if_index, rx, ctx);
180 ip_punt_redirect_get_node (fib_node_index_t index)
182 ip_punt_redirect_rx_t *ipr = ip_punt_redirect_get (index);
183 return (&(ipr->node));
186 static ip_punt_redirect_rx_t *
187 ip_punt_redirect_get_from_node (fib_node_t * node)
189 return ((ip_punt_redirect_rx_t *) (((char *) node) -
190 STRUCT_OFFSET_OF (ip_punt_redirect_rx_t,
195 ip_punt_redirect_last_lock_gone (fib_node_t * node)
198 * the lifetime of the entry is managed by the table.
204 * A back walk has reached this BIER entry
206 static fib_node_back_walk_rc_t
207 ip_punt_redirect_back_walk_notify (fib_node_t * node,
208 fib_node_back_walk_ctx_t * ctx)
211 * re-populate the ECMP tables with new choices
213 ip_punt_redirect_rx_t *ipr = ip_punt_redirect_get_from_node (node);
215 ip_punt_redirect_stack (ipr);
218 * no need to propagate further up the graph, since there's nothing there
220 return (FIB_NODE_BACK_WALK_CONTINUE);
224 * The BIER fmask's graph node virtual function table
226 static const fib_node_vft_t ip_punt_redirect_vft = {
227 .fnv_get = ip_punt_redirect_get_node,
228 .fnv_last_lock = ip_punt_redirect_last_lock_gone,
229 .fnv_back_walk = ip_punt_redirect_back_walk_notify,
232 static clib_error_t *
233 ip_punt_drop_init (vlib_main_t * vm)
235 fib_node_register_type (FIB_NODE_TYPE_IP_PUNT_REDIRECT,
236 &ip_punt_redirect_vft);
238 ip4_punt_policer_cfg.fq_index =
239 vlib_frame_queue_main_init (ip4_punt_policer_node.index, 0);
240 ip6_punt_policer_cfg.fq_index =
241 vlib_frame_queue_main_init (ip6_punt_policer_node.index, 0);
246 VLIB_INIT_FUNCTION (ip_punt_drop_init);
249 * fd.io coding-style-patch-verification: ON
252 * eval: (c-set-style "gnu")