Changeset bab946c


Ignore:
Timestamp:
01/15/19 16:47:20 (17 months ago)
Author:
Shane Alcock <salcock@…>
Branches:
develop
Children:
e9fe6ac
Parents:
edd0448
Message:

Fix clashes between global and local variable names in tools.

Location:
tools
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • tools/traceanon/traceanon.cc

    r8e11beb rbab946c  
    4646};
    4747
    48 bool enc_source = false;
    49 bool enc_dest   = false;
     48bool enc_source_opt = false;
     49bool enc_dest_opt   = false;
    5050enum enc_type_t enc_type = ENC_NONE;
    5151char *key = NULL;
     
    5454trace_option_compresstype_t compress_type = TRACE_OPTION_COMPRESSTYPE_NONE;
    5555
    56 struct libtrace_t *trace = NULL;
     56struct libtrace_t *inptrace = NULL;
    5757
    5858static void cleanup_signal(int signal)
     
    6060        (void)signal;
    6161        // trace_pstop isn't really signal safe because its got lots of locks in it
    62         trace_pstop(trace);
     62        trace_pstop(inptrace);
    6363}
    6464
     
    182182        ip6 = trace_get_ip6(packet);
    183183
    184         if (ipptr && (enc_source || enc_dest)) {
    185                 encrypt_ips(anon, ipptr,enc_source,enc_dest);
     184        if (ipptr && (enc_source_opt || enc_dest_opt)) {
     185                encrypt_ips(anon, ipptr,enc_source_opt,enc_dest_opt);
    186186                ipptr->ip_sum = 0;
    187         } else if (ip6 && (enc_source || enc_dest)) {
    188                 encrypt_ipv6(anon, ip6, enc_source, enc_dest);
     187        } else if (ip6 && (enc_source_opt || enc_dest_opt)) {
     188                encrypt_ipv6(anon, ip6, enc_source_opt, enc_dest_opt);
    189189        }
    190190
     
    197197
    198198        udp = trace_get_udp(packet);
    199         if (udp && (enc_source || enc_dest)) {
     199        if (udp && (enc_source_opt || enc_dest_opt)) {
    200200                udp->check = 0;
    201201        }
    202202
    203203        tcp = trace_get_tcp(packet);
    204         if (tcp && (enc_source || enc_dest)) {
     204        if (tcp && (enc_source_opt || enc_dest_opt)) {
    205205                tcp->check = 0;
    206206        }
    207207
    208208        icmp6 = trace_get_icmp6(packet);
    209         if (icmp6 && (enc_source || enc_dest)) {
     209        if (icmp6 && (enc_source_opt || enc_dest_opt)) {
    210210                icmp6->checksum = 0;
    211211        }
     
    357357                        case 'Z': compress_type_str=optarg; break;         
    358358                        case 'z': level = atoi(optarg); break;
    359                         case 's': enc_source=true; break;
    360                         case 'd': enc_dest  =true; break;
     359                        case 's': enc_source_opt=true; break;
     360                        case 'd': enc_dest_opt  =true; break;
    361361                        case 'c':
    362362                                  if (key!=NULL) {
     
    442442
    443443        /* open input uri */
    444         trace = trace_create(argv[optind]);
    445         if (trace_is_err(trace)) {
    446                 trace_perror(trace,"trace_create");
     444        inptrace = trace_create(argv[optind]);
     445        if (trace_is_err(inptrace)) {
     446                trace_perror(inptrace,"trace_create");
    447447                exitcode = 1;
    448448                goto exitanon;
     
    463463         * special case to have.
    464464         */
    465         trace_set_combiner(trace, &combiner_ordered, (libtrace_generic_t){0});
     465        trace_set_combiner(inptrace, &combiner_ordered, (libtrace_generic_t){0});
    466466
    467467        pktcbs = trace_create_callback_set();
     
    475475        trace_set_starting_cb(repcbs, init_output);
    476476
    477         trace_set_perpkt_threads(trace, maxthreads);
     477        trace_set_perpkt_threads(inptrace, maxthreads);
    478478
    479479        if (filterstring) {
     
    481481        }
    482482
    483         if (filter && trace_config(trace, TRACE_OPTION_FILTER, filter) == -1)
     483        if (filter && trace_config(inptrace, TRACE_OPTION_FILTER, filter) == -1)
    484484        {
    485                 trace_perror(trace, "Configuring input filter");
     485                trace_perror(inptrace, "Configuring input filter");
    486486                exitcode = 1;
    487487                goto exitanon;
    488488        }
    489489
    490         if (trace_pstart(trace, output, pktcbs, repcbs)==-1) {
    491                 trace_perror(trace,"trace_start");
     490        if (trace_pstart(inptrace, output, pktcbs, repcbs)==-1) {
     491                trace_perror(inptrace,"trace_start");
    492492                exitcode = 1;
    493493                goto exitanon;
     
    502502
    503503        // Wait for the trace to finish
    504         trace_join(trace);
     504        trace_join(inptrace);
    505505
    506506exitanon:
     
    509509        if (repcbs)
    510510                trace_destroy_callback_set(repcbs);
    511         if (trace)
    512                 trace_destroy(trace);
     511        if (inptrace)
     512                trace_destroy(inptrace);
    513513        return exitcode;
    514514}
  • tools/tracertstats/tracertstats.c

    r1800ee3 rbab946c  
    8080struct output_data_t *output = NULL;
    8181
    82 uint64_t count;
    83 uint64_t bytes;
     82uint64_t totalcount;
     83uint64_t totalbytes;
    8484
    8585struct libtrace_t *currenttrace;
     
    178178        }
    179179        while ((glob_last_ts >> 32) < (ts >> 32)) {
    180                 report_results(glob_last_ts >> 32, count, bytes, stats);
    181                 count = 0;
    182                 bytes = 0;
     180                report_results(glob_last_ts >> 32, totalcount, totalbytes,
     181                                stats);
     182                totalcount = 0;
     183                totalbytes = 0;
    183184                for (j = 0; j < filter_count; j++)
    184185                        filters[j].count = filters[j].bytes = 0;
    185186                glob_last_ts = ts;
    186187        }
    187         count += res->total.count;
     188        totalcount += res->total.count;
    188189        packets_seen += res->total.count;
    189         bytes += res->total.bytes;
     190        totalbytes += res->total.bytes;
    190191        for (j = 0; j < filter_count; j++) {
    191192                filters[j].count += res->filters[j].count;
     
    344345                stats = trace_get_statistics(trace, stats);
    345346        }
    346         report_results((glob_last_ts >> 32), count, bytes, stats);
     347        report_results((glob_last_ts >> 32), totalcount, totalbytes, stats);
    347348        if (trace_is_err(trace))
    348349                trace_perror(trace,"%s",uri);
  • tools/tracesplit/tracesplit.c

    r4c5bbfc rbab946c  
    5252uint64_t filescreated = 0;
    5353uint16_t snaplen = 0;
    54 int jump=0;
     54int jumpopt=0;
    5555int verbose=0;
    5656int compress_level=-1;
     
    324324
    325325        /* Support "jump"ping to the nth IP header. */
    326         if (jump) {
     326        if (jumpopt) {
    327327            /* Skip headers */
    328             struct libtrace_packet_t *newpacket = perform_jump(*packet, jump);
     328            struct libtrace_packet_t *newpacket = perform_jump(*packet, jumpopt);
    329329            if (newpacket) {
    330330                /* If an IP header was found on the nth layer down
     
    404404                        case 'i': interval=atoi(optarg);
    405405                                  break;
    406                         case 'j': jump=atoi(optarg);
     406                        case 'j': jumpopt=atoi(optarg);
    407407                                  break;
    408408                        case 'm': maxfiles=atoi(optarg);
  • tools/tracestats/tracestats.c

    r02d13cb rbab946c  
    5454#include <pthread.h>
    5555
    56 struct libtrace_t *trace = NULL;
     56struct libtrace_t *inptrace = NULL;
    5757
    5858static void cleanup_signal(int signal UNUSED)
    5959{
    60         if (trace)
    61                 trace_pstop(trace);
     60        if (inptrace)
     61                trace_pstop(inptrace);
    6262}
    6363
     
    196196        libtrace_callback_set_t *pktcbs, *rescbs;
    197197
    198         trace = trace_create(uri);
    199 
    200         if (trace_is_err(trace)) {
    201                 trace_perror(trace,"Failed to create trace");
     198        inptrace = trace_create(uri);
     199
     200        if (trace_is_err(inptrace)) {
     201                trace_perror(inptrace,"Failed to create trace");
    202202                return;
    203203        }
     
    214214
    215215        if (threadcount != 0)
    216                 trace_set_perpkt_threads(trace, threadcount);
     216                trace_set_perpkt_threads(inptrace, threadcount);
    217217
    218218        /* Start the trace as a parallel trace */
    219         if (trace_pstart(trace, NULL, pktcbs, rescbs)==-1) {
    220                 trace_perror(trace,"Failed to start trace");
     219        if (trace_pstart(inptrace, NULL, pktcbs, rescbs)==-1) {
     220                trace_perror(inptrace,"Failed to start trace");
    221221                return;
    222222        }
    223223
    224224        /* Wait for all threads to stop */
    225         trace_join(trace);
    226 
    227         if (trace_is_err(trace))
    228                 trace_perror(trace,"%s",uri);
    229 
    230         trace_destroy(trace);
     225        trace_join(inptrace);
     226
     227        if (trace_is_err(inptrace))
     228                trace_perror(inptrace,"%s",uri);
     229
     230        trace_destroy(inptrace);
    231231        trace_destroy_callback_set(pktcbs);
    232232        trace_destroy_callback_set(rescbs);
Note: See TracChangeset for help on using the changeset viewer.