Changeset 8af0d01

Timestamp:

07/04/14 14:07:34 (7 years ago)

Author:

Richard Sanger <rsangerarj@…>

Branches:

4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes

Children:

50ce607

Parents:

0c866b0

Message:

Limit threads to number of queues detected on the card we are connected to rather than hardcoded at 8

File:

• lib/format_dpdk.c (modified) (2 diffs)

lib/format_dpdk.c

@@ -1032 +1032 @@
 }
 
+static inline size_t dpdk_get_max_rx_queues(uint8_t port_id) {
+    struct rte_eth_dev_info dev_info;
+    rte_eth_dev_info_get(0, &dev_info);
+    return dev_info.max_rx_queues;
+}
+
 static int dpdk_pstart_input (libtrace_t *libtrace) {
     char err[500];
@@ -1047 +1053 @@
         
         tot = MIN(libtrace->perpkt_thread_count, enabled_lcore_count);
-        tot = MIN(tot, 8);
+        tot = MIN(tot, dpdk_get_max_rx_queues(FORMAT(libtrace)->port));
         fprintf(stderr, "Running pstart DPDK %d %d %d %d\n", tot, libtrace->perpkt_thread_count, enabled_lcore_count, rte_lcore_count());