Changeset 17a3dff for lib/format_dpdk.c


Ignore:
Timestamp:
04/26/14 23:23:17 (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:
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:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/format_dpdk.c

    r29bbef0 r17a3dff  
    827827    return 0;
    828828}
    829 int mapper_start(void *data); // This actually a void*
    830829
    831830/* Attach memory to the port and start the port or restart the ports.
     
    967966    // Can use remote launch for all
    968967    /*RTE_LCORE_FOREACH_SLAVE(i) {
    969                 rte_eal_remote_launch(mapper_start, (void *)libtrace, i);
     968                rte_eal_remote_launch(perpkt_threads_entry, (void *)libtrace, i);
    970969        }*/
    971970   
     
    996995    char err[500];
    997996    int enabled_lcore_count = 0, i=0;
    998     int tot = libtrace->mapper_thread_count;
     997    int tot = libtrace->perpkt_thread_count;
    999998    err[0] = 0;
    1000999       
    1001         libtrace->mapper_thread_count;
     1000        libtrace->perpkt_thread_count;
    10021001       
    10031002        for (i = 0; i < RTE_MAX_LCORE; i++)
     
    10071006        }
    10081007       
    1009         tot = MIN(libtrace->mapper_thread_count, enabled_lcore_count);
     1008        tot = MIN(libtrace->perpkt_thread_count, enabled_lcore_count);
    10101009        tot = MIN(tot, 8);
    1011         printf("Running pstart DPDK %d %d %d %d\n", tot, libtrace->mapper_thread_count, enabled_lcore_count, rte_lcore_count());
     1010        printf("Running pstart DPDK %d %d %d %d\n", tot, libtrace->perpkt_thread_count, enabled_lcore_count, rte_lcore_count());
    10121011       
    10131012    if (dpdk_start_port_queues(libtrace, FORMAT(libtrace), err, sizeof(err), tot) != 0) {
Note: See TracChangeset for help on using the changeset viewer.