Changeset 6a6e6a8 for test


Ignore:
Timestamp:
03/12/15 17:14:42 (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:
a978dec
Parents:
b54e2da
Message:

More documentation, including some renaming and modifications to behaviour

  • Removes accessor functions for libtrace_result_t, instead directly access the structure
  • Documentation for most functions
  • Split tick into interval and count messages for the two modes of operation
  • Normalise interval and packet order to use the erf timestamp format
  • Rename trace_send_message_to_XXX to trace trace_message_XXX
Location:
test
Files:
6 edited

Legend:

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

    r6a082f8 r6a6e6a8  
    107107        switch (mesg) {
    108108        case MESSAGE_RESULT:
    109                 assert(libtrace_result_get_key(data.res) == 0);
    110                 printf("%d,", libtrace_result_get_value(data.res).sint);
     109                assert(data.res->key == 0);
     110                printf("%d,", data.res->value.sint);
    111111                totalthreads++;
    112                 totalpkts += libtrace_result_get_value(data.res).sint;
    113                 assert(libtrace_result_get_value(data.res).sint == 25 ||
    114                        libtrace_result_get_value(data.res).sint == expected - 25);
     112                totalpkts += data.res->value.sint;
     113                assert(data.res->value.sint == 25 ||
     114                       data.res->value.sint == expected - 25);
    115115                break;
    116116        case MESSAGE_STARTING:
     
    166166                // All threads publish to verify the thread count
    167167                assert(tls->count == 25 || tls->count == 75);
    168                 trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
     168                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_USER);
    169169                trace_post_reporter(trace);
    170170                free(tls);
    171171                break;
    172         case MESSAGE_TICK:
     172        case MESSAGE_TICK_INTERVAL:
     173        case MESSAGE_TICK_COUNT:
    173174                assert(tls->seen_start_message );
    174175                fprintf(stderr, "Not expecting a tick packet\n");
  • test/test-format-parallel-reporter.c

    r6a082f8 r6a6e6a8  
    102102        switch (mesg) {
    103103        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));
     104                packet = data.res->value.pkt;
     105                assert(data.res->key == trace_packet_get_order(packet));
    106106                if(last == (uint64_t)-1) {
    107                         last = libtrace_result_get_key(data.res);
     107                        last = data.res->key;
    108108                } else {
    109                         assert (last < libtrace_result_get_key(data.res));
    110                         last = libtrace_result_get_key(data.res);
     109                        assert (last < data.res->key);
     110                        last = data.res->key;
    111111                }
    112112                pktcount++;
    113                 trace_free_result_packet(libtrace, packet);
     113                trace_free_packet(libtrace, packet);
    114114                break;
    115115        case MESSAGE_STOPPING:
  • test/test-format-parallel-singlethreaded-hasher.c

    r6a082f8 r6a6e6a8  
    108108        switch (mesg) {
    109109        case MESSAGE_RESULT:
    110                 assert(libtrace_result_get_key(data.res) == 0);
    111                 printf("%d,", libtrace_result_get_value(data.res).sint);
     110                assert(data.res->key == 0);
     111                printf("%d,", data.res->value.sint);
    112112                totalthreads++;
    113                 totalpkts += libtrace_result_get_value(data.res).sint;
     113                totalpkts += data.res->value.sint;
    114114                break;
    115115        case MESSAGE_STARTING:
     
    164164
    165165                // All threads publish to verify the thread count
    166                 trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
     166                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_USER);
    167167                trace_post_reporter(trace);
    168168                free(tls);
    169169                break;
    170         case MESSAGE_TICK:
     170        case MESSAGE_TICK_INTERVAL:
     171        case MESSAGE_TICK_COUNT:
    171172                assert(tls->seen_start_message );
    172173                fprintf(stderr, "Not expecting a tick packet\n");
  • test/test-format-parallel-singlethreaded.c

    r6a082f8 r6a6e6a8  
    107107        switch (mesg) {
    108108        case MESSAGE_RESULT:
    109                 assert(libtrace_result_get_key(data.res) == 0);
    110                 printf("%d,", libtrace_result_get_value(data.res).sint);
     109                assert(data.res->key == 0);
     110                printf("%d,", data.res->value.sint);
    111111                totalthreads++;
    112                 totalpkts += libtrace_result_get_value(data.res).sint;
     112                totalpkts += data.res->value.sint;
    113113                break;
    114114        case MESSAGE_STARTING:
     
    163163
    164164                // All threads publish to verify the thread count
    165                 trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
     165                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_USER);
    166166                trace_post_reporter(trace);
    167167                free(tls);
    168168                break;
    169         case MESSAGE_TICK:
     169        case MESSAGE_TICK_INTERVAL:
     170        case MESSAGE_TICK_COUNT:
    170171                assert(tls->seen_start_message );
    171172                fprintf(stderr, "Not expecting a tick packet\n");
  • test/test-format-parallel-stressthreads.c

    r6a082f8 r6a6e6a8  
    107107        switch (mesg) {
    108108        case MESSAGE_RESULT:
    109                 assert(libtrace_result_get_key(data.res) == 0);
    110                 printf("%d,", libtrace_result_get_value(data.res).sint);
     109                assert(data.res->key == 0);
     110                printf("%d,", data.res->value.sint);
    111111                totalthreads++;
    112                 totalpkts += libtrace_result_get_value(data.res).sint;
     112                totalpkts += data.res->value.sint;
    113113                break;
    114114        case MESSAGE_STARTING:
     
    163163
    164164                // All threads publish to verify the thread count
    165                 trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
     165                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_USER);
    166166                trace_post_reporter(trace);
    167167                free(tls);
    168168                break;
    169         case MESSAGE_TICK:
     169        case MESSAGE_TICK_INTERVAL:
     170        case MESSAGE_TICK_COUNT:
    170171                assert(tls->seen_start_message );
    171172                fprintf(stderr, "Not expecting a tick packet\n");
  • test/test-format-parallel.c

    r6a082f8 r6a6e6a8  
    106106        switch (mesg) {
    107107        case MESSAGE_RESULT:
    108                 assert(libtrace_result_get_key(data.res) == 0);
    109                 printf("%d,", libtrace_result_get_value(data.res).sint);
     108                assert(data.res->key == 0);
     109                printf("%d,", data.res->value.sint);
    110110                totalthreads++;
    111                 totalpkts += libtrace_result_get_value(data.res).sint;
     111                totalpkts += data.res->value.sint;
    112112                break;
    113113        case MESSAGE_STARTING:
     
    173173
    174174                // All threads publish to verify the thread count
    175                 trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint = count}, RESULT_NORMAL);
     175                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint = count}, RESULT_USER);
    176176                trace_post_reporter(trace);
    177177                break;
    178         case MESSAGE_TICK:
     178        case MESSAGE_TICK_INTERVAL:
     179        case MESSAGE_TICK_COUNT:
    179180                assert(seen_start_message);
    180181                fprintf(stderr, "Not expecting a tick packet\n");
Note: See TracChangeset for help on using the changeset viewer.