vppinfra: deprecate clib_mem_is_vec
[vpp.git] / src / plugins / dpdk / device / format.c
1 /*
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:
6  *
7  *     http://www.apache.org/licenses/LICENSE-2.0
8  *
9  * Unless required by applicable law or agreed to in writing, software
10  * distributed under the License is distributed on an "AS IS" BASIS,
11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12  * See the License for the specific language governing permissions and
13  * limitations under the License.
14  */
15 #include <vnet/vnet.h>
16 #include <vppinfra/vec.h>
17 #include <vppinfra/format.h>
18 #include <assert.h>
19
20 #define __USE_GNU
21 #include <dlfcn.h>
22
23 #include <vnet/ethernet/ethernet.h>
24 #include <vnet/ethernet/sfp.h>
25 #include <dpdk/device/dpdk.h>
26
27 #include <dpdk/device/dpdk_priv.h>
28 #include <vppinfra/error.h>
29
30 #define foreach_dpdk_counter                    \
31   _ (tx_frames_ok, opackets)                    \
32   _ (tx_bytes_ok, obytes)                       \
33   _ (tx_errors, oerrors)                        \
34   _ (rx_frames_ok, ipackets)                    \
35   _ (rx_bytes_ok, ibytes)                       \
36   _ (rx_errors, ierrors)                        \
37   _ (rx_missed, imissed)                        \
38   _ (rx_no_bufs, rx_nombuf)
39
40 #define foreach_dpdk_q_counter                  \
41   _ (rx_frames_ok, q_ipackets)                  \
42   _ (tx_frames_ok, q_opackets)                  \
43   _ (rx_bytes_ok, q_ibytes)                     \
44   _ (tx_bytes_ok, q_obytes)                     \
45   _ (rx_errors, q_errors)
46
47 #if RTE_VERSION < RTE_VERSION_NUM(21, 5, 0, 0)
48 #define PKT_RX_OUTER_IP_CKSUM_BAD PKT_RX_EIP_CKSUM_BAD
49 #endif
50
51 #define foreach_dpdk_pkt_rx_offload_flag                                      \
52   _ (RX_FDIR, "RX packet with FDIR infos")                                    \
53   _ (RX_FDIR_FLX, "RX packet with FDIR_FLX info")                             \
54   _ (RX_FDIR_ID, "RX packet with FDIR_ID info")                               \
55   _ (RX_IEEE1588_PTP, "RX IEEE1588 L2 Ethernet PT Packet")                    \
56   _ (RX_IEEE1588_TMST, "RX IEEE1588 L2/L4 timestamped packet")                \
57   _ (RX_IP_CKSUM_BAD, "IP cksum of RX pkt. is not OK")                        \
58   _ (RX_IP_CKSUM_GOOD, "IP cksum of RX pkt. is valid")                        \
59   _ (RX_IP_CKSUM_NONE, "no IP cksum of RX pkt.")                              \
60   _ (RX_L4_CKSUM_BAD, "L4 cksum of RX pkt. is not OK")                        \
61   _ (RX_L4_CKSUM_GOOD, "L4 cksum of RX pkt. is valid")                        \
62   _ (RX_L4_CKSUM_NONE, "no L4 cksum of RX pkt.")                              \
63   _ (RX_LRO, "LRO packet")                                                    \
64   _ (RX_OUTER_IP_CKSUM_BAD, "External IP header checksum error")              \
65   _ (RX_OUTER_L4_CKSUM_BAD, "External L4 header checksum error")              \
66   _ (RX_OUTER_L4_CKSUM_GOOD, "External L4 header checksum OK")                \
67   _ (RX_QINQ, "RX packet with QinQ tags")                                     \
68   _ (RX_QINQ_STRIPPED, "RX packet QinQ tags stripped")                        \
69   _ (RX_RSS_HASH, "RX packet with RSS hash result")                           \
70   _ (RX_SEC_OFFLOAD, "RX packet with security offload")                       \
71   _ (RX_SEC_OFFLOAD_FAILED, "RX packet with security offload failed")         \
72   _ (RX_VLAN, "RX packet is a 802.1q VLAN packet")                            \
73   _ (RX_VLAN_STRIPPED, "RX packet VLAN tag stripped")
74
75 #define foreach_dpdk_pkt_type                                           \
76   _ (L2, ETHER, "Ethernet packet")                                      \
77   _ (L2, ETHER_TIMESYNC, "Ethernet packet for time sync")               \
78   _ (L2, ETHER_ARP, "ARP packet")                                       \
79   _ (L2, ETHER_LLDP, "LLDP (Link Layer Discovery Protocol) packet")     \
80   _ (L2, ETHER_NSH, "NSH (Network Service Header) packet")              \
81   _ (L2, ETHER_VLAN, "VLAN packet")                                     \
82   _ (L2, ETHER_QINQ, "QinQ packet")                                     \
83   _ (L3, IPV4, "IPv4 packet without extension headers")                 \
84   _ (L3, IPV4_EXT, "IPv4 packet with extension headers")                \
85   _ (L3, IPV4_EXT_UNKNOWN, "IPv4 packet with or without extension headers") \
86   _ (L3, IPV6, "IPv6 packet without extension headers")                 \
87   _ (L3, IPV6_EXT, "IPv6 packet with extension headers")                \
88   _ (L3, IPV6_EXT_UNKNOWN, "IPv6 packet with or without extension headers") \
89   _ (L4, TCP, "TCP packet")                                             \
90   _ (L4, UDP, "UDP packet")                                             \
91   _ (L4, FRAG, "Fragmented IP packet")                                  \
92   _ (L4, SCTP, "SCTP (Stream Control Transmission Protocol) packet")    \
93   _ (L4, ICMP, "ICMP packet")                                           \
94   _ (L4, NONFRAG, "Non-fragmented IP packet")                           \
95   _ (TUNNEL, GRE, "GRE tunneling packet")                               \
96   _ (TUNNEL, VXLAN, "VXLAN tunneling packet")                           \
97   _ (TUNNEL, NVGRE, "NVGRE Tunneling packet")                           \
98   _ (TUNNEL, GENEVE, "GENEVE Tunneling packet")                         \
99   _ (TUNNEL, GRENAT, "Teredo, VXLAN or GRE Tunneling packet")           \
100   _ (INNER_L2, ETHER, "Inner Ethernet packet")                          \
101   _ (INNER_L2, ETHER_VLAN, "Inner Ethernet packet with VLAN")           \
102   _ (INNER_L3, IPV4, "Inner IPv4 packet without extension headers")     \
103   _ (INNER_L3, IPV4_EXT, "Inner IPv4 packet with extension headers")    \
104   _ (INNER_L3, IPV4_EXT_UNKNOWN, "Inner IPv4 packet with or without extension headers") \
105   _ (INNER_L3, IPV6, "Inner IPv6 packet without extension headers")     \
106   _ (INNER_L3, IPV6_EXT, "Inner IPv6 packet with extension headers")    \
107   _ (INNER_L3, IPV6_EXT_UNKNOWN, "Inner IPv6 packet with or without extension headers") \
108   _ (INNER_L4, TCP, "Inner TCP packet")                                 \
109   _ (INNER_L4, UDP, "Inner UDP packet")                                 \
110   _ (INNER_L4, FRAG, "Inner fragmented IP packet")                       \
111   _ (INNER_L4, SCTP, "Inner SCTP (Stream Control Transmission Protocol) packet") \
112   _ (INNER_L4, ICMP, "Inner ICMP packet")                               \
113   _ (INNER_L4, NONFRAG, "Inner non-fragmented IP packet")
114
115 #define foreach_dpdk_pkt_tx_offload_flag                                      \
116   _ (TX_IEEE1588_TMST, "TX IEEE1588 packet to timestamp")                     \
117   _ (TX_IPV4, "TX IPV4")                                                      \
118   _ (TX_IPV6, "TX IPV6")                                                      \
119   _ (TX_IP_CKSUM, "IP cksum of TX pkt. computed by NIC")                      \
120   _ (TX_MACSEC, "TX MACSEC")                                                  \
121   _ (TX_OUTER_IPV4, "TX outer IPV4")                                          \
122   _ (TX_OUTER_IPV6, "TX outer IPV6")                                          \
123   _ (TX_OUTER_IP_CKSUM, "Outer IP cksum of Tx pkt. computed by NIC")          \
124   _ (TX_OUTER_UDP_CKSUM, "TX outer UDP cksum")                                \
125   _ (TX_QINQ, "TX QINQ")                                                      \
126   _ (TX_SCTP_CKSUM, "SCTP cksum of TX pkt. computed by NIC")                  \
127   _ (TX_SEC_OFFLOAD, "TX SEC OFFLOAD")                                        \
128   _ (TX_TCP_CKSUM, "TCP cksum of TX pkt. computed by NIC")                    \
129   _ (TX_TCP_SEG, "TSO of TX pkt. done by NIC")                                \
130   _ (TX_TUNNEL_GENEVE, "TX tunnel GENEVE")                                    \
131   _ (TX_TUNNEL_GRE, "TX tunnel GRE")                                          \
132   _ (TX_TUNNEL_GTP, "TX tunnel GTP")                                          \
133   _ (TX_TUNNEL_IP, "TX tunnel IP")                                            \
134   _ (TX_TUNNEL_IPIP, "TX tunnel IPIP")                                        \
135   _ (TX_TUNNEL_MPLSINUDP, "TX tunnel MPLSinUDP")                              \
136   _ (TX_TUNNEL_UDP, "TX tunnel UDP")                                          \
137   _ (TX_TUNNEL_VXLAN, "TX packet is a VXLAN packet")                          \
138   _ (TX_TUNNEL_VXLAN_GPE, "TX tunnel VXLAN GPE")                              \
139   _ (TX_UDP_CKSUM, "TX UDP cksum")                                            \
140   _ (TX_UDP_SEG, "TX UDP SEG")                                                \
141   _ (TX_VLAN, "TX packet is a 802.1q VLAN packet")
142
143 #define foreach_dpdk_pkt_offload_flag           \
144   foreach_dpdk_pkt_rx_offload_flag              \
145   foreach_dpdk_pkt_tx_offload_flag
146
147 #define foreach_dpdk_pkt_dyn_rx_offload_flag                            \
148   _ (RX_TIMESTAMP, 0, "Timestamp field is valid")
149
150 u8 *
151 format_dpdk_device_name (u8 * s, va_list * args)
152 {
153   dpdk_main_t *dm = &dpdk_main;
154   u32 i = va_arg (*args, u32);
155   dpdk_device_t *xd = vec_elt_at_index (dm->devices, i);
156
157   return format (s, "%v", xd->name);
158 }
159
160 u8 *
161 format_dpdk_device_flags (u8 * s, va_list * args)
162 {
163   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
164   u8 *t = 0;
165
166 #define _(a, b, c) if (xd->flags & (1 << a)) \
167 t = format (t, "%s%s", t ? " ":"", c);
168   foreach_dpdk_device_flags
169 #undef _
170     s = format (s, "%v", t);
171   vec_free (t);
172   return s;
173 }
174
175 static u8 *
176 format_dpdk_device_type (u8 * s, va_list * args)
177 {
178   dpdk_main_t *dm = &dpdk_main;
179   u32 i = va_arg (*args, u32);
180
181   if (dm->devices[i].if_desc)
182     return format (s, dm->devices[i].if_desc);
183   else
184     return format (s, "### UNKNOWN ###");
185 }
186
187 static u8 *
188 format_dpdk_link_status (u8 * s, va_list * args)
189 {
190   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
191   struct rte_eth_link *l = &xd->link;
192   vnet_main_t *vnm = vnet_get_main ();
193   vnet_hw_interface_t *hi = vnet_get_hw_interface (vnm, xd->hw_if_index);
194
195   s = format (s, "%s ", l->link_status ? "up" : "down");
196   if (l->link_status)
197     {
198       u32 promisc = rte_eth_promiscuous_get (xd->port_id);
199
200       s = format (s, "%s duplex ", (l->link_duplex == ETH_LINK_FULL_DUPLEX) ?
201                   "full" : "half");
202       s = format (s, "max-frame-size %d %s\n", hi->max_frame_size,
203                   promisc ? " promisc" : "");
204     }
205   else
206     s = format (s, "\n");
207
208   return s;
209 }
210
211 #define _(n, v, str)                                            \
212 if (bitmap & v) {                                            \
213   if (format_get_indent (s) > 72)                            \
214     s = format(s,"\n%U", format_white_space, indent);        \
215   s = format(s, "%s ", str);                                 \
216 }
217
218 u8 *
219 format_dpdk_rss_hf_name (u8 * s, va_list * args)
220 {
221   u64 bitmap = va_arg (*args, u64);
222   u32 indent = format_get_indent (s);
223
224   if (!bitmap)
225     return format (s, "none");
226
227   foreach_dpdk_rss_hf return s;
228 }
229
230 #undef _
231
232 /* Convert to all lower case e.g "VLAN_STRIP" -> "vlan-strip"
233    Works for both vector names and null terminated c strings. */
234 static u8 *
235 format_offload (u8 * s, va_list * va)
236 {
237   u8 *id = va_arg (*va, u8 *);
238   uword i, l;
239
240   l = ~0;
241
242   if (id)
243     for (i = 0; id[i] != 0 && i < l; i++)
244       {
245         u8 c = id[i];
246
247         if (c == '_')
248           c = '-';
249         else
250           c = tolower (c);
251         vec_add1 (s, c);
252       }
253
254   return s;
255 }
256
257 #define _(v, func)                                           \
258 if (bitmap & v) {                                            \
259   if (format_get_indent (s) > 72)                            \
260     s = format(s,"\n%U", format_white_space, indent);        \
261   s = format(s, "%U ", format_offload, func (v));            \
262 }
263
264 u8 *
265 format_dpdk_rx_offload_caps (u8 * s, va_list * args)
266 {
267   u64 bitmap = va_arg (*args, u32);
268   u32 indent = format_get_indent (s);
269   uword i;
270
271   if (!bitmap)
272     return format (s, "none");
273
274   for (i = 0; i < 64; i++)
275     {
276       u64 mask = (u64) 1 << i;
277
278       _(mask, rte_eth_dev_rx_offload_name);
279     }
280   return s;
281 }
282
283 u8 *
284 format_dpdk_tx_offload_caps (u8 * s, va_list * args)
285 {
286   u64 bitmap = va_arg (*args, u32);
287   u32 indent = format_get_indent (s);
288   uword i;
289
290   if (!bitmap)
291     return format (s, "none");
292
293   for (i = 0; i < 64; i++)
294     {
295       u64 mask = (u64) 1 << i;
296
297       _(mask, rte_eth_dev_tx_offload_name);
298     }
299   return s;
300 }
301
302 #undef _
303
304 u8 *
305 format_dpdk_device_errors (u8 * s, va_list * args)
306 {
307   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
308   clib_error_t *e;
309   u32 indent = format_get_indent (s);
310
311   vec_foreach (e, xd->errors)
312   {
313     s = format (s, "%U%v\n", format_white_space, indent, e->what);
314   }
315   return s;
316 }
317
318 static u8 *
319 format_dpdk_device_module_info (u8 * s, va_list * args)
320 {
321   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
322   struct rte_eth_dev_module_info mi = { 0 };
323   struct rte_dev_eeprom_info ei = { 0 };
324
325   if (rte_eth_dev_get_module_info (xd->port_id, &mi) != 0)
326     return format (s, "unknown");
327
328   ei.length = mi.eeprom_len;
329   ei.data = clib_mem_alloc (mi.eeprom_len);
330
331   if (rte_eth_dev_get_module_eeprom (xd->port_id, &ei) == 0)
332     {
333       s = format (s, "%U", format_sfp_eeprom, ei.data +
334                   (mi.type == RTE_ETH_MODULE_SFF_8436 ? 0x80 : 0));
335     }
336   else
337     s = format (s, "eeprom read error");
338
339   clib_mem_free (ei.data);
340   return s;
341 }
342
343 u8 *
344 format_dpdk_burst_fn (u8 *s, va_list *args)
345 {
346   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
347   vlib_rx_or_tx_t dir = va_arg (*args, vlib_rx_or_tx_t);
348   void *p;
349   Dl_info info = { 0 };
350
351 #if RTE_VERSION < RTE_VERSION_NUM(21, 11, 0, 0)
352 #define rte_eth_fp_ops rte_eth_devices
353 #endif
354
355   p = (dir == VLIB_TX) ? rte_eth_fp_ops[xd->port_id].tx_pkt_burst :
356                          rte_eth_fp_ops[xd->port_id].rx_pkt_burst;
357
358   if (dladdr (p, &info) == 0 || info.dli_sname == 0)
359     return format (s, "(not available)");
360
361   return format (s, "%s", info.dli_sname);
362 }
363
364 static u8 *
365 format_switch_info (u8 * s, va_list * args)
366 {
367   struct rte_eth_switch_info *si =
368     va_arg (*args, struct rte_eth_switch_info *);
369
370   if (si->name)
371     s = format (s, "name %s ", si->name);
372
373   s = format (s, "domain id %d port id %d", si->domain_id, si->port_id);
374
375   return s;
376 }
377
378 u8 *
379 format_dpdk_rte_device (u8 *s, va_list *args)
380 {
381   struct rte_device *d = va_arg (*args, struct rte_device *);
382
383   if (!d)
384     return format (s, "not available");
385
386   s = format (s, "name: %s, numa: %d", d->name, d->numa_node);
387
388   if (d->driver)
389     s = format (s, ", driver: %s", d->driver->name);
390
391   if (d->bus)
392     s = format (s, ", bus: %s", d->bus->name);
393
394   return s;
395 }
396
397 u8 *
398 format_dpdk_device (u8 * s, va_list * args)
399 {
400   u32 dev_instance = va_arg (*args, u32);
401   int verbose = va_arg (*args, int);
402   dpdk_main_t *dm = &dpdk_main;
403   vlib_main_t *vm = vlib_get_main ();
404   dpdk_device_t *xd = vec_elt_at_index (dm->devices, dev_instance);
405   u32 indent = format_get_indent (s);
406   f64 now = vlib_time_now (vm);
407   struct rte_eth_dev_info di;
408   struct rte_eth_burst_mode mode;
409   struct rte_pci_device *pci;
410   struct rte_eth_rss_conf rss_conf;
411   int vlan_off;
412   int retval;
413
414   dpdk_update_counters (xd, now);
415   dpdk_update_link_state (xd, now);
416   rte_eth_dev_info_get (xd->port_id, &di);
417
418   s = format (s, "%U\n%Ucarrier %U",
419               format_dpdk_device_type, dev_instance,
420               format_white_space, indent + 2, format_dpdk_link_status, xd);
421   s = format (s, "%Uflags: %U\n",
422               format_white_space, indent + 2, format_dpdk_device_flags, xd);
423   if (di.device->devargs && di.device->devargs->args)
424     s = format (s, "%UDevargs: %s\n",
425                 format_white_space, indent + 2, di.device->devargs->args);
426   s = format (s,
427               "%Urx: queues %d (max %d), desc %d "
428               "(min %d max %d align %d)\n",
429               format_white_space, indent + 2, xd->conf.n_rx_queues,
430               di.max_rx_queues, xd->conf.n_rx_desc, di.rx_desc_lim.nb_min,
431               di.rx_desc_lim.nb_max, di.rx_desc_lim.nb_align);
432   s = format (s,
433               "%Utx: queues %d (max %d), desc %d "
434               "(min %d max %d align %d)\n",
435               format_white_space, indent + 2, xd->conf.n_tx_queues,
436               di.max_tx_queues, xd->conf.n_tx_desc, di.tx_desc_lim.nb_min,
437               di.tx_desc_lim.nb_max, di.tx_desc_lim.nb_align);
438
439   rss_conf.rss_key = 0;
440   rss_conf.rss_hf = 0;
441   retval = rte_eth_dev_rss_hash_conf_get (xd->port_id, &rss_conf);
442   if (retval < 0)
443     clib_warning ("rte_eth_dev_rss_hash_conf_get returned %d", retval);
444
445   pci = dpdk_get_pci_device (&di);
446
447   if (pci)
448     {
449       u8 *s2;
450       if (xd->cpu_socket > -1)
451         s2 = format (0, "%d", xd->cpu_socket);
452       else
453         s2 = format (0, "unknown");
454       s = format (s,
455                   "%Upci: device %04x:%04x subsystem %04x:%04x "
456                   "address %04x:%02x:%02x.%02x numa %v\n",
457                   format_white_space, indent + 2, pci->id.vendor_id,
458                   pci->id.device_id, pci->id.subsystem_vendor_id,
459                   pci->id.subsystem_device_id, pci->addr.domain, pci->addr.bus,
460                   pci->addr.devid, pci->addr.function, s2);
461       vec_free (s2);
462     }
463
464   if (di.switch_info.domain_id != RTE_ETH_DEV_SWITCH_DOMAIN_ID_INVALID)
465     {
466       s = format (s, "%Uswitch info: %U\n", format_white_space, indent + 2,
467                   format_switch_info, &di.switch_info);
468     }
469
470   if (1 < verbose)
471     {
472       s = format (s, "%Umodule: %U\n", format_white_space, indent + 2,
473                   format_dpdk_device_module_info, xd);
474     }
475
476   s = format (s, "%Umax rx packet len: %d\n", format_white_space, indent + 2,
477               di.max_rx_pktlen);
478   s = format (s, "%Upromiscuous: unicast %s all-multicast %s\n",
479               format_white_space, indent + 2,
480               rte_eth_promiscuous_get (xd->port_id) ? "on" : "off",
481               rte_eth_allmulticast_get (xd->port_id) ? "on" : "off");
482   vlan_off = rte_eth_dev_get_vlan_offload (xd->port_id);
483   s = format (s, "%Uvlan offload: strip %s filter %s qinq %s\n",
484               format_white_space, indent + 2,
485               vlan_off & ETH_VLAN_STRIP_OFFLOAD ? "on" : "off",
486               vlan_off & ETH_VLAN_FILTER_OFFLOAD ? "on" : "off",
487               vlan_off & ETH_VLAN_EXTEND_OFFLOAD ? "on" : "off");
488   s = format (s, "%Urx offload avail:  %U\n", format_white_space, indent + 2,
489               format_dpdk_rx_offload_caps, di.rx_offload_capa);
490   s = format (s, "%Urx offload active: %U\n", format_white_space, indent + 2,
491               format_dpdk_rx_offload_caps, xd->enabled_rx_off);
492   s = format (s, "%Utx offload avail:  %U\n", format_white_space, indent + 2,
493               format_dpdk_tx_offload_caps, di.tx_offload_capa);
494   s = format (s, "%Utx offload active: %U\n", format_white_space, indent + 2,
495               format_dpdk_tx_offload_caps, xd->enabled_tx_off);
496   s = format (s,
497               "%Urss avail:         %U\n"
498               "%Urss active:        %U\n",
499               format_white_space, indent + 2, format_dpdk_rss_hf_name,
500               di.flow_type_rss_offloads, format_white_space, indent + 2,
501               format_dpdk_rss_hf_name, rss_conf.rss_hf);
502
503   if (rte_eth_tx_burst_mode_get (xd->port_id, 0, &mode) == 0)
504     {
505       s = format (s, "%Utx burst mode: %s%s\n", format_white_space, indent + 2,
506                   mode.info,
507                   mode.flags & RTE_ETH_BURST_FLAG_PER_QUEUE ? " (per queue)" :
508                                                               "");
509     }
510
511   s = format (s, "%Utx burst function: %U\n", format_white_space, indent + 2,
512               format_dpdk_burst_fn, xd, VLIB_TX);
513
514   if (rte_eth_rx_burst_mode_get (xd->port_id, 0, &mode) == 0)
515     {
516       s = format (s, "%Urx burst mode: %s%s\n", format_white_space, indent + 2,
517                   mode.info,
518                   mode.flags & RTE_ETH_BURST_FLAG_PER_QUEUE ? " (per queue)" :
519                                                               "");
520     }
521
522   s = format (s, "%Urx burst function: %U\n", format_white_space, indent + 2,
523               format_dpdk_burst_fn, xd, VLIB_RX);
524
525   /* $$$ MIB counters  */
526   {
527 #define _(N, V)                                                 \
528     if (xd->stats.V != 0) {                                    \
529       s = format (s, "\n%U%-40U%16Lu",                         \
530                   format_white_space, indent + 2,              \
531                   format_c_identifier, #N,                     \
532                   xd->stats.V);                                \
533     }                                                          \
534
535     foreach_dpdk_counter
536 #undef _
537   }
538
539   u8 *xs = 0;
540   u32 i = 0;
541   struct rte_eth_xstat *xstat;
542   struct rte_eth_xstat_name *xstat_names = 0;
543   int len = vec_len (xd->xstats);
544   vec_validate (xstat_names, len - 1);
545   int ret = rte_eth_xstats_get_names (xd->port_id, xstat_names, len);
546
547   if (ret >= 0 && ret <= len)
548     {
549       /* *INDENT-OFF* */
550       vec_foreach_index(i, xd->xstats)
551         {
552           xstat = vec_elt_at_index(xd->xstats, i);
553           if (verbose == 2 || (verbose && xstat->value))
554             {
555               xs = format(xs, "\n%U%-38s%16Lu",
556                           format_white_space, indent + 4,
557                           xstat_names[i].name,
558                           xstat->value);
559             }
560         }
561       /* *INDENT-ON* */
562
563       vec_free (xstat_names);
564     }
565
566   if (xs)
567     {
568       s = format (s, "\n%Uextended stats:%v",
569                   format_white_space, indent + 2, xs);
570       vec_free (xs);
571     }
572
573   if (vec_len (xd->errors))
574     {
575       s = format (s, "%UErrors:\n  %U", format_white_space, indent,
576                   format_dpdk_device_errors, xd);
577     }
578
579   return s;
580 }
581
582 u8 *
583 format_dpdk_tx_trace (u8 * s, va_list * va)
584 {
585   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
586   CLIB_UNUSED (vlib_node_t * node) = va_arg (*va, vlib_node_t *);
587   CLIB_UNUSED (vnet_main_t * vnm) = vnet_get_main ();
588   dpdk_tx_trace_t *t = va_arg (*va, dpdk_tx_trace_t *);
589   dpdk_main_t *dm = &dpdk_main;
590   dpdk_device_t *xd = vec_elt_at_index (dm->devices, t->device_index);
591   u32 indent = format_get_indent (s);
592   vnet_sw_interface_t *sw = vnet_get_sw_interface (vnm, xd->sw_if_index);
593
594   s = format (s, "%U tx queue %d",
595               format_vnet_sw_interface_name, vnm, sw, t->queue_index);
596
597   s = format (s, "\n%Ubuffer 0x%x: %U", format_white_space, indent,
598               t->buffer_index, format_vnet_buffer_no_chain, &t->buffer);
599
600   s = format (s, "\n%U%U",
601               format_white_space, indent,
602               format_dpdk_rte_mbuf, &t->mb, &t->data);
603
604   s = format (s, "\n%U%U", format_white_space, indent,
605               format_ethernet_header_with_length, t->buffer.pre_data,
606               sizeof (t->buffer.pre_data));
607
608   return s;
609 }
610
611 u8 *
612 format_dpdk_rx_trace (u8 * s, va_list * va)
613 {
614   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
615   CLIB_UNUSED (vlib_node_t * node) = va_arg (*va, vlib_node_t *);
616   CLIB_UNUSED (vnet_main_t * vnm) = vnet_get_main ();
617   dpdk_rx_trace_t *t = va_arg (*va, dpdk_rx_trace_t *);
618   dpdk_main_t *dm = &dpdk_main;
619   dpdk_device_t *xd = vec_elt_at_index (dm->devices, t->device_index);
620   format_function_t *f;
621   u32 indent = format_get_indent (s);
622   vnet_sw_interface_t *sw = vnet_get_sw_interface (vnm, xd->sw_if_index);
623
624   s = format (s, "%U rx queue %d",
625               format_vnet_sw_interface_name, vnm, sw, t->queue_index);
626
627   s = format (s, "\n%Ubuffer 0x%x: %U", format_white_space, indent,
628               t->buffer_index, format_vnet_buffer_no_chain, &t->buffer);
629
630   s = format (s, "\n%U%U",
631               format_white_space, indent,
632               format_dpdk_rte_mbuf, &t->mb, &t->data);
633
634   if (vm->trace_main.verbose)
635     {
636       s = format (s, "\n%UPacket Dump%s", format_white_space, indent + 2,
637                   t->mb.data_len > sizeof (t->data) ? " (truncated)" : "");
638       s = format (s, "\n%U%U", format_white_space, indent + 4,
639                   format_hexdump, &t->data,
640                   t->mb.data_len >
641                   sizeof (t->data) ? sizeof (t->data) : t->mb.data_len);
642     }
643   f = node->format_buffer;
644   if (!f)
645     f = format_hex_bytes;
646   s = format (s, "\n%U%U", format_white_space, indent,
647               f, t->buffer.pre_data, sizeof (t->buffer.pre_data));
648
649   return s;
650 }
651
652
653 static inline u8 *
654 format_dpdk_pkt_types (u8 * s, va_list * va)
655 {
656   u32 *pkt_types = va_arg (*va, u32 *);
657   u32 indent __attribute__ ((unused)) = format_get_indent (s) + 2;
658
659   if (!*pkt_types)
660     return s;
661
662   s = format (s, "Packet Types");
663
664 #define _(L, F, S)             \
665   if ((*pkt_types & RTE_PTYPE_##L##_MASK) == RTE_PTYPE_##L##_##F)           \
666     {                                                                       \
667       s = format (s, "\n%U%s (0x%04x) %s", format_white_space, indent,      \
668                      "RTE_PTYPE_" #L "_" #F, RTE_PTYPE_##L##_##F, S);       \
669     }
670
671   foreach_dpdk_pkt_type
672 #undef _
673     return s;
674 }
675
676 static inline u8 *
677 format_dpdk_pkt_offload_flags (u8 * s, va_list * va)
678 {
679   u64 *ol_flags = va_arg (*va, u64 *);
680   u32 indent = format_get_indent (s) + 2;
681   u64 rx_dynflag;
682   int rx_dynflag_offset;
683
684   if (!*ol_flags)
685     return s;
686
687   s = format (s, "Packet Offload Flags");
688
689 #define _(F, S)                                                               \
690   if (*ol_flags & RTE_MBUF_F_##F)                                             \
691     {                                                                         \
692       s = format (s, "\n%U%s (0x%04x) %s", format_white_space, indent,        \
693                   "PKT_" #F, RTE_MBUF_F_##F, S);                              \
694     }
695
696   foreach_dpdk_pkt_offload_flag
697 #undef _
698 #define _(F, P, S)                                                      \
699   {                                                                     \
700     rx_dynflag_offset = rte_mbuf_dynflag_lookup(RTE_MBUF_DYNFLAG_##F##_NAME, \
701                                                 P);                     \
702     if (rx_dynflag_offset >= 0)                                         \
703       {                                                                 \
704         rx_dynflag = (u64) 1 << rx_dynflag_offset;                      \
705         if (*ol_flags & rx_dynflag)                                     \
706           {                                                             \
707             s = format (s, "\n%U%s %s", format_white_space, indent,     \
708                         #F, S);                                         \
709           }                                                             \
710       }                                                                 \
711   }
712     foreach_dpdk_pkt_dyn_rx_offload_flag
713 #undef _
714     return s;
715 }
716
717 u8 *
718 format_dpdk_rte_mbuf_tso (u8 *s, va_list *va)
719 {
720   struct rte_mbuf *mb = va_arg (*va, struct rte_mbuf *);
721   if (mb->ol_flags & RTE_MBUF_F_TX_TCP_SEG)
722     {
723       s = format (s, "l4_len %u tso_segsz %u", mb->l4_len, mb->tso_segsz);
724     }
725   return s;
726 }
727
728 u8 *
729 format_dpdk_rte_mbuf_vlan (u8 * s, va_list * va)
730 {
731   ethernet_vlan_header_tv_t *vlan_hdr =
732     va_arg (*va, ethernet_vlan_header_tv_t *);
733
734   if (clib_net_to_host_u16 (vlan_hdr->type) == ETHERNET_TYPE_DOT1AD)
735     {
736       s = format (s, "%U 802.1q vlan ",
737                   format_ethernet_vlan_tci,
738                   clib_net_to_host_u16 (vlan_hdr->priority_cfi_and_id));
739       vlan_hdr++;
740     }
741
742   s = format (s, "%U",
743               format_ethernet_vlan_tci,
744               clib_net_to_host_u16 (vlan_hdr->priority_cfi_and_id));
745
746   return s;
747 }
748
749 u8 *
750 format_dpdk_rte_mbuf (u8 * s, va_list * va)
751 {
752   struct rte_mbuf *mb = va_arg (*va, struct rte_mbuf *);
753   ethernet_header_t *eth_hdr = va_arg (*va, ethernet_header_t *);
754   u32 indent = format_get_indent (s) + 2;
755
756   s = format (
757     s,
758     "PKT MBUF: port %d, nb_segs %d, pkt_len %d"
759     "\n%Ubuf_len %d, data_len %d, ol_flags 0x%lx, data_off %d, phys_addr 0x%x"
760     "\n%Upacket_type 0x%x l2_len %u l3_len %u outer_l2_len %u outer_l3_len %u "
761     "%U"
762     "\n%Urss 0x%x fdir.hi 0x%x fdir.lo 0x%x",
763     mb->port, mb->nb_segs, mb->pkt_len, format_white_space, indent,
764     mb->buf_len, mb->data_len, mb->ol_flags, mb->data_off, mb->buf_iova,
765     format_white_space, indent, mb->packet_type, mb->l2_len, mb->l3_len,
766     mb->outer_l2_len, mb->outer_l3_len, format_dpdk_rte_mbuf_tso, mb,
767     format_white_space, indent, mb->hash.rss, mb->hash.fdir.hi,
768     mb->hash.fdir.lo);
769
770   if (mb->ol_flags)
771     s = format (s, "\n%U%U", format_white_space, indent,
772                 format_dpdk_pkt_offload_flags, &mb->ol_flags);
773
774   if ((mb->ol_flags & RTE_MBUF_F_RX_VLAN) &&
775       ((mb->ol_flags &
776         (RTE_MBUF_F_RX_VLAN_STRIPPED | RTE_MBUF_F_RX_QINQ_STRIPPED)) == 0))
777     {
778       ethernet_vlan_header_tv_t *vlan_hdr =
779         ((ethernet_vlan_header_tv_t *) & (eth_hdr->type));
780       s = format (s, " %U", format_dpdk_rte_mbuf_vlan, vlan_hdr);
781     }
782
783   if (mb->packet_type)
784     s = format (s, "\n%U%U", format_white_space, indent,
785                 format_dpdk_pkt_types, &mb->packet_type);
786
787   return s;
788 }
789
790 clib_error_t *
791 unformat_rss_fn (unformat_input_t * input, uword * rss_fn)
792 {
793   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
794     {
795       if (0)
796         ;
797 #undef _
798 #define _(n, f, s)                                 \
799       else if (unformat (input, s))             \
800         *rss_fn |= f;
801
802       foreach_dpdk_rss_hf
803 #undef _
804         else
805         {
806           return clib_error_return (0, "unknown input `%U'",
807                                     format_unformat_error, input);
808         }
809     }
810   return 0;
811 }
812
813
814 /*
815  * fd.io coding-style-patch-verification: ON
816  *
817  * Local Variables:
818  * eval: (c-set-style "gnu")
819  * End:
820  */