Ignore:
Timestamp:
03/05/15 15:44:30 (6 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:
ab3fa18
Parents:
b023181
Message:

Update the reporter method to match with the per_pkt method.

We now treat a result as a type of message.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • test/test-format-parallel-reporter.c

    r98dc1ba r62b3c4e  
    9494int globalcount = 0;
    9595
    96 static void reporter(libtrace_t *libtrace, libtrace_result_t *res, libtrace_message_t *mesg) {
     96static void reporter(libtrace_t *libtrace UNUSED, int mesg,
     97                     libtrace_generic_t data,
     98                     libtrace_thread_t *sender UNUSED) {
    9799        static uint64_t last = -1;
    98100        static int pktcount = 0;
    99         if (res) {
    100                 libtrace_packet_t *packet = libtrace_result_get_value(res).pkt;
    101                 assert(libtrace_result_get_key(res) == trace_packet_get_order(packet));
     101        libtrace_packet_t *packet;
     102        switch (mesg) {
     103        case MESSAGE_RESULT:
     104                packet = libtrace_result_get_value(data.res).pkt;
     105                assert(libtrace_result_get_key(data.res) == trace_packet_get_order(packet));
    102106                if(last == (uint64_t)-1) {
    103                         last = libtrace_result_get_key(res);
     107                        last = libtrace_result_get_key(data.res);
    104108                } else {
    105                 assert (last < libtrace_result_get_key(res));
    106                 last = libtrace_result_get_key(res);
     109                assert (last < libtrace_result_get_key(data.res));
     110                last = libtrace_result_get_key(data.res);
    107111                }
    108112                pktcount++;
    109113                trace_free_result_packet(libtrace, packet);
    110         } else {
    111                 // Mesg
    112                 switch (mesg->code) {
    113                 case MESSAGE_STOPPING:
    114                         globalcount = pktcount;
    115                 default:
    116                         break;
    117                 }
     114                break;
     115        case MESSAGE_STOPPING:
     116                globalcount = pktcount;
     117                break;
    118118        }
    119119}
Note: See TracChangeset for help on using the changeset viewer.