Changeset 17a3dff for tools


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.

Location:
tools
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • tools/traceanon/traceanon_parallel.c

    rd6a56b6 r17a3dff  
    352352        int i = 1;
    353353        trace_parallel_config(trace, TRACE_OPTION_SEQUENTIAL, &i);
    354         //trace_parallel_config(trace, TRACE_OPTION_SET_MAPPER_BUFFER_SIZE, &i);
     354        //trace_parallel_config(trace, TRACE_OPTION_SET_PERPKT_BUFFER_SIZE, &i);
    355355        //trace_parallel_config(trace, TRACE_OPTION_USE_DEDICATED_HASHER, &i);
    356356        //trace_parallel_config(trace, TRACE_OPTION_USE_SLIDING_WINDOW_BUFFER, &i);
    357357        i = 2;
    358         trace_parallel_config(trace, TRACE_OPTION_SET_MAPPER_THREAD_COUNT, &i);
     358        trace_parallel_config(trace, TRACE_OPTION_SET_PERPKT_THREAD_COUNT, &i);
    359359       
    360360        if (trace_pstart(trace, NULL, &per_packet, NULL)==-1) {
  • tools/tracertstats/tracertstats_parallel.c

    rd6a56b6 r17a3dff  
    161161                assert(res != last_res);
    162162                last_res = res;
    163                 //printf("Mapper published %"PRIu64" - c=%"PRIu64"\n", ts, res->total.count);
     163                //printf("Perpkt published %"PRIu64" - c=%"PRIu64"\n", ts, res->total.count);
    164164                while (*last_ts < ts) {
    165165                        report_results((double) *last_ts * (double) packet_interval, count, bytes);
     
    218218                //assert(res != last_res);
    219219                last_res = res;
    220                 //printf("Mapper published %"PRIu64" - c=%"PRIu64"\n", ts, res->total.count);
     220                //printf("Perpkt published %"PRIu64" - c=%"PRIu64"\n", ts, res->total.count);
    221221                /*while (*last_ts < ts) {
    222222                        report_results((double) *last_ts * (double) packet_interval, count, bytes);
  • tools/tracestats/tracestats_parallel.c

    rd6a56b6 r17a3dff  
    215215        //trace_parallel_config(trace, TRACE_OPTION_USE_SLIDING_WINDOW_BUFFER, &option);
    216216        option = 2;
    217         trace_parallel_config(trace, TRACE_OPTION_SET_MAPPER_THREAD_COUNT, &option);
     217        trace_parallel_config(trace, TRACE_OPTION_SET_PERPKT_THREAD_COUNT, &option);
    218218        //trace_parallel_config(trace, TRACE_OPTION_SET_MAPPER_BUFFER_SIZE, &option);
    219219
Note: See TracChangeset for help on using the changeset viewer.