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-hasher.c

    r0ec8a7c r98dc1ba  
    126126
    127127static int x;
    128 static void* per_packet(libtrace_t *trace, libtrace_packet_t *pkt,
    129                                                 libtrace_message_t *mesg,
    130                                                 libtrace_thread_t *t) {
     128static void* per_packet(libtrace_t *trace, libtrace_thread_t *t,
     129                        int mesg, libtrace_generic_t data,
     130                        libtrace_thread_t *sender UNUSED) {
    131131        struct TLS *tls;
    132132        void* ret;
    133133        tls = trace_get_tls(t);
    134 
    135         if (pkt) {
    136                 int a,*b,c=0;
     134        int a,*b,c=0;
     135
     136        switch (mesg) {
     137        case MESSAGE_PACKET:
    137138                assert(tls != NULL);
    138139                assert(!(tls->seen_stop_message));
     
    148149                }
    149150                x = c;
    150         }
    151         else switch (mesg->code) {
    152                 case MESSAGE_STARTING:
    153                         assert(tls == NULL);
    154                         tls = calloc(sizeof(struct TLS), 1);
    155                         ret = trace_set_tls(t, tls);
    156                         assert(ret == NULL);
    157                         tls->seen_start_message = true;
    158                         break;
    159                 case MESSAGE_STOPPING:
    160                         assert(tls->seen_start_message);
    161                         assert(tls != NULL);
    162                         tls->seen_stop_message = true;
    163                         trace_set_tls(t, NULL);
    164 
    165                         // All threads publish to verify the thread count
    166                         assert(tls->count == 25 || tls->count == 75);
    167                         trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
    168                         trace_post_reporter(trace);
    169                         free(tls);
    170                         break;
    171                 case MESSAGE_TICK:
    172                         assert(tls->seen_start_message );
    173                         fprintf(stderr, "Not expecting a tick packet\n");
    174                         kill(getpid(), SIGTERM);
    175                         break;
    176                 case MESSAGE_PAUSING:
    177                         assert(tls->seen_start_message);
    178                         tls->seen_pausing_message = true;
    179                         break;
    180                 case MESSAGE_RESUMING:
    181                         assert(tls->seen_pausing_message  || tls->seen_start_message);
    182                         tls->seen_resumed_message = true;
    183                         break;
    184         }
    185         return pkt;
     151                return data.pkt;
     152        case MESSAGE_STARTING:
     153                assert(tls == NULL);
     154                tls = calloc(sizeof(struct TLS), 1);
     155                ret = trace_set_tls(t, tls);
     156                assert(ret == NULL);
     157                tls->seen_start_message = true;
     158                break;
     159        case MESSAGE_STOPPING:
     160                assert(tls->seen_start_message);
     161                assert(tls != NULL);
     162                tls->seen_stop_message = true;
     163                trace_set_tls(t, NULL);
     164
     165                // All threads publish to verify the thread count
     166                assert(tls->count == 25 || tls->count == 75);
     167                trace_publish_result(trace, t, (uint64_t) 0, (libtrace_generic_t){.sint=tls->count}, RESULT_NORMAL);
     168                trace_post_reporter(trace);
     169                free(tls);
     170                break;
     171        case MESSAGE_TICK:
     172                assert(tls->seen_start_message );
     173                fprintf(stderr, "Not expecting a tick packet\n");
     174                kill(getpid(), SIGTERM);
     175                break;
     176        case MESSAGE_PAUSING:
     177                assert(tls->seen_start_message);
     178                tls->seen_pausing_message = true;
     179                break;
     180        case MESSAGE_RESUMING:
     181                assert(tls->seen_pausing_message  || tls->seen_start_message);
     182                tls->seen_resumed_message = true;
     183                break;
     184        }
     185        return NULL;
    186186}
    187187
     
    192192 * might change and still be valid even if this test fails!!.
    193193 */
    194 uint64_t hash25_75(const libtrace_packet_t* packet, void *data) {
     194uint64_t hash25_75(const libtrace_packet_t* packet UNUSED, void *data) {
    195195        int *count = (int *) data;
    196196        *count += 1;
Note: See TracChangeset for help on using the changeset viewer.