Changeset 17a3dff for lib/format_dpdk.c

Timestamp:

04/26/14 23:23:17 (8 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:

5ce14a5

Parents:

60e8e86

Message:

Rename from google map/reduce framework names to something more meaningful.
Rename mapper to perpkt since this is what it actually is in libtrace.

File:

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

lib/format_dpdk.c

@@ -827 +827 @@
     return 0;
 }
-int mapper_start(void *data); // This actually a void*
 
 /* Attach memory to the port and start the port or restart the ports.
@@ -967 +966 @@
     // Can use remote launch for all
     /*RTE_LCORE_FOREACH_SLAVE(i) {
-                rte_eal_remote_launch(mapper_start, (void *)libtrace, i);
+                rte_eal_remote_launch(perpkt_threads_entry, (void *)libtrace, i);
         }*/
     
@@ -996 +995 @@
     char err[500];
     int enabled_lcore_count = 0, i=0;
-    int tot = libtrace->mapper_thread_count;
+    int tot = libtrace->perpkt_thread_count;
     err[0] = 0;
         
-        libtrace->mapper_thread_count;
+        libtrace->perpkt_thread_count;
         
         for (i = 0; i < RTE_MAX_LCORE; i++)
@@ -1007 +1006 @@
         }
         
-        tot = MIN(libtrace->mapper_thread_count, enabled_lcore_count);
+        tot = MIN(libtrace->perpkt_thread_count, enabled_lcore_count);
         tot = MIN(tot, 8);
-        printf("Running pstart DPDK %d %d %d %d\n", tot, libtrace->mapper_thread_count, enabled_lcore_count, rte_lcore_count());
+        printf("Running pstart DPDK %d %d %d %d\n", tot, libtrace->perpkt_thread_count, enabled_lcore_count, rte_lcore_count());
         
     if (dpdk_start_port_queues(libtrace, FORMAT(libtrace), err, sizeof(err), tot) != 0) {