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 ",
 201                   (l->link_duplex == RTE_ETH_LINK_FULL_DUPLEX) ? "full" :
 202                                                                        "half");
 203       s = format (s, "max-frame-size %d %s\n", hi->max_frame_size,
 204                   promisc ? " promisc" : "");
 205     }
 206   else
 207     s = format (s, "\n");
 208
 209   return s;
 210 }
 211
 212 #define _(n, v, str)                                            \
 213 if (bitmap & v) {                                            \
 214   if (format_get_indent (s) > 72)                            \
 215     s = format(s,"\n%U", format_white_space, indent);        \
 216   s = format(s, "%s ", str);                                 \
 217 }
 218
 219 u8 *
 220 format_dpdk_rss_hf_name (u8 * s, va_list * args)
 221 {
 222   u64 bitmap = va_arg (*args, u64);
 223   u32 indent = format_get_indent (s);
 224
 225   if (!bitmap)
 226     return format (s, "none");
 227
 228   foreach_dpdk_rss_hf return s;
 229 }
 230
 231 #undef _
 232
 233 /* Convert to all lower case e.g "VLAN_STRIP" -> "vlan-strip"
 234    Works for both vector names and null terminated c strings. */
 235 static u8 *
 236 format_offload (u8 * s, va_list * va)
 237 {
 238   u8 *id = va_arg (*va, u8 *);
 239   uword i, l;
 240
 241   l = ~0;
 242
 243   if (id)
 244     for (i = 0; id[i] != 0 && i < l; i++)
 245       {
 246         u8 c = id[i];
 247
 248         if (c == '_')
 249           c = '-';
 250         else
 251           c = tolower (c);
 252         vec_add1 (s, c);
 253       }
 254
 255   return s;
 256 }
 257
 258 #define _(v, func)                                           \
 259 if (bitmap & v) {                                            \
 260   if (format_get_indent (s) > 72)                            \
 261     s = format(s,"\n%U", format_white_space, indent);        \
 262   s = format(s, "%U ", format_offload, func (v));            \
 263 }
 264
 265 u8 *
 266 format_dpdk_rx_offload_caps (u8 * s, va_list * args)
 267 {
 268   u64 bitmap = va_arg (*args, u32);
 269   u32 indent = format_get_indent (s);
 270   uword i;
 271
 272   if (!bitmap)
 273     return format (s, "none");
 274
 275   for (i = 0; i < 64; i++)
 276     {
 277       u64 mask = (u64) 1 << i;
 278
 279       _(mask, rte_eth_dev_rx_offload_name);
 280     }
 281   return s;
 282 }
 283
 284 u8 *
 285 format_dpdk_tx_offload_caps (u8 * s, va_list * args)
 286 {
 287   u64 bitmap = va_arg (*args, u32);
 288   u32 indent = format_get_indent (s);
 289   uword i;
 290
 291   if (!bitmap)
 292     return format (s, "none");
 293
 294   for (i = 0; i < 64; i++)
 295     {
 296       u64 mask = (u64) 1 << i;
 297
 298       _(mask, rte_eth_dev_tx_offload_name);
 299     }
 300   return s;
 301 }
 302
 303 #undef _
 304
 305 u8 *
 306 format_dpdk_device_errors (u8 * s, va_list * args)
 307 {
 308   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
 309   clib_error_t *e;
 310   u32 indent = format_get_indent (s);
 311
 312   vec_foreach (e, xd->errors)
 313   {
 314     s = format (s, "%U%v\n", format_white_space, indent, e->what);
 315   }
 316   return s;
 317 }
 318
 319 static u8 *
 320 format_dpdk_device_module_info (u8 * s, va_list * args)
 321 {
 322   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
 323   struct rte_eth_dev_module_info mi = { 0 };
 324   struct rte_dev_eeprom_info ei = { 0 };
 325
 326   if (rte_eth_dev_get_module_info (xd->port_id, &mi) != 0)
 327     return format (s, "unknown");
 328
 329   ei.length = mi.eeprom_len;
 330   ei.data = clib_mem_alloc (mi.eeprom_len);
 331
 332   if (rte_eth_dev_get_module_eeprom (xd->port_id, &ei) == 0)
 333     {
 334       s = format (s, "%U", format_sfp_eeprom, ei.data +
 335                   (mi.type == RTE_ETH_MODULE_SFF_8436 ? 0x80 : 0));
 336     }
 337   else
 338     s = format (s, "eeprom read error");
 339
 340   clib_mem_free (ei.data);
 341   return s;
 342 }
 343
 344 u8 *
 345 format_dpdk_burst_fn (u8 *s, va_list *args)
 346 {
 347   dpdk_device_t *xd = va_arg (*args, dpdk_device_t *);
 348   vlib_rx_or_tx_t dir = va_arg (*args, vlib_rx_or_tx_t);
 349   void *p;
 350   Dl_info info = { 0 };
 351
 352 #if RTE_VERSION < RTE_VERSION_NUM(21, 11, 0, 0)
 353 #define rte_eth_fp_ops rte_eth_devices
 354 #endif
 355
 356   p = (dir == VLIB_TX) ? rte_eth_fp_ops[xd->port_id].tx_pkt_burst :
 357                          rte_eth_fp_ops[xd->port_id].rx_pkt_burst;
 358
 359   if (dladdr (p, &info) == 0 || info.dli_sname == 0)
 360     return format (s, "(not available)");
 361
 362   return format (s, "%s", info.dli_sname);
 363 }
 364
 365 static u8 *
 366 format_switch_info (u8 * s, va_list * args)
 367 {
 368   struct rte_eth_switch_info *si =
 369     va_arg (*args, struct rte_eth_switch_info *);
 370
 371   if (si->name)
 372     s = format (s, "name %s ", si->name);
 373
 374   s = format (s, "domain id %d port id %d", si->domain_id, si->port_id);
 375
 376   return s;
 377 }
 378
 379 u8 *
 380 format_dpdk_rte_device (u8 *s, va_list *args)
 381 {
 382   struct rte_device *d = va_arg (*args, struct rte_device *);
 383
 384   if (!d)
 385     return format (s, "not available");
 386
 387 #if RTE_VERSION >= RTE_VERSION_NUM(22, 11, 0, 0)
 388   s =
 389     format (s, "name: %s, numa: %d", rte_dev_name (d), rte_dev_numa_node (d));
 390
 391   if (rte_dev_driver (d))
 392     s = format (s, ", driver: %s", rte_driver_name (rte_dev_driver (d)));
 393
 394   if (rte_dev_bus (d))
 395     s = format (s, ", bus: %s", rte_bus_name (rte_dev_bus (d)));
 396 #else
 397   s = format (s, "name: %s, numa: %d", d->name, d->numa_node);
 398
 399   if (d->driver)
 400     s = format (s, ", driver: %s", d->driver->name);
 401
 402   if (d->bus)
 403     s = format (s, ", bus: %s", d->bus->name);
 404 #endif
 405
 406   return s;
 407 }
 408
 409 u8 *
 410 format_dpdk_device (u8 * s, va_list * args)
 411 {
 412   u32 dev_instance = va_arg (*args, u32);
 413   int verbose = va_arg (*args, int);
 414   dpdk_main_t *dm = &dpdk_main;
 415   vlib_main_t *vm = vlib_get_main ();
 416   dpdk_device_t *xd = vec_elt_at_index (dm->devices, dev_instance);
 417   u32 indent = format_get_indent (s);
 418   f64 now = vlib_time_now (vm);
 419   struct rte_eth_dev_info di;
 420   struct rte_eth_burst_mode mode;
 421   struct rte_pci_device *pci;
 422   struct rte_eth_rss_conf rss_conf;
 423   int vlan_off;
 424   int retval;
 425
 426   dpdk_update_counters (xd, now);
 427   dpdk_update_link_state (xd, now);
 428   rte_eth_dev_info_get (xd->port_id, &di);
 429
 430   s = format (s, "%U\n%Ucarrier %U",
 431               format_dpdk_device_type, dev_instance,
 432               format_white_space, indent + 2, format_dpdk_link_status, xd);
 433   s = format (s, "%Uflags: %U\n",
 434               format_white_space, indent + 2, format_dpdk_device_flags, xd);
 435 #if RTE_VERSION >= RTE_VERSION_NUM(22, 11, 0, 0)
 436   if (rte_dev_devargs (di.device) && rte_dev_devargs (di.device)->args)
 437     s = format (s, "%UDevargs: %s\n", format_white_space, indent + 2,
 438                 rte_dev_devargs (di.device)->args);
 439 #else
 440   if (di.device->devargs && di.device->devargs->args)
 441     s = format (s, "%UDevargs: %s\n",
 442                 format_white_space, indent + 2, di.device->devargs->args);
 443 #endif
 444   s = format (s,
 445               "%Urx: queues %d (max %d), desc %d "
 446               "(min %d max %d align %d)\n",
 447               format_white_space, indent + 2, xd->conf.n_rx_queues,
 448               di.max_rx_queues, xd->conf.n_rx_desc, di.rx_desc_lim.nb_min,
 449               di.rx_desc_lim.nb_max, di.rx_desc_lim.nb_align);
 450   s = format (s,
 451               "%Utx: queues %d (max %d), desc %d "
 452               "(min %d max %d align %d)\n",
 453               format_white_space, indent + 2, xd->conf.n_tx_queues,
 454               di.max_tx_queues, xd->conf.n_tx_desc, di.tx_desc_lim.nb_min,
 455               di.tx_desc_lim.nb_max, di.tx_desc_lim.nb_align);
 456
 457   rss_conf.rss_key = 0;
 458   rss_conf.rss_hf = 0;
 459   retval = rte_eth_dev_rss_hash_conf_get (xd->port_id, &rss_conf);
 460   if (retval < 0)
 461     clib_warning ("rte_eth_dev_rss_hash_conf_get returned %d", retval);
 462
 463   pci = dpdk_get_pci_device (&di);
 464
 465   if (pci)
 466     {
 467       u8 *s2;
 468       if (xd->cpu_socket > -1)
 469         s2 = format (0, "%d", xd->cpu_socket);
 470       else
 471         s2 = format (0, "unknown");
 472       s = format (s,
 473                   "%Upci: device %04x:%04x subsystem %04x:%04x "
 474                   "address %04x:%02x:%02x.%02x numa %v\n",
 475                   format_white_space, indent + 2, pci->id.vendor_id,
 476                   pci->id.device_id, pci->id.subsystem_vendor_id,
 477                   pci->id.subsystem_device_id, pci->addr.domain, pci->addr.bus,
 478                   pci->addr.devid, pci->addr.function, s2);
 479       vec_free (s2);
 480     }
 481
 482   if (di.switch_info.domain_id != RTE_ETH_DEV_SWITCH_DOMAIN_ID_INVALID)
 483     {
 484       s = format (s, "%Uswitch info: %U\n", format_white_space, indent + 2,
 485                   format_switch_info, &di.switch_info);
 486     }
 487
 488   if (1 < verbose)
 489     {
 490       s = format (s, "%Umodule: %U\n", format_white_space, indent + 2,
 491                   format_dpdk_device_module_info, xd);
 492     }
 493
 494   s = format (s, "%Umax rx packet len: %d\n", format_white_space, indent + 2,
 495               di.max_rx_pktlen);
 496   s = format (s, "%Upromiscuous: unicast %s all-multicast %s\n",
 497               format_white_space, indent + 2,
 498               rte_eth_promiscuous_get (xd->port_id) ? "on" : "off",
 499               rte_eth_allmulticast_get (xd->port_id) ? "on" : "off");
 500   vlan_off = rte_eth_dev_get_vlan_offload (xd->port_id);
 501   s = format (s, "%Uvlan offload: strip %s filter %s qinq %s\n",
 502               format_white_space, indent + 2,
 503               vlan_off & RTE_ETH_VLAN_STRIP_OFFLOAD ? "on" : "off",
 504               vlan_off & RTE_ETH_VLAN_FILTER_OFFLOAD ? "on" : "off",
 505               vlan_off & RTE_ETH_VLAN_EXTEND_OFFLOAD ? "on" : "off");
 506   s = format (s, "%Urx offload avail:  %U\n", format_white_space, indent + 2,
 507               format_dpdk_rx_offload_caps, di.rx_offload_capa);
 508   s = format (s, "%Urx offload active: %U\n", format_white_space, indent + 2,
 509               format_dpdk_rx_offload_caps, xd->enabled_rx_off);
 510   s = format (s, "%Utx offload avail:  %U\n", format_white_space, indent + 2,
 511               format_dpdk_tx_offload_caps, di.tx_offload_capa);
 512   s = format (s, "%Utx offload active: %U\n", format_white_space, indent + 2,
 513               format_dpdk_tx_offload_caps, xd->enabled_tx_off);
 514   s = format (s,
 515               "%Urss avail:         %U\n"
 516               "%Urss active:        %U\n",
 517               format_white_space, indent + 2, format_dpdk_rss_hf_name,
 518               di.flow_type_rss_offloads, format_white_space, indent + 2,
 519               format_dpdk_rss_hf_name, rss_conf.rss_hf);
 520
 521   if (rte_eth_tx_burst_mode_get (xd->port_id, 0, &mode) == 0)
 522     {
 523       s = format (s, "%Utx burst mode: %s%s\n", format_white_space, indent + 2,
 524                   mode.info,
 525                   mode.flags & RTE_ETH_BURST_FLAG_PER_QUEUE ? " (per queue)" :
 526                                                               "");
 527     }
 528
 529   s = format (s, "%Utx burst function: %U\n", format_white_space, indent + 2,
 530               format_dpdk_burst_fn, xd, VLIB_TX);
 531
 532   if (rte_eth_rx_burst_mode_get (xd->port_id, 0, &mode) == 0)
 533     {
 534       s = format (s, "%Urx burst mode: %s%s\n", format_white_space, indent + 2,
 535                   mode.info,
 536                   mode.flags & RTE_ETH_BURST_FLAG_PER_QUEUE ? " (per queue)" :
 537                                                               "");
 538     }
 539
 540   s = format (s, "%Urx burst function: %U\n", format_white_space, indent + 2,
 541               format_dpdk_burst_fn, xd, VLIB_RX);
 542
 543   /* $$$ MIB counters  */
 544   {
 545 #define _(N, V)                                                 \
 546     if (xd->stats.V != 0) {                                    \
 547       s = format (s, "\n%U%-40U%16Lu",                         \
 548                   format_white_space, indent + 2,              \
 549                   format_c_identifier, #N,                     \
 550                   xd->stats.V);                                \
 551     }                                                          \
 552
 553     foreach_dpdk_counter
 554 #undef _
 555   }
 556
 557   u8 *xs = 0;
 558   u32 i = 0;
 559   struct rte_eth_xstat *xstat;
 560   struct rte_eth_xstat_name *xstat_names = 0;
 561   int len = vec_len (xd->xstats);
 562   vec_validate (xstat_names, len - 1);
 563   int ret = rte_eth_xstats_get_names (xd->port_id, xstat_names, len);
 564
 565   if (ret >= 0 && ret <= len)
 566     {
 567       /* *INDENT-OFF* */
 568       vec_foreach_index(i, xd->xstats)
 569         {
 570           xstat = vec_elt_at_index(xd->xstats, i);
 571           if (verbose == 2 || (verbose && xstat->value))
 572             {
 573               xs = format(xs, "\n%U%-38s%16Lu",
 574                           format_white_space, indent + 4,
 575                           xstat_names[i].name,
 576                           xstat->value);
 577             }
 578         }
 579       /* *INDENT-ON* */
 580
 581       vec_free (xstat_names);
 582     }
 583
 584   if (xs)
 585     {
 586       s = format (s, "\n%Uextended stats:%v",
 587                   format_white_space, indent + 2, xs);
 588       vec_free (xs);
 589     }
 590
 591   if (vec_len (xd->errors))
 592     {
 593       s = format (s, "%UErrors:\n  %U", format_white_space, indent,
 594                   format_dpdk_device_errors, xd);
 595     }
 596
 597   return s;
 598 }
 599
 600 u8 *
 601 format_dpdk_tx_trace (u8 * s, va_list * va)
 602 {
 603   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
 604   CLIB_UNUSED (vlib_node_t * node) = va_arg (*va, vlib_node_t *);
 605   CLIB_UNUSED (vnet_main_t * vnm) = vnet_get_main ();
 606   dpdk_tx_trace_t *t = va_arg (*va, dpdk_tx_trace_t *);
 607   dpdk_main_t *dm = &dpdk_main;
 608   dpdk_device_t *xd = vec_elt_at_index (dm->devices, t->device_index);
 609   u32 indent = format_get_indent (s);
 610   vnet_sw_interface_t *sw = vnet_get_sw_interface (vnm, xd->sw_if_index);
 611
 612   s = format (s, "%U tx queue %d",
 613               format_vnet_sw_interface_name, vnm, sw, t->queue_index);
 614
 615   s = format (s, "\n%Ubuffer 0x%x: %U", format_white_space, indent,
 616               t->buffer_index, format_vnet_buffer_no_chain, &t->buffer);
 617
 618   s = format (s, "\n%U%U",
 619               format_white_space, indent,
 620               format_dpdk_rte_mbuf, &t->mb, &t->data);
 621
 622   s = format (s, "\n%U%U", format_white_space, indent,
 623               format_ethernet_header_with_length, t->buffer.pre_data,
 624               sizeof (t->buffer.pre_data));
 625
 626   return s;
 627 }
 628
 629 u8 *
 630 format_dpdk_rx_trace (u8 * s, va_list * va)
 631 {
 632   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
 633   CLIB_UNUSED (vlib_node_t * node) = va_arg (*va, vlib_node_t *);
 634   CLIB_UNUSED (vnet_main_t * vnm) = vnet_get_main ();
 635   dpdk_rx_trace_t *t = va_arg (*va, dpdk_rx_trace_t *);
 636   dpdk_main_t *dm = &dpdk_main;
 637   dpdk_device_t *xd = vec_elt_at_index (dm->devices, t->device_index);
 638   format_function_t *f;
 639   u32 indent = format_get_indent (s);
 640   vnet_sw_interface_t *sw = vnet_get_sw_interface (vnm, xd->sw_if_index);
 641
 642   s = format (s, "%U rx queue %d",
 643               format_vnet_sw_interface_name, vnm, sw, t->queue_index);
 644
 645   s = format (s, "\n%Ubuffer 0x%x: %U", format_white_space, indent,
 646               t->buffer_index, format_vnet_buffer_no_chain, &t->buffer);
 647
 648   s = format (s, "\n%U%U",
 649               format_white_space, indent,
 650               format_dpdk_rte_mbuf, &t->mb, &t->data);
 651
 652   if (vm->trace_main.verbose)
 653     {
 654       s = format (s, "\n%UPacket Dump%s", format_white_space, indent + 2,
 655                   t->mb.data_len > sizeof (t->data) ? " (truncated)" : "");
 656       s = format (s, "\n%U%U", format_white_space, indent + 4,
 657                   format_hexdump, &t->data,
 658                   t->mb.data_len >
 659                   sizeof (t->data) ? sizeof (t->data) : t->mb.data_len);
 660     }
 661   f = node->format_buffer;
 662   if (!f)
 663     f = format_hex_bytes;
 664   s = format (s, "\n%U%U", format_white_space, indent,
 665               f, t->buffer.pre_data, sizeof (t->buffer.pre_data));
 666
 667   return s;
 668 }
 669
 670
 671 static inline u8 *
 672 format_dpdk_pkt_types (u8 * s, va_list * va)
 673 {
 674   u32 *pkt_types = va_arg (*va, u32 *);
 675   u32 indent __attribute__ ((unused)) = format_get_indent (s) + 2;
 676
 677   if (!*pkt_types)
 678     return s;
 679
 680   s = format (s, "Packet Types");
 681
 682 #define _(L, F, S)             \
 683   if ((*pkt_types & RTE_PTYPE_##L##_MASK) == RTE_PTYPE_##L##_##F)           \
 684     {                                                                       \
 685       s = format (s, "\n%U%s (0x%04x) %s", format_white_space, indent,      \
 686                      "RTE_PTYPE_" #L "_" #F, RTE_PTYPE_##L##_##F, S);       \
 687     }
 688
 689   foreach_dpdk_pkt_type
 690 #undef _
 691     return s;
 692 }
 693
 694 static inline u8 *
 695 format_dpdk_pkt_offload_flags (u8 * s, va_list * va)
 696 {
 697   u64 *ol_flags = va_arg (*va, u64 *);
 698   u32 indent = format_get_indent (s) + 2;
 699   u64 rx_dynflag;
 700   int rx_dynflag_offset;
 701
 702   if (!*ol_flags)
 703     return s;
 704
 705   s = format (s, "Packet Offload Flags");
 706
 707 #define _(F, S)                                                               \
 708   if (*ol_flags & RTE_MBUF_F_##F)                                             \
 709     {                                                                         \
 710       s = format (s, "\n%U%s (0x%04x) %s", format_white_space, indent,        \
 711                   "PKT_" #F, RTE_MBUF_F_##F, S);                              \
 712     }
 713
 714   foreach_dpdk_pkt_offload_flag
 715 #undef _
 716 #define _(F, P, S)                                                      \
 717   {                                                                     \
 718     rx_dynflag_offset = rte_mbuf_dynflag_lookup(RTE_MBUF_DYNFLAG_##F##_NAME, \
 719                                                 P);                     \
 720     if (rx_dynflag_offset >= 0)                                         \
 721       {                                                                 \
 722         rx_dynflag = (u64) 1 << rx_dynflag_offset;                      \
 723         if (*ol_flags & rx_dynflag)                                     \
 724           {                                                             \
 725             s = format (s, "\n%U%s %s", format_white_space, indent,     \
 726                         #F, S);                                         \
 727           }                                                             \
 728       }                                                                 \
 729   }
 730     foreach_dpdk_pkt_dyn_rx_offload_flag
 731 #undef _
 732     return s;
 733 }
 734
 735 u8 *
 736 format_dpdk_rte_mbuf_tso (u8 *s, va_list *va)
 737 {
 738   struct rte_mbuf *mb = va_arg (*va, struct rte_mbuf *);
 739   if (mb->ol_flags & RTE_MBUF_F_TX_TCP_SEG)
 740     {
 741       s = format (s, "l4_len %u tso_segsz %u", mb->l4_len, mb->tso_segsz);
 742     }
 743   return s;
 744 }
 745
 746 u8 *
 747 format_dpdk_rte_mbuf_vlan (u8 * s, va_list * va)
 748 {
 749   ethernet_vlan_header_tv_t *vlan_hdr =
 750     va_arg (*va, ethernet_vlan_header_tv_t *);
 751
 752   if (clib_net_to_host_u16 (vlan_hdr->type) == ETHERNET_TYPE_DOT1AD)
 753     {
 754       s = format (s, "%U 802.1q vlan ",
 755                   format_ethernet_vlan_tci,
 756                   clib_net_to_host_u16 (vlan_hdr->priority_cfi_and_id));
 757       vlan_hdr++;
 758     }
 759
 760   s = format (s, "%U",
 761               format_ethernet_vlan_tci,
 762               clib_net_to_host_u16 (vlan_hdr->priority_cfi_and_id));
 763
 764   return s;
 765 }
 766
 767 u8 *
 768 format_dpdk_rte_mbuf (u8 * s, va_list * va)
 769 {
 770   struct rte_mbuf *mb = va_arg (*va, struct rte_mbuf *);
 771   ethernet_header_t *eth_hdr = va_arg (*va, ethernet_header_t *);
 772   u32 indent = format_get_indent (s) + 2;
 773
 774   s = format (
 775     s,
 776     "PKT MBUF: port %d, nb_segs %d, pkt_len %d"
 777     "\n%Ubuf_len %d, data_len %d, ol_flags 0x%lx, data_off %d, phys_addr 0x%x"
 778     "\n%Upacket_type 0x%x l2_len %u l3_len %u outer_l2_len %u outer_l3_len %u "
 779     "%U"
 780     "\n%Urss 0x%x fdir.hi 0x%x fdir.lo 0x%x",
 781     mb->port, mb->nb_segs, mb->pkt_len, format_white_space, indent,
 782     mb->buf_len, mb->data_len, mb->ol_flags, mb->data_off, mb->buf_iova,
 783     format_white_space, indent, mb->packet_type, mb->l2_len, mb->l3_len,
 784     mb->outer_l2_len, mb->outer_l3_len, format_dpdk_rte_mbuf_tso, mb,
 785     format_white_space, indent, mb->hash.rss, mb->hash.fdir.hi,
 786     mb->hash.fdir.lo);
 787
 788   if (mb->ol_flags)
 789     s = format (s, "\n%U%U", format_white_space, indent,
 790                 format_dpdk_pkt_offload_flags, &mb->ol_flags);
 791
 792   if ((mb->ol_flags & RTE_MBUF_F_RX_VLAN) &&
 793       ((mb->ol_flags &
 794         (RTE_MBUF_F_RX_VLAN_STRIPPED | RTE_MBUF_F_RX_QINQ_STRIPPED)) == 0))
 795     {
 796       ethernet_vlan_header_tv_t *vlan_hdr =
 797         ((ethernet_vlan_header_tv_t *) & (eth_hdr->type));
 798       s = format (s, " %U", format_dpdk_rte_mbuf_vlan, vlan_hdr);
 799     }
 800
 801   if (mb->packet_type)
 802     s = format (s, "\n%U%U", format_white_space, indent,
 803                 format_dpdk_pkt_types, &mb->packet_type);
 804
 805   return s;
 806 }
 807
 808 clib_error_t *
 809 unformat_rss_fn (unformat_input_t * input, uword * rss_fn)
 810 {
 811   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
 812     {
 813       if (0)
 814         ;
 815 #undef _
 816 #define _(n, f, s)                                 \
 817       else if (unformat (input, s))             \
 818         *rss_fn |= f;
 819
 820       foreach_dpdk_rss_hf
 821 #undef _
 822         else
 823         {
 824           return clib_error_return (0, "unknown input `%U'",
 825                                     format_unformat_error, input);
 826         }
 827     }
 828   return 0;
 829 }
 830
 831
 832 /*
 833  * fd.io coding-style-patch-verification: ON
 834  *
 835  * Local Variables:
 836  * eval: (c-set-style "gnu")
 837  * End:
 838  */