cdp_main_t cdp_main;
-#define DEBUG_TLV_DUMP 0 /* 1=> dump TLV's to stdout while processing them */
+#define DEBUG_TLV_DUMP 0 /* 1=> dump TLV's to stdout while processing them */
/* Reliable multicast messages we use to keep peers updated */
mc_serialize_msg_t serialize_cdp_neighbor_msg;
* ported from an unspecified Cisco cdp implementation.
* Compute / return in HOST byte order. 0 => good checksum.
*/
-u16 cdp_checksum (void *p, int count)
+u16
+cdp_checksum (void *p, int count)
{
- u32 sum;
- u16 i, *data;
-
- data = p;
- sum = 0;
- while (count > 1) {
- sum += ntohs(*data);
- data++;
- count -= 2;
+ u32 sum;
+ u16 i, *data;
+
+ data = p;
+ sum = 0;
+ while (count > 1)
+ {
+ sum += ntohs (*data);
+ data++;
+ count -= 2;
}
- if (count > 0)
- sum += *(char *)data;
+ if (count > 0)
+ sum += *(char *) data;
- while (sum >> 16) {
- sum = (sum & 0xFFFF) + (sum >> 16);
+ while (sum >> 16)
+ {
+ sum = (sum & 0xFFFF) + (sum >> 16);
}
- i = (i16) sum;
- return (~i);
+ i = (i16) sum;
+ return (~i);
}
/* TLV handler table */
-typedef struct {
- char *name;
- u32 tlv_id;
- void *format;
- void *process;
+typedef struct
+{
+ char *name;
+ u32 tlv_id;
+ void *format;
+ void *process;
} tlv_handler_t;
-static tlv_handler_t tlv_handlers [];
+static tlv_handler_t tlv_handlers[];
/* Display a generic TLV as a set of hex bytes */
-static u8 * format_generic_tlv (u8 * s, va_list * va)
+static u8 *
+format_generic_tlv (u8 * s, va_list * va)
{
- cdp_tlv_t *t = va_arg (*va, cdp_tlv_t *);
- tlv_handler_t *h = &tlv_handlers[t->t];
+ cdp_tlv_t *t = va_arg (*va, cdp_tlv_t *);
+ tlv_handler_t *h = &tlv_handlers[t->t];
- s = format (s, "%s(%d): %U\n", h->name,
- t->t, format_hex_bytes, t->v, t->l - sizeof (*t));
- return s;
+ s = format (s, "%s(%d): %U\n", h->name,
+ t->t, format_hex_bytes, t->v, t->l - sizeof (*t));
+ return s;
}
/* Ignore / skip a TLV we don't support */
-static cdp_error_t process_generic_tlv (cdp_main_t *cm, cdp_neighbor_t *n,
- cdp_tlv_t *t)
+static cdp_error_t
+process_generic_tlv (cdp_main_t * cm, cdp_neighbor_t * n, cdp_tlv_t * t)
{
#if DEBUG_TLV_DUMP > 0
- fformat(stdout, "%U", format_generic_tlv, t);
+ fformat (stdout, "%U", format_generic_tlv, t);
#endif
- return CDP_ERROR_NONE;
+ return CDP_ERROR_NONE;
}
/* print a text tlv */
-static u8 * format_text_tlv (u8 * s, va_list * va)
+static u8 *
+format_text_tlv (u8 * s, va_list * va)
{
- cdp_tlv_t *t = va_arg (*va, cdp_tlv_t *);
- tlv_handler_t *h = &tlv_handlers[t->t];
- int i;
-
- s = format (s, "%s(%d): ", h->name, t->t);
+ cdp_tlv_t *t = va_arg (*va, cdp_tlv_t *);
+ tlv_handler_t *h = &tlv_handlers[t->t];
+ int i;
+
+ s = format (s, "%s(%d): ", h->name, t->t);
- for (i = 0; i < (t->l - sizeof (*t)); i++)
- vec_add1(s, t->v[i]);
+ for (i = 0; i < (t->l - sizeof (*t)); i++)
+ vec_add1 (s, t->v[i]);
- vec_add1(s, '\n');
- return s;
+ vec_add1 (s, '\n');
+ return s;
}
#if DEBUG_TLV_DUMP == 0
/* gcc warning be gone */
-CLIB_UNUSED (static cdp_error_t
- process_text_tlv (cdp_main_t *cm, cdp_neighbor_t *n,
- cdp_tlv_t *t));
+CLIB_UNUSED (static cdp_error_t
+ process_text_tlv (cdp_main_t * cm, cdp_neighbor_t * n,
+ cdp_tlv_t * t));
#endif
/* process / skip a generic text TLV that we don't support */
-static cdp_error_t process_text_tlv (cdp_main_t *cm, cdp_neighbor_t *n,
- cdp_tlv_t *t)
+static cdp_error_t
+process_text_tlv (cdp_main_t * cm, cdp_neighbor_t * n, cdp_tlv_t * t)
{
#if DEBUG_TLV_DUMP > 0
- fformat(stdout, "%U\n", format_text_tlv, t);
+ fformat (stdout, "%U\n", format_text_tlv, t);
#endif
- return CDP_ERROR_NONE;
+ return CDP_ERROR_NONE;
}
/* per-TLV format function definitions */
#define format_spare_poe_tlv format_generic_tlv
/* tlv ID=0 is a mistake */
-static cdp_error_t process_unused_tlv (cdp_main_t *cm, cdp_neighbor_t *n,
- cdp_tlv_t *t)
+static cdp_error_t
+process_unused_tlv (cdp_main_t * cm, cdp_neighbor_t * n, cdp_tlv_t * t)
{
- return CDP_ERROR_BAD_TLV;
+ return CDP_ERROR_BAD_TLV;
}
/* list of text TLV's that we snapshoot */
if (dbg) \
fformat(stdout, "%U\n", format_text_tlv, t); \
\
- if (n->z) \
- _vec_len(n->z) = 0; \
+ if (n->z) \
+ _vec_len(n->z) = 0; \
\
for (i = 0; i < (t->l - sizeof (*t)); i++) \
- vec_add1(n->z, t->v[i]); \
+ vec_add1(n->z, t->v[i]); \
\
- vec_add1(n->z, 0); \
+ vec_add1(n->z, 0); \
\
return CDP_ERROR_NONE; \
}
foreach_text_to_struct_tlv
#undef _
-
#define process_address_tlv process_generic_tlv
#define process_capabilities_tlv process_generic_tlv
#define process_ipprefix_tlv process_generic_tlv
#define process_energywise_tlv process_generic_tlv
#define process_unknown_30_tlv process_generic_tlv
#define process_spare_poe_tlv process_generic_tlv
-
-static tlv_handler_t tlv_handlers [] =
-{
+static tlv_handler_t tlv_handlers[] = {
#define _(a) {#a, CDP_TLV_##a, format_##a##_tlv, process_##a##_tlv},
- foreach_cdp_tlv_type
+ foreach_cdp_tlv_type
#undef _
};
#if DEBUG_TLV_DUMP == 0
-CLIB_UNUSED(static u8 * format_cdp_hdr (u8 * s, va_list * va));
+CLIB_UNUSED (static u8 * format_cdp_hdr (u8 * s, va_list * va));
#endif
-static u8 * format_cdp_hdr (u8 * s, va_list * va)
+static u8 *
+format_cdp_hdr (u8 * s, va_list * va)
{
- cdp_hdr_t *h = va_arg (*va, cdp_hdr_t *);
+ cdp_hdr_t *h = va_arg (*va, cdp_hdr_t *);
- s = format (s, "version %d, ttl %d(secs), cksum 0x%04x\n",
- h->version, h->ttl, h->checksum);
- return s;
+ s = format (s, "version %d, ttl %d(secs), cksum 0x%04x\n",
+ h->version, h->ttl, h->checksum);
+ return s;
}
-static cdp_error_t process_cdp_hdr (cdp_main_t *cm, cdp_neighbor_t *n,
- cdp_hdr_t *h)
+static cdp_error_t
+process_cdp_hdr (cdp_main_t * cm, cdp_neighbor_t * n, cdp_hdr_t * h)
{
#if DEBUG_TLV_DUMP > 0
- fformat(stdout, "%U", format_cdp_hdr, h);
+ fformat (stdout, "%U", format_cdp_hdr, h);
#endif
- if (h->version != 1 && h->version != 2)
- return CDP_ERROR_PROTOCOL_VERSION;
+ if (h->version != 1 && h->version != 2)
+ return CDP_ERROR_PROTOCOL_VERSION;
- n->ttl_in_seconds = h->ttl;
+ n->ttl_in_seconds = h->ttl;
- return CDP_ERROR_NONE;
+ return CDP_ERROR_NONE;
}
/* scan a cdp packet; header, then tlv's */
-static int cdp_packet_scan (cdp_main_t *cm, cdp_neighbor_t *n)
+static int
+cdp_packet_scan (cdp_main_t * cm, cdp_neighbor_t * n)
{
- u8 *cur = n->last_rx_pkt;
- cdp_hdr_t *h;
- cdp_tlv_t *tlv;
- cdp_error_t e = CDP_ERROR_NONE;
- tlv_handler_t *handler;
- cdp_error_t (*fp)(cdp_main_t *, cdp_neighbor_t *, cdp_tlv_t *);
- u16 computed_checksum;
+ u8 *cur = n->last_rx_pkt;
+ cdp_hdr_t *h;
+ cdp_tlv_t *tlv;
+ cdp_error_t e = CDP_ERROR_NONE;
+ tlv_handler_t *handler;
+ cdp_error_t (*fp) (cdp_main_t *, cdp_neighbor_t *, cdp_tlv_t *);
+ u16 computed_checksum;
- computed_checksum = cdp_checksum (cur, vec_len(cur));
+ computed_checksum = cdp_checksum (cur, vec_len (cur));
- if (computed_checksum)
- return CDP_ERROR_CHECKSUM;
+ if (computed_checksum)
+ return CDP_ERROR_CHECKSUM;
- h = (cdp_hdr_t *)cur;
+ h = (cdp_hdr_t *) cur;
- e = process_cdp_hdr (cm, n, h);
- if (e)
- return e;
+ e = process_cdp_hdr (cm, n, h);
+ if (e)
+ return e;
- cur = (u8 *)(h+1);
-
- while (cur < n->last_rx_pkt + vec_len (n->last_rx_pkt) - 1) {
- tlv = (cdp_tlv_t *)cur;
- tlv->t = ntohs(tlv->t);
- tlv->l = ntohs(tlv->l);
- if (tlv->t >= ARRAY_LEN(tlv_handlers))
- return CDP_ERROR_BAD_TLV;
- handler = &tlv_handlers[tlv->t];
- fp = handler->process;
- e = (*fp)(cm, n, tlv);
- if (e)
- return e;
- /* tlv length includes (t, l) */
- cur += tlv->l;
+ cur = (u8 *) (h + 1);
+
+ while (cur < n->last_rx_pkt + vec_len (n->last_rx_pkt) - 1)
+ {
+ tlv = (cdp_tlv_t *) cur;
+ tlv->t = ntohs (tlv->t);
+ tlv->l = ntohs (tlv->l);
+ if (tlv->t >= ARRAY_LEN (tlv_handlers))
+ return CDP_ERROR_BAD_TLV;
+ handler = &tlv_handlers[tlv->t];
+ fp = handler->process;
+ e = (*fp) (cm, n, tlv);
+ if (e)
+ return e;
+ /* tlv length includes (t, l) */
+ cur += tlv->l;
}
-
- return CDP_ERROR_NONE;
+
+ return CDP_ERROR_NONE;
}
/*
* cdp input routine
*/
-cdp_error_t cdp_input (vlib_main_t *vm, vlib_buffer_t * b0, u32 bi0)
+cdp_error_t
+cdp_input (vlib_main_t * vm, vlib_buffer_t * b0, u32 bi0)
{
- cdp_main_t * cm = &cdp_main;
- cdp_neighbor_t *n;
- uword *p, nbytes;
- cdp_error_t e;
- uword last_packet_signature;
-
- /* find or create a neighbor pool entry for the (sw) interface
- upon which we received this pkt */
- p = hash_get (cm->neighbor_by_sw_if_index,
- vnet_buffer(b0)->sw_if_index[VLIB_RX]);
-
- if (p == 0) {
- pool_get (cm->neighbors, n);
- memset (n, 0, sizeof (*n));
- n->sw_if_index = vnet_buffer(b0)->sw_if_index[VLIB_RX];
- n->packet_template_index = (u8)~0;
- hash_set (cm->neighbor_by_sw_if_index, n->sw_if_index,
- n - cm->neighbors);
- } else {
- n = pool_elt_at_index (cm->neighbors, p[0]);
+ cdp_main_t *cm = &cdp_main;
+ cdp_neighbor_t *n;
+ uword *p, nbytes;
+ cdp_error_t e;
+ uword last_packet_signature;
+
+ /* find or create a neighbor pool entry for the (sw) interface
+ upon which we received this pkt */
+ p = hash_get (cm->neighbor_by_sw_if_index,
+ vnet_buffer (b0)->sw_if_index[VLIB_RX]);
+
+ if (p == 0)
+ {
+ pool_get (cm->neighbors, n);
+ memset (n, 0, sizeof (*n));
+ n->sw_if_index = vnet_buffer (b0)->sw_if_index[VLIB_RX];
+ n->packet_template_index = (u8) ~ 0;
+ hash_set (cm->neighbor_by_sw_if_index, n->sw_if_index,
+ n - cm->neighbors);
+ }
+ else
+ {
+ n = pool_elt_at_index (cm->neighbors, p[0]);
}
- /*
- * typical clib idiom. Don't repeatedly allocate and free
- * the per-neighbor rx buffer. Reset its apparent length to zero
- * and reuse it.
- */
-
- if (n->last_rx_pkt)
- _vec_len (n->last_rx_pkt) = 0;
-
- /* cdp disabled on this interface, we're done */
- if (n->disabled)
- return CDP_ERROR_DISABLED;
-
- /*
- * Make sure the per-neighbor rx buffer is big enough to hold
- * the data we're about to copy
- */
- vec_validate (n->last_rx_pkt, vlib_buffer_length_in_chain (vm, b0)-1);
-
- /*
- * Coalesce / copy e the buffer chain into the per-neighbor
- * rx buffer
- */
- nbytes = vlib_buffer_contents (vm, bi0, n->last_rx_pkt);
- ASSERT(nbytes <= vec_len (n->last_rx_pkt));
-
- /*
- * Compute Jenkins hash of the new packet, decide if we need to
- * actually parse through the TLV's. CDP packets are all identical,
- * so unless we time out the peer, we don't need to process the packet.
- */
- last_packet_signature =
- hash_memory (n->last_rx_pkt, vec_len (n->last_rx_pkt), 0xd00b);
-
- if (n->last_packet_signature_valid &&
- n->last_packet_signature == last_packet_signature) {
- e = CDP_ERROR_CACHE_HIT;
- } else {
- /* Actually scan the packet */
- e = cdp_packet_scan (cm, n);
- n->last_packet_signature_valid = 1;
- n->last_packet_signature = last_packet_signature;
+ /*
+ * typical clib idiom. Don't repeatedly allocate and free
+ * the per-neighbor rx buffer. Reset its apparent length to zero
+ * and reuse it.
+ */
+
+ if (n->last_rx_pkt)
+ _vec_len (n->last_rx_pkt) = 0;
+
+ /* cdp disabled on this interface, we're done */
+ if (n->disabled)
+ return CDP_ERROR_DISABLED;
+
+ /*
+ * Make sure the per-neighbor rx buffer is big enough to hold
+ * the data we're about to copy
+ */
+ vec_validate (n->last_rx_pkt, vlib_buffer_length_in_chain (vm, b0) - 1);
+
+ /*
+ * Coalesce / copy e the buffer chain into the per-neighbor
+ * rx buffer
+ */
+ nbytes = vlib_buffer_contents (vm, bi0, n->last_rx_pkt);
+ ASSERT (nbytes <= vec_len (n->last_rx_pkt));
+
+ /*
+ * Compute Jenkins hash of the new packet, decide if we need to
+ * actually parse through the TLV's. CDP packets are all identical,
+ * so unless we time out the peer, we don't need to process the packet.
+ */
+ last_packet_signature =
+ hash_memory (n->last_rx_pkt, vec_len (n->last_rx_pkt), 0xd00b);
+
+ if (n->last_packet_signature_valid &&
+ n->last_packet_signature == last_packet_signature)
+ {
+ e = CDP_ERROR_CACHE_HIT;
+ }
+ else
+ {
+ /* Actually scan the packet */
+ e = cdp_packet_scan (cm, n);
+ n->last_packet_signature_valid = 1;
+ n->last_packet_signature = last_packet_signature;
}
- if (e == CDP_ERROR_NONE) {
- n->last_heard = vlib_time_now (vm);
+ if (e == CDP_ERROR_NONE)
+ {
+ n->last_heard = vlib_time_now (vm);
}
- return e;
+ return e;
}
/*
* setup neighbor hash table
*/
-static clib_error_t *cdp_init (vlib_main_t *vm)
+static clib_error_t *
+cdp_init (vlib_main_t * vm)
{
- clib_error_t * error;
- cdp_main_t *cm = &cdp_main;
- void vnet_cdp_node_reference(void);
+ clib_error_t *error;
+ cdp_main_t *cm = &cdp_main;
+ void vnet_cdp_node_reference (void);
- vnet_cdp_node_reference();
+ vnet_cdp_node_reference ();
- if ((error = vlib_call_init_function (vm, cdp_periodic_init)))
- return error;
+ if ((error = vlib_call_init_function (vm, cdp_periodic_init)))
+ return error;
- cm->vlib_main = vm;
- cm->vnet_main = vnet_get_main();
- cm->neighbor_by_sw_if_index = hash_create (0, sizeof (uword));
+ cm->vlib_main = vm;
+ cm->vnet_main = vnet_get_main ();
+ cm->neighbor_by_sw_if_index = hash_create (0, sizeof (uword));
- return 0;
+ return 0;
}
VLIB_INIT_FUNCTION (cdp_init);
-static u8 * format_cdp_neighbors (u8 * s, va_list * va)
+static u8 *
+format_cdp_neighbors (u8 * s, va_list * va)
{
- CLIB_UNUSED(vlib_main_t *vm) = va_arg (*va, vlib_main_t *);
- cdp_main_t *cm = va_arg (*va, cdp_main_t *);
- vnet_main_t * vnm = & vnet_main;
- cdp_neighbor_t *n;
- vnet_hw_interface_t *hw;
-
- s = format (s,
- "%=25s %=15s %=25s %=10s\n",
- "Our Port", "Peer System", "Peer Port", "Last Heard");
-
- pool_foreach (n, cm->neighbors,
- ({
- hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
-
- if (n->disabled == 0)
- s = format (s, "%=25s %=15s %=25s %=10.1f\n",
- hw->name, n->device_name, n->port_id,
- n->last_heard);
- }));
- return s;
+ CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
+ cdp_main_t *cm = va_arg (*va, cdp_main_t *);
+ vnet_main_t *vnm = &vnet_main;
+ cdp_neighbor_t *n;
+ vnet_hw_interface_t *hw;
+
+ s = format (s,
+ "%=25s %=15s %=25s %=10s\n",
+ "Our Port", "Peer System", "Peer Port", "Last Heard");
+
+ /* *INDENT-OFF* */
+ pool_foreach (n, cm->neighbors,
+ ({
+ hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
+
+ if (n->disabled == 0)
+ s = format (s, "%=25s %=15s %=25s %=10.1f\n",
+ hw->name, n->device_name, n->port_id,
+ n->last_heard);
+ }));
+ /* *INDENT-ON* */
+ return s;
}
static clib_error_t *
show_cdp (vlib_main_t * vm,
- unformat_input_t * input,
- vlib_cli_command_t * cmd)
+ unformat_input_t * input, vlib_cli_command_t * cmd)
{
- cdp_main_t *cm = &cdp_main;
-
- vlib_cli_output (vm, "%U\n", format_cdp_neighbors, vm, cm);
+ cdp_main_t *cm = &cdp_main;
- return 0;
+ vlib_cli_output (vm, "%U\n", format_cdp_neighbors, vm, cm);
+
+ return 0;
}
+/* *INDENT-OFF* */
VLIB_CLI_COMMAND (show_cdp_command, static) = {
- .path = "show cdp",
- .short_help = "Show cdp command",
- .function = show_cdp,
+ .path = "show cdp",
+ .short_help = "Show cdp command",
+ .function = show_cdp,
};
+/* *INDENT-ON* */
/*
* cdp_packet_scan except that we call the per TLV format
* functions instead of the per TLV processing functions
*/
-u8 * cdp_input_format_trace (u8 * s, va_list * args)
+u8 *
+cdp_input_format_trace (u8 * s, va_list * args)
{
- CLIB_UNUSED(vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
- CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
- cdp_input_trace_t * t = va_arg (*args, cdp_input_trace_t *);
- u8 *cur;
- cdp_hdr_t *h;
- cdp_tlv_t *tlv;
- tlv_handler_t *handler;
- u8 * (*fp)(cdp_tlv_t *);
-
- cur = t->data;
-
- h = (cdp_hdr_t *)cur;
- s = format (s, "%U", format_cdp_hdr, h);
-
- cur = (u8 *)(h+1);
-
- while (cur < t->data + t->len) {
- tlv = (cdp_tlv_t *)cur;
- tlv->t = ntohs(tlv->t);
- tlv->l = ntohs(tlv->l);
- if (tlv->t >= ARRAY_LEN(tlv_handlers)) {
- s = format (s, "BAD_TLV\n");
- break;
- }
- handler = &tlv_handlers[tlv->t];
- fp = handler->format;
- s = format (s, " %U", fp, tlv);
- /* tlv length includes (t, l) */
- cur += tlv->l;
+ CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
+ CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
+ cdp_input_trace_t *t = va_arg (*args, cdp_input_trace_t *);
+ u8 *cur;
+ cdp_hdr_t *h;
+ cdp_tlv_t *tlv;
+ tlv_handler_t *handler;
+ u8 *(*fp) (cdp_tlv_t *);
+
+ cur = t->data;
+
+ h = (cdp_hdr_t *) cur;
+ s = format (s, "%U", format_cdp_hdr, h);
+
+ cur = (u8 *) (h + 1);
+
+ while (cur < t->data + t->len)
+ {
+ tlv = (cdp_tlv_t *) cur;
+ tlv->t = ntohs (tlv->t);
+ tlv->l = ntohs (tlv->l);
+ if (tlv->t >= ARRAY_LEN (tlv_handlers))
+ {
+ s = format (s, "BAD_TLV\n");
+ break;
+ }
+ handler = &tlv_handlers[tlv->t];
+ fp = handler->format;
+ s = format (s, " %U", fp, tlv);
+ /* tlv length includes (t, l) */
+ cur += tlv->l;
}
- return s;
+ return s;
}
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */
* packet counter strings
* Dump these counters via the "show error" CLI command
*/
-static char * cdp_error_strings[] = {
+static char *cdp_error_strings[] = {
#define _(sym,string) string,
foreach_cdp_error
#undef _
* them, so the graph node has only one next-index. The "error-drop"
* node automatically bumps our per-node packet counters for us.
*/
-typedef enum {
- CDP_INPUT_NEXT_NORMAL,
- CDP_INPUT_N_NEXT,
+typedef enum
+{
+ CDP_INPUT_NEXT_NORMAL,
+ CDP_INPUT_N_NEXT,
} cdp_next_t;
/*
*/
static uword
cdp_node_fn (vlib_main_t * vm,
- vlib_node_runtime_t * node,
- vlib_frame_t * frame)
+ vlib_node_runtime_t * node, vlib_frame_t * frame)
{
- u32 n_left_from, * from;
- cdp_input_trace_t * t0;
+ u32 n_left_from, *from;
+ cdp_input_trace_t *t0;
- from = vlib_frame_vector_args (frame); /* array of buffer indices */
- n_left_from = frame->n_vectors; /* number of buffer indices */
+ from = vlib_frame_vector_args (frame); /* array of buffer indices */
+ n_left_from = frame->n_vectors; /* number of buffer indices */
while (n_left_from > 0)
{
u32 bi0;
- vlib_buffer_t * b0;
+ vlib_buffer_t *b0;
u32 next0, error0;
bi0 = from[0];
b0 = vlib_get_buffer (vm, bi0);
-
+
next0 = CDP_INPUT_NEXT_NORMAL;
/* scan this cdp pkt. error0 is the counter index to bump */
b0->error = node->errors[error0];
/* If this pkt is traced, snapshoot the data */
- if (b0->flags & VLIB_BUFFER_IS_TRACED) {
- int len;
+ if (b0->flags & VLIB_BUFFER_IS_TRACED)
+ {
+ int len;
t0 = vlib_add_trace (vm, node, b0, sizeof (*t0));
- len = (b0->current_length < sizeof (t0->data))
- ? b0->current_length : sizeof (t0->data);
- t0->len = len;
- clib_memcpy (t0->data, vlib_buffer_get_current (b0), len);
- }
+ len = (b0->current_length < sizeof (t0->data))
+ ? b0->current_length : sizeof (t0->data);
+ t0->len = len;
+ clib_memcpy (t0->data, vlib_buffer_get_current (b0), len);
+ }
/* push this pkt to the next graph node, always error-drop */
vlib_set_next_frame_buffer (vm, node, next0, bi0);
/*
* cdp input graph node declaration
*/
+/* *INDENT-OFF* */
VLIB_REGISTER_NODE (cdp_input_node, static) = {
.function = cdp_node_fn,
.name = "cdp-input",
.n_errors = CDP_N_ERROR,
.error_strings = cdp_error_strings,
-
+
.format_trace = cdp_input_format_trace,
-
+
.n_next_nodes = CDP_INPUT_N_NEXT,
.next_nodes = {
- [CDP_INPUT_NEXT_NORMAL] = "error-drop",
+ [CDP_INPUT_NEXT_NORMAL] = "error-drop",
},
};
+/* *INDENT-ON* */
/*
* cdp periodic function
*/
static uword
-cdp_process (vlib_main_t * vm,
- vlib_node_runtime_t * rt,
- vlib_frame_t * f)
+cdp_process (vlib_main_t * vm, vlib_node_runtime_t * rt, vlib_frame_t * f)
{
- cdp_main_t * cm = &cdp_main;
- f64 poll_time_remaining;
- uword event_type, * event_data = 0;
-
- /* So we can send events to the cdp process */
- cm->cdp_process_node_index = cdp_process_node.index;
-
- /* Dynamically register the cdp input node with the snap classifier */
- snap_register_input_protocol (vm, "cdp-input",
- 0xC /* ieee_oui, Cisco */,
- 0x2000 /* protocol CDP */,
- cdp_input_node.index);
-
- snap_register_input_protocol (vm, "cdp-input",
- 0xC /* ieee_oui, Cisco */,
- 0x2004 /* protocol CDP */,
- cdp_input_node.index);
-
-#if 0 /* retain for reference */
- /* with the hdlc classifier */
- hdlc_register_input_protocol (vm, HDLC_PROTOCOL_cdp,
- cdp_input_node.index);
+ cdp_main_t *cm = &cdp_main;
+ f64 poll_time_remaining;
+ uword event_type, *event_data = 0;
+
+ /* So we can send events to the cdp process */
+ cm->cdp_process_node_index = cdp_process_node.index;
+
+ /* Dynamically register the cdp input node with the snap classifier */
+ snap_register_input_protocol (vm, "cdp-input", 0xC /* ieee_oui, Cisco */ ,
+ 0x2000 /* protocol CDP */ ,
+ cdp_input_node.index);
+
+ snap_register_input_protocol (vm, "cdp-input", 0xC /* ieee_oui, Cisco */ ,
+ 0x2004 /* protocol CDP */ ,
+ cdp_input_node.index);
+
+#if 0 /* retain for reference */
+ /* with the hdlc classifier */
+ hdlc_register_input_protocol (vm, HDLC_PROTOCOL_cdp, cdp_input_node.index);
#endif
- /* with ethernet input (for SRP) */
- ethernet_register_input_type (vm, ETHERNET_TYPE_CDP /* CDP */,
- cdp_input_node.index);
-
- poll_time_remaining = 10.0 /* seconds */;
- while (1) {
- /* sleep until next poll time, or msg serialize event occurs */
- poll_time_remaining =
- vlib_process_wait_for_event_or_clock (vm, poll_time_remaining);
-
- event_type = vlib_process_get_events (vm, &event_data);
- switch (event_type) {
- case ~0: /* no events => timeout */
- break;
-
- default:
- clib_warning ("BUG: event type 0x%wx", event_type);
- break;
- }
- if (event_data)
- _vec_len (event_data) = 0;
-
- /* peer timeout scan, send announcements */
- if (vlib_process_suspend_time_is_zero (poll_time_remaining)) {
- cdp_periodic (vm);
- poll_time_remaining = 10.0;
- }
+ /* with ethernet input (for SRP) */
+ ethernet_register_input_type (vm, ETHERNET_TYPE_CDP /* CDP */ ,
+ cdp_input_node.index);
+
+ poll_time_remaining = 10.0 /* seconds */ ;
+ while (1)
+ {
+ /* sleep until next poll time, or msg serialize event occurs */
+ poll_time_remaining =
+ vlib_process_wait_for_event_or_clock (vm, poll_time_remaining);
+
+ event_type = vlib_process_get_events (vm, &event_data);
+ switch (event_type)
+ {
+ case ~0: /* no events => timeout */
+ break;
+
+ default:
+ clib_warning ("BUG: event type 0x%wx", event_type);
+ break;
+ }
+ if (event_data)
+ _vec_len (event_data) = 0;
+
+ /* peer timeout scan, send announcements */
+ if (vlib_process_suspend_time_is_zero (poll_time_remaining))
+ {
+ cdp_periodic (vm);
+ poll_time_remaining = 10.0;
+ }
}
- return 0;
+ return 0;
}
/*
* cdp periodic node declaration
*/
+/* *INDENT-OFF* */
VLIB_REGISTER_NODE (cdp_process_node, static) = {
- .function = cdp_process,
- .type = VLIB_NODE_TYPE_PROCESS,
- .name = "cdp-process",
+ .function = cdp_process,
+ .type = VLIB_NODE_TYPE_PROCESS,
+ .name = "cdp-process",
};
+/* *INDENT-ON* */
-void vnet_cdp_node_reference(void) { }
+void
+vnet_cdp_node_reference (void)
+{
+}
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */
#include <vnet/cdp/cdp_protocol.h>
-typedef enum {
- CDP_PACKET_TEMPLATE_ETHERNET,
- CDP_PACKET_TEMPLATE_HDLC,
- CDP_PACKET_TEMPLATE_SRP,
- CDP_N_PACKET_TEMPLATES,
+typedef enum
+{
+ CDP_PACKET_TEMPLATE_ETHERNET,
+ CDP_PACKET_TEMPLATE_HDLC,
+ CDP_PACKET_TEMPLATE_SRP,
+ CDP_N_PACKET_TEMPLATES,
} cdp_packet_template_id_t;
-typedef struct {
- /* neighbor's vlib software interface index */
- u32 sw_if_index;
+typedef struct
+{
+ /* neighbor's vlib software interface index */
+ u32 sw_if_index;
- /* Timers */
- f64 last_heard;
- f64 last_sent;
+ /* Timers */
+ f64 last_heard;
+ f64 last_sent;
- /* Neighbor time-to-live (usually 180s) */
- u8 ttl_in_seconds;
+ /* Neighbor time-to-live (usually 180s) */
+ u8 ttl_in_seconds;
- /* "no cdp run" or similar */
- u8 disabled;
+ /* "no cdp run" or similar */
+ u8 disabled;
- /* tx packet template id for this neighbor */
- u8 packet_template_index;
+ /* tx packet template id for this neighbor */
+ u8 packet_template_index;
- /* Jenkins hash optimization: avoid tlv scan, send short keepalive msg */
- u8 last_packet_signature_valid;
- uword last_packet_signature;
+ /* Jenkins hash optimization: avoid tlv scan, send short keepalive msg */
+ u8 last_packet_signature_valid;
+ uword last_packet_signature;
- /* Info we actually keep about each neighbor */
- u8 *device_name;
- u8 *version;
- u8 *port_id;
- u8 *platform;
+ /* Info we actually keep about each neighbor */
+ u8 *device_name;
+ u8 *version;
+ u8 *port_id;
+ u8 *platform;
- /* last received packet, for the J-hash optimization */
- u8 *last_rx_pkt;
+ /* last received packet, for the J-hash optimization */
+ u8 *last_rx_pkt;
} cdp_neighbor_t;
#define foreach_neighbor_string_field \
_(port_id) \
_(platform)
-typedef struct {
- /* pool of cdp neighbors */
- cdp_neighbor_t *neighbors;
+typedef struct
+{
+ /* pool of cdp neighbors */
+ cdp_neighbor_t *neighbors;
- /* tx pcap debug enable */
- u8 tx_pcap_debug;
+ /* tx pcap debug enable */
+ u8 tx_pcap_debug;
- /* rapidly find a neighbor by vlib software interface index */
- uword *neighbor_by_sw_if_index;
+ /* rapidly find a neighbor by vlib software interface index */
+ uword *neighbor_by_sw_if_index;
- /* Background process node index */
- u32 cdp_process_node_index;
+ /* Background process node index */
+ u32 cdp_process_node_index;
- /* Packet templates for different encap types */
- vlib_packet_template_t packet_templates [CDP_N_PACKET_TEMPLATES];
+ /* Packet templates for different encap types */
+ vlib_packet_template_t packet_templates[CDP_N_PACKET_TEMPLATES];
- /* convenience variables */
- vlib_main_t *vlib_main;
- vnet_main_t *vnet_main;
+ /* convenience variables */
+ vlib_main_t *vlib_main;
+ vnet_main_t *vnet_main;
} cdp_main_t;
cdp_main_t cdp_main;
_ (CHECKSUM, "cdp packets with bad checksums") \
_ (DISABLED, "cdp packets received on disabled interfaces")
-typedef enum {
+typedef enum
+{
#define _(sym,str) CDP_ERROR_##sym,
foreach_cdp_error
#undef _
- CDP_N_ERROR,
+ CDP_N_ERROR,
} cdp_error_t;
/* cdp packet trace capture */
-typedef struct {
- u32 len;
- u8 data[400];
+typedef struct
+{
+ u32 len;
+ u8 data[400];
} cdp_input_trace_t;
-typedef enum {
- CDP_EVENT_SEND_NEIGHBOR,
- CDP_EVENT_SEND_KEEPALIVE,
+typedef enum
+{
+ CDP_EVENT_SEND_NEIGHBOR,
+ CDP_EVENT_SEND_KEEPALIVE,
} cdp_process_event_t;
void cdp_periodic (vlib_main_t * vm);
void cdp_keepalive (cdp_main_t * cm, cdp_neighbor_t * n);
u16 cdp_checksum (void *p, int count);
-u8 * cdp_input_format_trace (u8 * s, va_list * args);
+u8 *cdp_input_format_trace (u8 * s, va_list * args);
serialize_function_t serialize_cdp_main, unserialize_cdp_main;
#endif /* __included_cdp_node_h__ */
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */
* etc.
*/
-static void add_device_name_tlv (vnet_hw_interface_t *hw, u8 **t0p)
+static void
+add_device_name_tlv (vnet_hw_interface_t * hw, u8 ** t0p)
{
- cdp_tlv_t *t = (cdp_tlv_t *) *t0p;
+ cdp_tlv_t *t = (cdp_tlv_t *) * t0p;
- t->t = htons(CDP_TLV_device_name);
- t->l = htons(3 + sizeof (*t));
- clib_memcpy (&t->v, "VPP", 3);
-
- *t0p += ntohs(t->l);
+ t->t = htons (CDP_TLV_device_name);
+ t->l = htons (3 + sizeof (*t));
+ clib_memcpy (&t->v, "VPP", 3);
+
+ *t0p += ntohs (t->l);
}
-static void add_port_id_tlv (vnet_hw_interface_t *hw, u8 **t0p)
+static void
+add_port_id_tlv (vnet_hw_interface_t * hw, u8 ** t0p)
{
- cdp_tlv_t *t = (cdp_tlv_t *) *t0p;
+ cdp_tlv_t *t = (cdp_tlv_t *) * t0p;
- t->t = htons(CDP_TLV_port_id);
- t->l = htons(vec_len(hw->name) + sizeof (*t));
- clib_memcpy (&t->v, hw->name, vec_len (hw->name));
- *t0p += ntohs(t->l);
+ t->t = htons (CDP_TLV_port_id);
+ t->l = htons (vec_len (hw->name) + sizeof (*t));
+ clib_memcpy (&t->v, hw->name, vec_len (hw->name));
+ *t0p += ntohs (t->l);
}
-static void add_version_tlv (vnet_hw_interface_t *hw, u8 **t0p)
+static void
+add_version_tlv (vnet_hw_interface_t * hw, u8 ** t0p)
{
- cdp_tlv_t *t = (cdp_tlv_t *) *t0p;
+ cdp_tlv_t *t = (cdp_tlv_t *) * t0p;
- t->t = htons(CDP_TLV_version);
- t->l = htons(12 + sizeof (*t));
- clib_memcpy (&t->v, "VPP Software", 12);
- *t0p += ntohs(t->l);
+ t->t = htons (CDP_TLV_version);
+ t->l = htons (12 + sizeof (*t));
+ clib_memcpy (&t->v, "VPP Software", 12);
+ *t0p += ntohs (t->l);
}
-static void add_platform_tlv (vnet_hw_interface_t *hw, u8 **t0p)
+static void
+add_platform_tlv (vnet_hw_interface_t * hw, u8 ** t0p)
{
- cdp_tlv_t *t = (cdp_tlv_t *) *t0p;
+ cdp_tlv_t *t = (cdp_tlv_t *) * t0p;
- t->t = htons(CDP_TLV_platform);
- t->l = htons(2 + sizeof (*t));
- clib_memcpy (&t->v, "SW", 2);
- *t0p += ntohs(t->l);
+ t->t = htons (CDP_TLV_platform);
+ t->l = htons (2 + sizeof (*t));
+ clib_memcpy (&t->v, "SW", 2);
+ *t0p += ntohs (t->l);
}
-static void add_capability_tlv (vnet_hw_interface_t *hw, u8 **t0p)
+static void
+add_capability_tlv (vnet_hw_interface_t * hw, u8 ** t0p)
{
- cdp_tlv_t *t = (cdp_tlv_t *) *t0p;
- u32 capabilities;
-
- t->t = htons(CDP_TLV_capabilities);
- t->l = htons(4 + sizeof (*t));
- capabilities = CDP_ROUTER_DEVICE;
- capabilities = htonl (capabilities);
- clib_memcpy (&t->v, &capabilities, sizeof (capabilities));
- *t0p += ntohs(t->l);
+ cdp_tlv_t *t = (cdp_tlv_t *) * t0p;
+ u32 capabilities;
+
+ t->t = htons (CDP_TLV_capabilities);
+ t->l = htons (4 + sizeof (*t));
+ capabilities = CDP_ROUTER_DEVICE;
+ capabilities = htonl (capabilities);
+ clib_memcpy (&t->v, &capabilities, sizeof (capabilities));
+ *t0p += ntohs (t->l);
}
-static void add_tlvs (cdp_main_t *cm, vnet_hw_interface_t *hw, u8 **t0p)
+static void
+add_tlvs (cdp_main_t * cm, vnet_hw_interface_t * hw, u8 ** t0p)
{
- add_device_name_tlv (hw, t0p);
- add_port_id_tlv (hw, t0p);
- add_version_tlv (hw, t0p);
- add_platform_tlv (hw, t0p);
- add_capability_tlv (hw, t0p);
+ add_device_name_tlv (hw, t0p);
+ add_port_id_tlv (hw, t0p);
+ add_version_tlv (hw, t0p);
+ add_platform_tlv (hw, t0p);
+ add_capability_tlv (hw, t0p);
}
/*
* send a cdp pkt on an ethernet interface
*/
-static void
-send_ethernet_hello (cdp_main_t *cm, cdp_neighbor_t *n, int count)
+static void
+send_ethernet_hello (cdp_main_t * cm, cdp_neighbor_t * n, int count)
{
- u32 * to_next;
- ethernet_llc_snap_and_cdp_header_t *h0;
- vnet_hw_interface_t *hw;
- u32 bi0;
- vlib_buffer_t *b0;
- u8 *t0;
- u16 checksum;
- int nbytes_to_checksum;
- int i;
- vlib_frame_t * f;
- vlib_main_t * vm = cm->vlib_main;
- vnet_main_t * vnm = cm->vnet_main;
-
- for (i = 0; i < count; i++) {
- /*
- * see cdp_periodic_init() to understand what's already painted
- * into the buffer by the packet template mechanism
- */
- h0 = vlib_packet_template_get_packet
- (vm,
- &cm->packet_templates[n->packet_template_index], &bi0);
-
- /* Add the interface's ethernet source address */
- hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
-
- clib_memcpy (h0->ethernet.src_address, hw->hw_address,
- vec_len (hw->hw_address));
-
- t0 = (u8 *) &h0->cdp.data;
-
- /* add TLVs */
- add_tlvs (cm, hw, &t0);
-
- /* add the cdp packet checksum */
- nbytes_to_checksum = t0 - (u8 *)&h0->cdp;
- checksum = cdp_checksum (&h0->cdp, nbytes_to_checksum);
- h0->cdp.checksum = htons (checksum);
-
- /* Set the outbound packet length */
- b0 = vlib_get_buffer (vm, bi0);
- b0->current_length = nbytes_to_checksum + sizeof (*h0)
- - sizeof (cdp_hdr_t) ;
-
- /* And the outbound interface */
- vnet_buffer(b0)->sw_if_index[VLIB_TX] = hw->sw_if_index;
-
- /* Set the 802.3 ethernet length */
- h0->ethernet.len = htons (b0->current_length
- - sizeof (ethernet_802_3_header_t));
-
- /* And output the packet on the correct interface */
- f = vlib_get_frame_to_node (vm, hw->output_node_index);
- to_next = vlib_frame_vector_args (f);
- to_next[0] = bi0;
- f->n_vectors = 1;
-
- vlib_put_frame_to_node (vm, hw->output_node_index, f);
- n->last_sent = vlib_time_now (vm);
+ u32 *to_next;
+ ethernet_llc_snap_and_cdp_header_t *h0;
+ vnet_hw_interface_t *hw;
+ u32 bi0;
+ vlib_buffer_t *b0;
+ u8 *t0;
+ u16 checksum;
+ int nbytes_to_checksum;
+ int i;
+ vlib_frame_t *f;
+ vlib_main_t *vm = cm->vlib_main;
+ vnet_main_t *vnm = cm->vnet_main;
+
+ for (i = 0; i < count; i++)
+ {
+ /*
+ * see cdp_periodic_init() to understand what's already painted
+ * into the buffer by the packet template mechanism
+ */
+ h0 = vlib_packet_template_get_packet
+ (vm, &cm->packet_templates[n->packet_template_index], &bi0);
+
+ /* Add the interface's ethernet source address */
+ hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
+
+ clib_memcpy (h0->ethernet.src_address, hw->hw_address,
+ vec_len (hw->hw_address));
+
+ t0 = (u8 *) & h0->cdp.data;
+
+ /* add TLVs */
+ add_tlvs (cm, hw, &t0);
+
+ /* add the cdp packet checksum */
+ nbytes_to_checksum = t0 - (u8 *) & h0->cdp;
+ checksum = cdp_checksum (&h0->cdp, nbytes_to_checksum);
+ h0->cdp.checksum = htons (checksum);
+
+ /* Set the outbound packet length */
+ b0 = vlib_get_buffer (vm, bi0);
+ b0->current_length = nbytes_to_checksum + sizeof (*h0)
+ - sizeof (cdp_hdr_t);
+
+ /* And the outbound interface */
+ vnet_buffer (b0)->sw_if_index[VLIB_TX] = hw->sw_if_index;
+
+ /* Set the 802.3 ethernet length */
+ h0->ethernet.len = htons (b0->current_length
+ - sizeof (ethernet_802_3_header_t));
+
+ /* And output the packet on the correct interface */
+ f = vlib_get_frame_to_node (vm, hw->output_node_index);
+ to_next = vlib_frame_vector_args (f);
+ to_next[0] = bi0;
+ f->n_vectors = 1;
+
+ vlib_put_frame_to_node (vm, hw->output_node_index, f);
+ n->last_sent = vlib_time_now (vm);
}
}
/*
* send a cdp pkt on an hdlc interface
*/
-static void
-send_hdlc_hello (cdp_main_t *cm, cdp_neighbor_t *n, int count)
+static void
+send_hdlc_hello (cdp_main_t * cm, cdp_neighbor_t * n, int count)
{
- u32 * to_next;
- hdlc_and_cdp_header_t *h0;
- vnet_hw_interface_t *hw;
- u32 bi0;
- vlib_buffer_t *b0;
- u8 *t0;
- u16 checksum;
- int nbytes_to_checksum;
- int i;
- vlib_frame_t * f;
- vlib_main_t * vm = cm->vlib_main;
- vnet_main_t * vnm = cm->vnet_main;
-
- for (i = 0; i < count; i++) {
- /*
- * see cdp_periodic_init() to understand what's already painted
- * into the buffer by the packet template mechanism
- */
- h0 = vlib_packet_template_get_packet
- (vm,
- &cm->packet_templates[n->packet_template_index], &bi0);
-
- hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
-
- t0 = (u8 *) &h0->cdp.data;
-
- /* add TLVs */
- add_tlvs (cm, hw, &t0);
-
- /* add the cdp packet checksum */
- nbytes_to_checksum = t0 - (u8 *)&h0->cdp;
- checksum = cdp_checksum (&h0->cdp, nbytes_to_checksum);
- h0->cdp.checksum = htons (checksum);
-
- /* Set the outbound packet length */
- b0 = vlib_get_buffer (vm, bi0);
- b0->current_length = nbytes_to_checksum + sizeof (*h0)
- - sizeof (cdp_hdr_t) ;
-
- /* And output the packet on the correct interface */
- f = vlib_get_frame_to_node (vm, hw->output_node_index);
- to_next = vlib_frame_vector_args (f);
- to_next[0] = bi0;
- f->n_vectors = 1;
-
- vlib_put_frame_to_node (vm, hw->output_node_index, f);
- n->last_sent = vlib_time_now (vm);
+ u32 *to_next;
+ hdlc_and_cdp_header_t *h0;
+ vnet_hw_interface_t *hw;
+ u32 bi0;
+ vlib_buffer_t *b0;
+ u8 *t0;
+ u16 checksum;
+ int nbytes_to_checksum;
+ int i;
+ vlib_frame_t *f;
+ vlib_main_t *vm = cm->vlib_main;
+ vnet_main_t *vnm = cm->vnet_main;
+
+ for (i = 0; i < count; i++)
+ {
+ /*
+ * see cdp_periodic_init() to understand what's already painted
+ * into the buffer by the packet template mechanism
+ */
+ h0 = vlib_packet_template_get_packet
+ (vm, &cm->packet_templates[n->packet_template_index], &bi0);
+
+ hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
+
+ t0 = (u8 *) & h0->cdp.data;
+
+ /* add TLVs */
+ add_tlvs (cm, hw, &t0);
+
+ /* add the cdp packet checksum */
+ nbytes_to_checksum = t0 - (u8 *) & h0->cdp;
+ checksum = cdp_checksum (&h0->cdp, nbytes_to_checksum);
+ h0->cdp.checksum = htons (checksum);
+
+ /* Set the outbound packet length */
+ b0 = vlib_get_buffer (vm, bi0);
+ b0->current_length = nbytes_to_checksum + sizeof (*h0)
+ - sizeof (cdp_hdr_t);
+
+ /* And output the packet on the correct interface */
+ f = vlib_get_frame_to_node (vm, hw->output_node_index);
+ to_next = vlib_frame_vector_args (f);
+ to_next[0] = bi0;
+ f->n_vectors = 1;
+
+ vlib_put_frame_to_node (vm, hw->output_node_index, f);
+ n->last_sent = vlib_time_now (vm);
}
}
/*
* send a cdp pkt on an srp interface
*/
-static void
-send_srp_hello (cdp_main_t *cm, cdp_neighbor_t *n, int count)
+static void
+send_srp_hello (cdp_main_t * cm, cdp_neighbor_t * n, int count)
{
- u32 * to_next;
- srp_and_cdp_header_t *h0;
- vnet_hw_interface_t *hw;
- u32 bi0;
- vlib_buffer_t *b0;
- u8 *t0;
- u16 checksum;
- int nbytes_to_checksum;
- int i;
- vlib_frame_t * f;
- vlib_main_t * vm = cm->vlib_main;
- vnet_main_t * vnm = cm->vnet_main;
-
- for (i = 0; i < count; i++) {
- /*
- * see cdp_periodic_init() to understand what's already painted
- * into the buffer by the packet template mechanism
- */
- h0 = vlib_packet_template_get_packet
- (vm,
- &cm->packet_templates[n->packet_template_index], &bi0);
-
- hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
-
- t0 = (u8 *) &h0->cdp.data;
-
- /* add TLVs */
- add_tlvs (cm, hw, &t0);
-
- /* Add the interface's ethernet source address */
- clib_memcpy (h0->ethernet.src_address, hw->hw_address,
- vec_len (hw->hw_address));
-
- /* add the cdp packet checksum */
- nbytes_to_checksum = t0 - (u8 *)&h0->cdp;
- checksum = cdp_checksum (&h0->cdp, nbytes_to_checksum);
- h0->cdp.checksum = htons (checksum);
-
- /* Set the outbound packet length */
- b0 = vlib_get_buffer (vm, bi0);
- b0->current_length = nbytes_to_checksum + sizeof (*h0)
- - sizeof (cdp_hdr_t) ;
-
- /* And output the packet on the correct interface */
- f = vlib_get_frame_to_node (vm, hw->output_node_index);
- to_next = vlib_frame_vector_args (f);
- to_next[0] = bi0;
- f->n_vectors = 1;
-
- vlib_put_frame_to_node (vm, hw->output_node_index, f);
- n->last_sent = vlib_time_now (vm);
+ u32 *to_next;
+ srp_and_cdp_header_t *h0;
+ vnet_hw_interface_t *hw;
+ u32 bi0;
+ vlib_buffer_t *b0;
+ u8 *t0;
+ u16 checksum;
+ int nbytes_to_checksum;
+ int i;
+ vlib_frame_t *f;
+ vlib_main_t *vm = cm->vlib_main;
+ vnet_main_t *vnm = cm->vnet_main;
+
+ for (i = 0; i < count; i++)
+ {
+ /*
+ * see cdp_periodic_init() to understand what's already painted
+ * into the buffer by the packet template mechanism
+ */
+ h0 = vlib_packet_template_get_packet
+ (vm, &cm->packet_templates[n->packet_template_index], &bi0);
+
+ hw = vnet_get_sup_hw_interface (vnm, n->sw_if_index);
+
+ t0 = (u8 *) & h0->cdp.data;
+
+ /* add TLVs */
+ add_tlvs (cm, hw, &t0);
+
+ /* Add the interface's ethernet source address */
+ clib_memcpy (h0->ethernet.src_address, hw->hw_address,
+ vec_len (hw->hw_address));
+
+ /* add the cdp packet checksum */
+ nbytes_to_checksum = t0 - (u8 *) & h0->cdp;
+ checksum = cdp_checksum (&h0->cdp, nbytes_to_checksum);
+ h0->cdp.checksum = htons (checksum);
+
+ /* Set the outbound packet length */
+ b0 = vlib_get_buffer (vm, bi0);
+ b0->current_length = nbytes_to_checksum + sizeof (*h0)
+ - sizeof (cdp_hdr_t);
+
+ /* And output the packet on the correct interface */
+ f = vlib_get_frame_to_node (vm, hw->output_node_index);
+ to_next = vlib_frame_vector_args (f);
+ to_next[0] = bi0;
+ f->n_vectors = 1;
+
+ vlib_put_frame_to_node (vm, hw->output_node_index, f);
+ n->last_sent = vlib_time_now (vm);
}
}
/*
* Decide which cdp packet template to use
*/
-static int pick_packet_template (cdp_main_t *cm, cdp_neighbor_t *n)
+static int
+pick_packet_template (cdp_main_t * cm, cdp_neighbor_t * n)
{
- n->packet_template_index = CDP_PACKET_TEMPLATE_ETHERNET;
+ n->packet_template_index = CDP_PACKET_TEMPLATE_ETHERNET;
- return 0;
+ return 0;
}
/* Send a cdp neighbor announcement */
-static void send_hello (cdp_main_t *cm, cdp_neighbor_t *n, int count)
+static void
+send_hello (cdp_main_t * cm, cdp_neighbor_t * n, int count)
{
- if (n->packet_template_index == (u8)~0) {
- /* If we don't know how to talk to this peer, don't try again */
- if (pick_packet_template (cm, n)) {
- n->last_sent = 1e70;
- return;
- }
+ if (n->packet_template_index == (u8) ~ 0)
+ {
+ /* If we don't know how to talk to this peer, don't try again */
+ if (pick_packet_template (cm, n))
+ {
+ n->last_sent = 1e70;
+ return;
+ }
}
- switch (n->packet_template_index)
+ switch (n->packet_template_index)
{
case CDP_PACKET_TEMPLATE_ETHERNET:
- send_ethernet_hello (cm, n, count);
- break;
+ send_ethernet_hello (cm, n, count);
+ break;
case CDP_PACKET_TEMPLATE_HDLC:
- send_hdlc_hello (cm, n, count);
- break;
+ send_hdlc_hello (cm, n, count);
+ break;
case CDP_PACKET_TEMPLATE_SRP:
- send_srp_hello (cm, n, count);
- break;
+ send_srp_hello (cm, n, count);
+ break;
default:
- ASSERT(0);
+ ASSERT (0);
}
- n->last_sent = vlib_time_now (cm->vlib_main);
-}
-
-static void delete_neighbor (cdp_main_t *cm, cdp_neighbor_t *n,
- int want_broadcast)
-{
- hash_unset (cm->neighbor_by_sw_if_index, n->sw_if_index);
- vec_free (n->device_name);
- vec_free (n->version);
- vec_free (n->port_id);
- vec_free (n->platform);
- vec_free (n->last_rx_pkt);
- pool_put (cm->neighbors, n);
+ n->last_sent = vlib_time_now (cm->vlib_main);
}
-void cdp_periodic (vlib_main_t * vm)
+static void
+delete_neighbor (cdp_main_t * cm, cdp_neighbor_t * n, int want_broadcast)
{
- cdp_main_t *cm = &cdp_main;
- cdp_neighbor_t *n;
- f64 now = vlib_time_now (vm);
- vnet_sw_interface_t *sw;
- static u32 * delete_list = 0;
- int i;
- static cdp_neighbor_t **n_list = 0;
-
- pool_foreach (n, cm->neighbors,
- ({
- vec_add1 (n_list, n);
- }));
-
- /* Across all cdp neighbors known to the system */
- for (i = 0; i < vec_len (n_list); i++) {
- n = n_list[i];
-
- /* "no cdp run" provisioned on the interface? */
- if (n->disabled == 1)
- continue;
-
- sw = vnet_get_sw_interface (cm->vnet_main, n->sw_if_index);
-
- /* Interface shutdown or rx timeout? */
- if (!(sw->flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP)
- || (now > (n->last_heard + (f64)n->ttl_in_seconds)))
- /* add to list of neighbors to delete */
- vec_add1 (delete_list, n - cm->neighbors);
- else if (n->last_sent == 0.0)
- /* First time, send 3 hellos */
- send_hello (cm, n, 3 /* three to begin with */);
- else if (now > (n->last_sent + (((f64)n->ttl_in_seconds)/6.0)))
- /* Normal keepalive, send one */
- send_hello (cm, n, 1 /* one as a keepalive */);
- }
-
- for (i = 0; i < vec_len (delete_list); i++) {
- n = vec_elt_at_index (cm->neighbors, delete_list[i]);
- delete_neighbor (cm, n, 1);
- }
- if (delete_list)
- _vec_len (delete_list) = 0;
- if (n_list)
- _vec_len (n_list) = 0;
+ hash_unset (cm->neighbor_by_sw_if_index, n->sw_if_index);
+ vec_free (n->device_name);
+ vec_free (n->version);
+ vec_free (n->port_id);
+ vec_free (n->platform);
+ vec_free (n->last_rx_pkt);
+ pool_put (cm->neighbors, n);
}
-static clib_error_t *cdp_periodic_init (vlib_main_t * vm)
+void
+cdp_periodic (vlib_main_t * vm)
{
- cdp_main_t * cm = &cdp_main;
-
- /* Create the ethernet cdp hello packet template */
+ cdp_main_t *cm = &cdp_main;
+ cdp_neighbor_t *n;
+ f64 now = vlib_time_now (vm);
+ vnet_sw_interface_t *sw;
+ static u32 *delete_list = 0;
+ int i;
+ static cdp_neighbor_t **n_list = 0;
+
+ /* *INDENT-OFF* */
+ pool_foreach (n, cm->neighbors,
+ ({
+ vec_add1 (n_list, n);
+ }));
+ /* *INDENT-ON* */
+
+ /* Across all cdp neighbors known to the system */
+ for (i = 0; i < vec_len (n_list); i++)
{
- ethernet_llc_snap_and_cdp_header_t h;
-
- memset (&h, 0, sizeof (h));
-
- /* Send to 01:00:0c:cc:cc */
- h.ethernet.dst_address[0] = 0x01;
- /* h.ethernet.dst_address[1] = 0x00; (memset) */
- h.ethernet.dst_address[2] = 0x0C;
- h.ethernet.dst_address[3] = 0xCC;
- h.ethernet.dst_address[4] = 0xCC;
- h.ethernet.dst_address[5] = 0xCC;
-
- /* leave src address blank (fill in at send time) */
-
- /* leave length blank (fill in at send time) */
-
- /* LLC */
- h.llc.dst_sap = h.llc.src_sap = 0xAA; /* SNAP */
- h.llc.control = 0x03; /* UI (no extended control bytes) */
-
- /* SNAP */
- /* h.snap.oui[0] = 0x00; (memset) */
- /* h.snap.oui[1] = 0x00; (memset) */
- h.snap.oui[2] = 0x0C; /* Cisco = 0x00000C */
- h.snap.protocol = htons (0x2000); /* CDP = 0x2000 */
-
- /* CDP */
- h.cdp.version = 2;
- h.cdp.ttl = 180;
-
- vlib_packet_template_init
- (vm,
- &cm->packet_templates[CDP_PACKET_TEMPLATE_ETHERNET],
- /* data */ &h,
- sizeof (h),
- /* alloc chunk size */ 8,
- "cdp-ethernet");
+ n = n_list[i];
+
+ /* "no cdp run" provisioned on the interface? */
+ if (n->disabled == 1)
+ continue;
+
+ sw = vnet_get_sw_interface (cm->vnet_main, n->sw_if_index);
+
+ /* Interface shutdown or rx timeout? */
+ if (!(sw->flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP)
+ || (now > (n->last_heard + (f64) n->ttl_in_seconds)))
+ /* add to list of neighbors to delete */
+ vec_add1 (delete_list, n - cm->neighbors);
+ else if (n->last_sent == 0.0)
+ /* First time, send 3 hellos */
+ send_hello (cm, n, 3 /* three to begin with */ );
+ else if (now > (n->last_sent + (((f64) n->ttl_in_seconds) / 6.0)))
+ /* Normal keepalive, send one */
+ send_hello (cm, n, 1 /* one as a keepalive */ );
}
-#if 0 /* retain for reference */
-
- /* Create the hdlc cdp hello packet template */
+ for (i = 0; i < vec_len (delete_list); i++)
{
- hdlc_and_cdp_header_t h;
-
- memset (&h, 0, sizeof (h));
-
- h.hdlc.address = 0x0f;
- /* h.hdlc.control = 0; (memset) */
- h.hdlc.protocol = htons (0x2000); /* CDP = 0x2000 */
-
- /* CDP */
- h.cdp.version = 2;
- h.cdp.ttl = 180;
-
- vlib_packet_template_init
- (vm,
- &cm->packet_templates[CDP_PACKET_TEMPLATE_HDLC],
- /* data */ &h,
- sizeof (h),
- /* alloc chunk size */ 8,
- "cdp-hdlc");
+ n = vec_elt_at_index (cm->neighbors, delete_list[i]);
+ delete_neighbor (cm, n, 1);
}
+ if (delete_list)
+ _vec_len (delete_list) = 0;
+ if (n_list)
+ _vec_len (n_list) = 0;
+}
- /* Create the srp cdp hello packet template */
- {
- srp_and_cdp_header_t h;
-
- memset (&h, 0, sizeof (h));
-
- /* Send to 01:00:0c:cc:cc */
- h.ethernet.dst_address[0] = 0x01;
- /* h.ethernet.dst_address[1] = 0x00; (memset) */
- h.ethernet.dst_address[2] = 0x0C;
- h.ethernet.dst_address[3] = 0xCC;
- h.ethernet.dst_address[4] = 0xCC;
- h.ethernet.dst_address[5] = 0xCC;
-
- /* leave src address blank (fill in at send time) */
-
- /* The srp header is filled in at xmt */
- h.srp.ttl = 1;
- h.srp.priority = 7;
- h.srp.mode = SRP_MODE_data;
- srp_header_compute_parity (&h.srp);
-
- /* Inner ring and parity will be set at send time */
-
- h.ethernet.type = htons (0x2000); /* CDP = 0x2000 */
-
- /* CDP */
- h.cdp.version = 2;
- h.cdp.ttl = 180;
-
- vlib_packet_template_init
- (vm,
- &cm->packet_templates[CDP_PACKET_TEMPLATE_SRP],
- /* data */ &h,
- sizeof (h),
- /* alloc chunk size */ 8,
- "cdp-srp");
- }
+static clib_error_t *
+cdp_periodic_init (vlib_main_t * vm)
+{
+ cdp_main_t *cm = &cdp_main;
+
+ /* Create the ethernet cdp hello packet template */
+ {
+ ethernet_llc_snap_and_cdp_header_t h;
+
+ memset (&h, 0, sizeof (h));
+
+ /* Send to 01:00:0c:cc:cc */
+ h.ethernet.dst_address[0] = 0x01;
+ /* h.ethernet.dst_address[1] = 0x00; (memset) */
+ h.ethernet.dst_address[2] = 0x0C;
+ h.ethernet.dst_address[3] = 0xCC;
+ h.ethernet.dst_address[4] = 0xCC;
+ h.ethernet.dst_address[5] = 0xCC;
+
+ /* leave src address blank (fill in at send time) */
+
+ /* leave length blank (fill in at send time) */
+
+ /* LLC */
+ h.llc.dst_sap = h.llc.src_sap = 0xAA; /* SNAP */
+ h.llc.control = 0x03; /* UI (no extended control bytes) */
+
+ /* SNAP */
+ /* h.snap.oui[0] = 0x00; (memset) */
+ /* h.snap.oui[1] = 0x00; (memset) */
+ h.snap.oui[2] = 0x0C; /* Cisco = 0x00000C */
+ h.snap.protocol = htons (0x2000); /* CDP = 0x2000 */
+
+ /* CDP */
+ h.cdp.version = 2;
+ h.cdp.ttl = 180;
+
+ vlib_packet_template_init
+ (vm, &cm->packet_templates[CDP_PACKET_TEMPLATE_ETHERNET],
+ /* data */ &h,
+ sizeof (h),
+ /* alloc chunk size */ 8,
+ "cdp-ethernet");
+ }
+
+#if 0 /* retain for reference */
+
+ /* Create the hdlc cdp hello packet template */
+ {
+ hdlc_and_cdp_header_t h;
+
+ memset (&h, 0, sizeof (h));
+
+ h.hdlc.address = 0x0f;
+ /* h.hdlc.control = 0; (memset) */
+ h.hdlc.protocol = htons (0x2000); /* CDP = 0x2000 */
+
+ /* CDP */
+ h.cdp.version = 2;
+ h.cdp.ttl = 180;
+
+ vlib_packet_template_init
+ (vm, &cm->packet_templates[CDP_PACKET_TEMPLATE_HDLC],
+ /* data */ &h,
+ sizeof (h),
+ /* alloc chunk size */ 8,
+ "cdp-hdlc");
+ }
+
+ /* Create the srp cdp hello packet template */
+ {
+ srp_and_cdp_header_t h;
+
+ memset (&h, 0, sizeof (h));
+
+ /* Send to 01:00:0c:cc:cc */
+ h.ethernet.dst_address[0] = 0x01;
+ /* h.ethernet.dst_address[1] = 0x00; (memset) */
+ h.ethernet.dst_address[2] = 0x0C;
+ h.ethernet.dst_address[3] = 0xCC;
+ h.ethernet.dst_address[4] = 0xCC;
+ h.ethernet.dst_address[5] = 0xCC;
+
+ /* leave src address blank (fill in at send time) */
+
+ /* The srp header is filled in at xmt */
+ h.srp.ttl = 1;
+ h.srp.priority = 7;
+ h.srp.mode = SRP_MODE_data;
+ srp_header_compute_parity (&h.srp);
+
+ /* Inner ring and parity will be set at send time */
+
+ h.ethernet.type = htons (0x2000); /* CDP = 0x2000 */
+
+ /* CDP */
+ h.cdp.version = 2;
+ h.cdp.ttl = 180;
+
+ vlib_packet_template_init
+ (vm, &cm->packet_templates[CDP_PACKET_TEMPLATE_SRP],
+ /* data */ &h,
+ sizeof (h),
+ /* alloc chunk size */ 8,
+ "cdp-srp");
+ }
#endif
- return 0;
+ return 0;
}
VLIB_INIT_FUNCTION (cdp_periodic_init);
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */
#include <vnet/snap/snap.h>
#include <vnet/srp/packet.h>
-typedef CLIB_PACKED (struct {
- u8 version;
- u8 ttl;
- u16 checksum; /* 1's complement of the 1's complement sum */
- u8 data[0];
-}) cdp_hdr_t;
-
-typedef struct {
+typedef CLIB_PACKED (struct
+ {
+ u8 version;
+ u8 ttl;
+ u16 checksum; /* 1's complement of the 1's complement sum */
+ u8 data[0];
+ }) cdp_hdr_t;
+
+typedef struct
+{
u8 dst_address[6];
u8 src_address[6];
u16 len;
} ethernet_802_3_header_t;
-typedef CLIB_PACKED (struct {
- ethernet_802_3_header_t ethernet;
- llc_header_t llc;
- snap_header_t snap;
- cdp_hdr_t cdp;
-}) ethernet_llc_snap_and_cdp_header_t;
-
-typedef CLIB_PACKED (struct {
- hdlc_header_t hdlc;
- cdp_hdr_t cdp;
-}) hdlc_and_cdp_header_t;
-
-typedef CLIB_PACKED (struct {
- srp_header_t srp;
- ethernet_header_t ethernet;
- cdp_hdr_t cdp;
-}) srp_and_cdp_header_t;
-
-typedef CLIB_PACKED (struct {
- u16 t;
- u16 l;
- u8 v[0];
-}) cdp_tlv_t;
+typedef CLIB_PACKED (struct
+ {
+ ethernet_802_3_header_t ethernet;
+ llc_header_t llc; snap_header_t snap; cdp_hdr_t cdp;
+ }) ethernet_llc_snap_and_cdp_header_t;
+
+typedef CLIB_PACKED (struct
+ {
+ hdlc_header_t hdlc; cdp_hdr_t cdp;
+ }) hdlc_and_cdp_header_t;
+
+typedef CLIB_PACKED (struct
+ {
+ srp_header_t srp;
+ ethernet_header_t ethernet; cdp_hdr_t cdp;
+ }) srp_and_cdp_header_t;
+
+typedef CLIB_PACKED (struct
+ {
+ u16 t;
+ u16 l;
+ u8 v[0];
+ }) cdp_tlv_t;
/*
* TLV codes.
_(unknown_30) \
_(spare_poe)
-typedef enum {
+typedef enum
+{
#define _(t) CDP_TLV_##t,
- foreach_cdp_tlv_type
+ foreach_cdp_tlv_type
#undef _
} cdp_tlv_code_t;
#define CDP_DUPLEX_TLV_FULL 0x1
#endif /* __included_cdp_protocol_h__ */
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */
Code Review / vpp.git / commitdiff