Changeset 6b98325 for tools


Ignore:
Timestamp:
03/23/15 17:52: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:
773d5e2
Parents:
963b13b
Message:

Removes pconfig_input() and replaces trace_config() with trace_set_<option>

  • Removes trace_pconfig completely - only trace_set_hasher is left now in trace_config
  • Rework user configuration so this is no longer modified directly. Now we just apply it directly to a trace.
  • Many minor documentation fixes and additions
Location:
tools
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • tools/traceanon/traceanon_parallel.c

    r6a6e6a8 r6b98325  
    253253        char *compress_type_str=NULL;
    254254        trace_option_compresstype_t compress_type = TRACE_OPTION_COMPRESSTYPE_NONE;
    255         struct user_configuration uc;
    256         ZERO_USER_CONFIG(uc);
     255        char *config = NULL;
     256        char *config_file = NULL;
    257257
    258258        if (argc<2)
     
    326326                                  break;
    327327                        case 'u':
    328                                   parse_user_config(&uc, optarg);
    329                                   break;
    330                         case 'U':;
    331                                 FILE * f = fopen(optarg, "r");
    332                                 if (f != NULL) {
    333                                         parse_user_config_file(&uc, f);
    334                                 } else {
    335                                         perror("Failed to open configuration file\n");
    336                                         usage(argv[0]);
    337                                 }
     328                                config = optarg;
     329                                break;
     330                        case 'U':
     331                                config_file = optarg;
    338332                                break;
    339333                        default:
     
    372366                return 1;
    373367        }
    374        
    375 
    376        
    377368
    378369        /* open input uri */
     
    427418                trace_destroy_output(writer);
    428419                trace_destroy(trace);
    429                 return 1;
     420                return 1;
    430421        }
    431422
     
    436427         * special case to have.
    437428         */
    438          
    439         int i = 1;
     429
     430        /* Apply config */
     431        if (config) {
     432                trace_set_configuration(trace, config);
     433        }
     434
     435        if (config_file) {
     436                FILE * f = fopen(optarg, "r");
     437                if (f != NULL) {
     438                        trace_set_configuration_file(trace, f);
     439                        fclose(f);
     440                } else {
     441                        perror("Failed to open configuration file\n");
     442                        usage(argv[0]);
     443                }
     444        }
     445
    440446        trace_set_combiner(trace, &combiner_ordered, (libtrace_generic_t){0});
    441         trace_parallel_config(trace, TRACE_OPTION_SET_CONFIG, &uc);
    442447
    443448        //trace_set_hasher(trace, HASHER_CUSTOM, rand_hash, NULL);
  • tools/tracertstats/tracertstats_parallel.c

    r6a6e6a8 r6b98325  
    294294                return;
    295295        }*/
    296         int i = 1;
    297296        trace_set_combiner(trace, &combiner_ordered, (libtrace_generic_t){0});
    298         /* trace_parallel_config(trace, TRACE_OPTION_TRACETIME, &i); */
     297        trace_set_tracetime(trace, true);
     298
    299299        //trace_set_hasher(trace, HASHER_CUSTOM, &bad_hash, NULL);
    300300
    301301        if (trace_get_information(trace)->live) {
    302                 i = (int) (packet_interval * 1000); // Every interval send a tick
    303                 trace_parallel_config(trace, TRACE_OPTION_TICK_INTERVAL, &i);
     302                trace_set_tick_interval(trace, (int) (packet_interval * 1000));
    304303        }
    305304
  • tools/tracestats/tracestats.c

    r5ab626a r6b98325  
    129129                bytes+=wlen;
    130130        }
     131        trace_destroy_packet(packet);
    131132
    132133        stats = trace_get_statistics(trace, NULL);
  • tools/tracestats/tracestats_parallel.c

    r6a6e6a8 r6b98325  
    215215}
    216216
    217 struct user_configuration uc;
    218 
    219 
    220217/* Process a trace, counting packets that match filter(s) */
    221 static void run_trace(char *uri)
     218static void run_trace(char *uri, char *config, char *config_file)
    222219{
    223220
     
    230227                return;
    231228        }
    232        
    233         int option = 2;
     229
     230        //libtrace_filter_t *f = trace_create_filter("udp");
     231        //trace_config(trace, TRACE_OPTION_FILTER, f);
     232
     233        //trace_config(trace, TRACE_OPTION_META_FREQ, &option);
    234234        //option = 10000;
    235     //trace_set_hasher(trace, HASHER_CUSTOM, &rand_hash, NULL);
     235        trace_set_hasher(trace, HASHER_CUSTOM, &rand_hash, NULL);
    236236        //trace_parallel_config(trace, TRACE_OPTION_SET_PERPKT_THREAD_COUNT, &option);
    237         trace_parallel_config(trace, TRACE_OPTION_SET_CONFIG, &uc);
     237
     238        /* Apply config */
     239        if (config) {
     240                trace_set_configuration(trace, config);
     241        }
     242
     243        if (config_file) {
     244                FILE * f = fopen(optarg, "r");
     245                if (f != NULL) {
     246                        trace_set_configuration_file(trace, f);
     247                        fclose(f);
     248                } else {
     249                        perror("Failed to open configuration file\n");
     250                        exit(-1);
     251                }
     252        }
     253
    238254        trace_set_combiner(trace, &combiner_ordered, (libtrace_generic_t){0});
    239255
     
    278294        int i;
    279295        struct sigaction sigact;
    280         ZERO_USER_CONFIG(uc);
     296        char *config = NULL;
     297        char *config_file = NULL;
     298
    281299        while(1) {
    282300                int option_index;
     
    309327                                break;
    310328                        case 'u':
    311                                   parse_user_config(&uc, optarg);
    312                                   break;
    313                         case 'U':;
    314                                 FILE * f = fopen(optarg, "r");
    315                                 if (f != NULL) {
    316                                         parse_user_config_file(&uc, f);
    317                                 } else {
    318                                         perror("Failed to open configuration file\n");
    319                                         usage(argv[0]);
    320                                 }
     329                                config = optarg;
     330                                break;
     331                        case 'U':
     332                                config_file = optarg;
    321333                                break;
    322334                        default:
     
    333345        sigaction(SIGINT, &sigact, NULL);
    334346        sigaction(SIGTERM, &sigact, NULL);
    335        
     347
    336348        for(i=optind;i<argc;++i) {
    337                 run_trace(argv[i]);
     349                run_trace(argv[i], config, config_file);
    338350        }
    339351        if (optind+1<argc) {
Note: See TracChangeset for help on using the changeset viewer.