Ignore:
Timestamp:
02/27/15 18:05:18 (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:
e7d3bdc
Parents:
0ec8a7c
Message:

Update tests to use the updated interface.

Also fixes some compile time warnings

File:
1 edited

Legend:

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

    r0ec8a7c r98dc1ba  
    124124
    125125static int x;
    126 static void* per_packet(libtrace_t *trace, libtrace_packet_t *pkt,
    127                                                 libtrace_message_t *mesg,
    128                                                 libtrace_thread_t *t) {
     126static void* per_packet(libtrace_t *trace, libtrace_thread_t *t,
     127                        int mesg, libtrace_generic_t data,
     128                        libtrace_thread_t *sender UNUSED) {
    129129        struct TLS *tls;
    130130        void* ret;
     131        int a,*b,c=0;
    131132        tls = trace_get_tls(t);
    132133
    133         if (pkt) {
    134                 int a,*b,c=0;
     134        switch (mesg) {
     135        case MESSAGE_PACKET:
    135136                assert(tls != NULL);
    136137                assert(!(tls->seen_stop_message));
     
    146147                }
    147148                x = c;
    148         }
    149         else switch (mesg->code) {
    150                 case MESSAGE_STARTING:
    151                         assert(tls == NULL);
    152                         tls = calloc(sizeof(struct TLS), 1);
    153                         ret = trace_set_tls(t, tls);
    154                         assert(ret == NULL);
    155                         tls->seen_start_message = true;
    156                         break;
    157                 case MESSAGE_STOPPING:
    158                         assert(tls->seen_start_message);
    159                         assert(tls != NULL);
    160                         tls->seen_stop_message = true;
    161                         trace_set_tls(t, NULL);
    162 
    163                         // All threads publish to verify the thread count
    164                         trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
    165                         trace_post_reporter(trace);
    166                         free(tls);
    167                         break;
    168                 case MESSAGE_TICK:
    169                         assert(tls->seen_start_message );
    170                         fprintf(stderr, "Not expecting a tick packet\n");
    171                         kill(getpid(), SIGTERM);
    172                         break;
    173                 case MESSAGE_PAUSING:
    174                         assert(tls->seen_start_message);
    175                         tls->seen_pausing_message = true;
    176                         break;
    177                 case MESSAGE_RESUMING:
    178                         assert(tls->seen_pausing_message || tls->seen_start_message);
    179                         tls->seen_resuming_message = true;
    180                         break;
    181         }
    182         return pkt;
     149                return data.pkt;
     150        case MESSAGE_STARTING:
     151                assert(tls == NULL);
     152                tls = calloc(sizeof(struct TLS), 1);
     153                ret = trace_set_tls(t, tls);
     154                assert(ret == NULL);
     155                tls->seen_start_message = true;
     156                break;
     157        case MESSAGE_STOPPING:
     158                assert(tls->seen_start_message);
     159                assert(tls != NULL);
     160                tls->seen_stop_message = true;
     161                trace_set_tls(t, NULL);
     162
     163                // All threads publish to verify the thread count
     164                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
     165                trace_post_reporter(trace);
     166                free(tls);
     167                break;
     168        case MESSAGE_TICK:
     169                assert(tls->seen_start_message );
     170                fprintf(stderr, "Not expecting a tick packet\n");
     171                kill(getpid(), SIGTERM);
     172                break;
     173        case MESSAGE_PAUSING:
     174                assert(tls->seen_start_message);
     175                tls->seen_pausing_message = true;
     176                break;
     177        case MESSAGE_RESUMING:
     178                assert(tls->seen_pausing_message || tls->seen_start_message);
     179                tls->seen_resuming_message = true;
     180                break;
     181        }
     182        return NULL;
    183183}
    184184
Note: See TracChangeset for help on using the changeset viewer.