Changeset 4007dbb for lib


Ignore:
Timestamp:
08/21/15 11:22: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:
eea427f
Parents:
76291d1
Message:

Updates the new interface to be more complete

This should work around any issues with systems without thread support.
This still remains compatible with existing code.
Examples/tools/tests still need to be updated to make use of the new interface.
And tests also need to be updated.
Adds debug memory stats as an option to configure.

Location:
lib
Files:
5 edited

Legend:

Unmodified
Added
Removed

  • lib/data-struct/object_cache.c

    r14c6c08 r4007dbb  
    2727};
    2828
     29#ifdef ENABLE_MEM_STATS
    2930extern __thread struct mem_stats mem_hits;
     31#endif
    3032
    3133struct local_caches {
    … …  
    123125/* Get TLS for the list of local_caches */
    124126static inline struct local_caches *get_local_caches() {
     127#if HAVE_TLS
    125128        static __thread struct local_caches *lcs = NULL;
    126129        if (lcs) {
    127130                return lcs;
    128         } else {
     131        }
     132#else
     133        struct local_caches *lcs;
     134        pthread_once(&memory_destructor_once, &once_memory_cache_key_init);
     135        if ((lcs=pthread_getspecific(memory_destructor_key)) != 0) {
     136                return lcs;
     137        }
     138#endif
     139        else {
    129140                /* This thread has not been used with a memory pool before */
    130141                /* Allocate our TLS */
    … …  
    280291                memcpy(values, &lc->cache[lc->used - nb_buffers], sizeof(void *) * nb_buffers);
    281292                lc->used -= nb_buffers;
     293#ifdef ENABLE_MEM_STATS
    282294                mem_hits.read.cache_hit += nb_buffers;
    283295                mem_hits.readbulk.cache_hit += 1;
     296#endif
    284297                return nb_buffers;
    285298        }
    … …  
    287300        else if (nb_buffers > lc->total) {
    288301                i = libtrace_ringbuffer_sread_bulk(rb, values, nb_buffers, min_nb_buffers);
     302#ifdef ENABLE_MEM_STATS
    289303                if (i)
    290304                        mem_hits.readbulk.ring_hit += 1;
    … …  
    292306                        mem_hits.readbulk.miss += 1;
    293307                mem_hits.read.ring_hit += i;
     308#endif
    294309        } else { // Not enough cached
    295310                // Empty the cache and re-fill it and then see what we're left with
    296311                i = lc->used;
    297312                memcpy(values, lc->cache, sizeof(void *) * lc->used);
     313#ifdef ENABLE_MEM_STATS
    298314                mem_hits.read.cache_hit += i;
     315#endif
    299316
    300317                // Make sure we still meet the minimum requirement
    … …  
    303320                else
    304321                        lc->used = libtrace_ringbuffer_sread_bulk(rb, lc->cache, lc->total, 0);
    305 
     322#ifdef ENABLE_MEM_STATS
    306323                if (lc->used == lc->total)
    307324                        mem_hits.readbulk.ring_hit += 1;
    … …  
    309326                        mem_hits.readbulk.miss += 1;
    310327                mem_hits.read.ring_hit += lc->used;
     328#endif
    311329        }
    312330
    … …  
    319337                i += remaining;
    320338        }
     339#ifdef ENABLE_MEM_STATS
    321340        mem_hits.read.miss += nb_buffers - i;
     341#endif
    322342        assert(i >= min_nb_buffers);
    323343        return i;
    … …  
    379399                memcpy(&lc->cache[lc->used], values, sizeof(void *) * nb_buffers);
    380400                lc->used += nb_buffers;
     401#ifdef ENABLE_MEM_STATS
    381402                mem_hits.write.cache_hit += nb_buffers;
    382403                mem_hits.writebulk.cache_hit += 1;
     404#endif
    383405                return nb_buffers;
    384406        }
    … …  
    386408        else if (nb_buffers > lc->total) {
    387409                i = libtrace_ringbuffer_swrite_bulk(rb, values, nb_buffers, min_nb_buffers);
     410#ifdef ENABLE_MEM_STATS
    388411                if (i)
    389412                        mem_hits.writebulk.ring_hit += 1;
    … …  
    391414                        mem_hits.writebulk.miss += 1;
    392415                mem_hits.write.ring_hit += i;
     416#endif
    393417        } else { // Not enough cache space but there might later
    394418                // Fill the cache and empty it and then see what we're left with
    395419                i = (lc->total - lc->used);
    396420                memcpy(&lc->cache[lc->used], values, sizeof(void *) * i);
     421#ifdef ENABLE_MEM_STATS
    397422                mem_hits.write.cache_hit += i;
     423#endif
    398424
    399425                // Make sure we still meet the minimum requirement
    … …  
    407433                        memmove(lc->cache, &lc->cache[lc->total - lc->used], sizeof(void *) * lc->used);
    408434
     435#ifdef ENABLE_MEM_STATS
    409436                if (lc->used)
    410437                        mem_hits.writebulk.miss += 1;
    … …  
    412439                        mem_hits.writebulk.ring_hit += 1;
    413440                mem_hits.write.ring_hit += lc->total - lc->used;
     441#endif
    414442        }
    415443
    … …  
    422450                i += remaining;
    423451        }
     452#ifdef ENABLE_MEM_STATS
    424453        mem_hits.write.miss += nb_buffers - i;
     454#endif
    425455        return i;
    426456}

  • lib/libtrace_int.h

    r76291d1 r4007dbb  
    330330        /** The actual freelist */
    331331        libtrace_ocache_t packet_freelist;
    332         /** User defined per_pkt function called when a pkt is ready */
    333         fn_per_pkt per_pkt;
     332        /** User defined per_msg function called when a message is ready */
     333        fn_cb_msg per_msg;
    334334        /** User defined reporter function entry point XXX not hooked up */
    335335        fn_reporter reporter;
    … …  
    359359        libtrace_combine_t combiner;
    360360        struct {
    361                 fn_handler message_starting;
    362                 fn_handler message_stopping;
    363                 fn_handler message_resuming;
    364                 fn_handler message_pausing;
    365                 fn_handler message_packet;
     361                fn_cb_starting message_starting;
     362                fn_cb_dataless message_stopping;
     363                fn_cb_dataless message_resuming;
     364                fn_cb_dataless message_pausing;
     365                fn_cb_packet message_packet;
     366                fn_cb_first_packet message_first_packet;
     367                fn_cb_tick message_tick_count;
     368                fn_cb_tick message_tick_interval;
    366369        } callbacks;
    367370};

  • lib/libtrace_parallel.h

    r76291d1 r4007dbb  
    154154         * @param data unused, do not use this
    155155         * @param sender The sender will be set as the current thread
     156         * @return When using a function callback for starting, the returned
     157         * value is stored against the thread tls. Otherwise the return is ignored.
    156158         */
    157159        MESSAGE_STARTING,
    … …  
    211213         * sent once a new packet is encountered
    212214         *
    213          * @
     215         * @see trace_get_first_packet()
    214216         */
    215217        MESSAGE_FIRST_PACKET,
    … …  
    225227         * trace_post_reporter()
    226228         *
    227          * @see trace_get_first_packet()
    228229         */
    229230        MESSAGE_POST_REPORTER,
    … …  
    236237         * with an earlier time-stamp.
    237238         *
    238          * @param data data.uint64_t holds the system time-stamp in the
     239         * @param data data.uint64 holds the system time-stamp in the
    239240         * erf format
    240241         * @param sender should be ignored
    … …  
    248249         * threads will see it between the same packets.
    249250         *
    250          * @param data The number of packets seen so far across all threads
     251         * @param data data.uint64 holds the number of packets seen so far across all threads
    251252         * @param sender Set to the current per-packet thread
    252253         */
    … …  
    397398/**
    398399 * The definition for the main function that the user supplies to process
    399  * packets.
     400 * messages.
    400401 *
    401402 * @param trace The trace the packet is related to.
    … …  
    412413 * documentation for the message as to what value these will contain.
    413414 */
    414 typedef void* (*fn_per_pkt)(libtrace_t* trace,
    415                             libtrace_thread_t *thread,
    416                             int mesg_code,
    417                             libtrace_generic_t data,
    418                             libtrace_thread_t *sender);
     415typedef void* (*fn_cb_msg)(libtrace_t* trace,
     416                           libtrace_thread_t *thread,
     417                           int mesg_code,
     418                           libtrace_generic_t data,
     419                           libtrace_thread_t *sender);
    419420
    420421/**
    … …  
    452453 * @param libtrace The input trace to start
    453454 * @param global_blob Global data related to this trace accessible using trace_get_global()
    454  * @param per_pkt A user supplied function called when a packet is ready
     455 * @param per_msg A user supplied function called when a message is ready
    455456 * @param reporter A user supplied function called when a result is ready.
    456457 * Optional if NULL the reporter thread will not be started.
    … …  
    459460 * This can also be used to restart an existing parallel trace,
    460461 * that has previously been paused using trace_ppause().
    461  * In this case global_blob,per_pkt and reporter will only be updated
     462 * In this case global_blob,per_msg and reporter will only be updated
    462463 * if they are non-null. Otherwise their previous values will be maintained.
    463464 *
    464465 */
    465466DLLEXPORT int trace_pstart(libtrace_t *libtrace, void* global_blob,
    466                            fn_per_pkt per_pkt, fn_reporter reporter);
    467 
     467                           fn_cb_msg per_msg, fn_reporter reporter);
     468
     469/**
     470 *
     471 * @param libtrace The parallel trace
     472 * @param t The thread that is running
     473 * @param global The global storage
     474 * @return The returned value is stored against the threads tls.
     475 *         This is typically passed as tls argument to other messages.
     476 */
     477typedef void* (*fn_cb_starting)(libtrace_t *libtrace,
     478                                     libtrace_thread_t *t,
     479                                     void *global);
     480
     481/**
     482 * @param libtrace The parallel trace
     483 * @param t The thread that is running
     484 * @param global The global storage
     485 * @param tls The thread local storage
     486 */
     487typedef void (*fn_cb_dataless)(libtrace_t *libtrace,
     488                                    libtrace_thread_t *t,
     489                                    void *global,
     490                                    void *tls);
     491
     492/**
     493 * @param libtrace The parallel trace
     494 * @param t The thread that is running
     495 * @param global The global storage
     496 * @param tls The thread local storage
     497 */
     498typedef void (*fn_cb_first_packet)(libtrace_t *libtrace,
     499                                   libtrace_thread_t *t,
     500                                   void *global,
     501                                   void *tls,
     502                                   libtrace_packet_t *first_packet,
     503                                   libtrace_thread_t *sender);
     504
     505/**
     506 * @param libtrace The parallel trace
     507 * @param t The thread that is running
     508 * @param global The global storage
     509 * @param tls The thread local storage
     510 * @param uint64_t Either the timestamp or packet count depending on message type
     511 */
     512typedef void (*fn_cb_tick)(libtrace_t *libtrace,
     513                           libtrace_thread_t *t,
     514                           void *global,
     515                           void *tls,
     516                           uint64_t order);
    468517
    469518/**
    470519 * @param libtrace The parallel trace
    471520 * @param t The thread
    472  * @param data The data associated with the message
     521 * @param packet The packet associated with the message
    473522 * @param global The global storage
    474523 * @param tls The thread local storage
    475  */
    476 typedef void* (*fn_handler)(libtrace_t *libtrace,
    477                                libtrace_thread_t *t,
    478                                libtrace_generic_t data,
    479                                void *global,
    480                                void *tls);
     524 *
     525 * @return optionally a packet which is handed back to the library,
     526 *         typically this is the packet supplied. Otherwise NULL.
     527 */
     528typedef libtrace_packet_t* (*fn_cb_packet)(libtrace_t *libtrace,
     529                                           libtrace_thread_t *t,
     530                                           void *global,
     531                                           void *tls,
     532                                           libtrace_packet_t *packet);
    481533
    482534/** Registers a built-in message with a handler.
    … …  
    489541 * @return 0 if successful otherwise -1.
    490542 */
    491 DLLEXPORT int trace_set_handler(libtrace_t *libtrace, enum libtrace_messages message, fn_handler handler);
     543
     544DLLEXPORT int trace_cb_starting(libtrace_t *libtrace, fn_cb_starting handler);
     545DLLEXPORT int trace_cb_stopping(libtrace_t *libtrace, fn_cb_dataless handler);
     546DLLEXPORT int trace_cb_resuming(libtrace_t *libtrace, fn_cb_dataless handler);
     547DLLEXPORT int trace_cb_pausing(libtrace_t *libtrace, fn_cb_dataless handler);
     548DLLEXPORT int trace_cb_packet(libtrace_t *libtrace, fn_cb_packet handler);
     549DLLEXPORT int trace_cb_first_packet(libtrace_t *libtrace, fn_cb_first_packet handler);
     550DLLEXPORT int trace_cb_tick_count(libtrace_t *libtrace, fn_cb_tick handler);
     551DLLEXPORT int trace_cb_tick_interval(libtrace_t *libtrace, fn_cb_tick handler);
    492552
    493553/** Pauses a trace previously started with trace_pstart()

  • lib/trace.c

    r76291d1 r4007dbb  
    268268        libtrace->perpkt_queue_full = false;
    269269        libtrace->global_blob = NULL;
    270         libtrace->per_pkt = NULL;
     270        libtrace->per_msg = NULL;
    271271        libtrace->reporter = NULL;
    272272        libtrace->hasher = NULL;
    … …  
    390390        libtrace->perpkt_queue_full = false;
    391391        libtrace->global_blob = NULL;
    392         libtrace->per_pkt = NULL;
     392        libtrace->per_msg = NULL;
    393393        libtrace->reporter = NULL;
    394394        libtrace->hasher = NULL;

  • lib/trace_parallel.c

    r76291d1 r4007dbb  
    113113};
    114114
     115
     116#ifdef ENABLE_MEM_STATS
    115117// Grrr gcc wants this spelt out
    116118__thread struct mem_stats mem_hits = {{0},{0},{0},{0}};
    117119
     120
    118121static void print_memory_stats() {
    119 #if 0
    120122        uint64_t total;
    121123#if defined(HAVE_PTHREAD_SETNAME_NP) && defined(__linux__)
    … …  
    163165                                total, (double) mem_hits.writebulk.miss / (double) total * 100.0);
    164166        }
     167}
     168#else
     169static void print_memory_stats() {}
    165170#endif
     171
     172static const libtrace_generic_t gen_zero = {0};
     173
     174/* This should optimise away the switch to nothing in the explict cases */
     175static inline void send_message(libtrace_t *trace, libtrace_thread_t *thread, const enum libtrace_messages type,
     176                                libtrace_generic_t data, libtrace_thread_t *sender) {
     177        fn_cb_dataless fn = NULL;
     178        switch (type) {
     179        case MESSAGE_STARTING:
     180                if (trace->callbacks.message_starting)
     181                        thread->user_data = (*trace->callbacks.message_starting)(trace, thread, trace->global_blob);
     182                else if (trace->per_msg)
     183                        (*trace->per_msg)(trace, thread, type, data, sender);
     184                return;
     185        case MESSAGE_FIRST_PACKET:
     186                if (trace->callbacks.message_first_packet)
     187                        (*trace->callbacks.message_first_packet)(trace, thread, trace->global_blob, thread->user_data, data.pkt, sender);
     188                else if (trace->per_msg)
     189                        (*trace->per_msg)(trace, thread, type, data, sender);
     190                return;
     191        case MESSAGE_TICK_COUNT:
     192                if (trace->callbacks.message_tick_count)
     193                        (*trace->callbacks.message_tick_count)(trace, thread, trace->global_blob, thread->user_data, data.uint64);
     194                else if (trace->per_msg)
     195                        (*trace->per_msg)(trace, thread, type, data, sender);
     196                return;
     197        case MESSAGE_TICK_INTERVAL:
     198                if (trace->callbacks.message_tick_interval)
     199                        (*trace->callbacks.message_tick_interval)(trace, thread, trace->global_blob, thread->user_data,  data.uint64);
     200                else if (trace->per_msg)
     201                        (*trace->per_msg)(trace, thread, type, data, sender);
     202                return;
     203        case MESSAGE_STOPPING:
     204                fn = trace->callbacks.message_stopping;
     205                break;
     206        case MESSAGE_RESUMING:
     207                fn = trace->callbacks.message_resuming;
     208                break;
     209        case MESSAGE_PAUSING:
     210                fn = trace->callbacks.message_pausing;
     211                break;
     212
     213        /* These should be unused */
     214        case MESSAGE_DO_PAUSE:
     215        case MESSAGE_DO_STOP:
     216        case MESSAGE_POST_REPORTER:
     217        case MESSAGE_RESULT:
     218        case MESSAGE_PACKET:
     219                return;
     220        case MESSAGE_USER:
     221                break;
     222        }
     223        if (fn)
     224                (*fn)(trace, thread, trace->global_blob, thread->user_data);
     225        else if (trace->per_msg)
     226                (*trace->per_msg)(trace, thread, type, data, sender);
    166227}
    167228
    … …  
    378439                libtrace_generic_t data = {.pkt = *packet};
    379440                if (trace->callbacks.message_packet)
    380                         *packet = (*trace->callbacks.message_packet)(trace, t, data, trace->global_blob, t->user_data);
    381                 else
    382                         *packet = (*trace->per_pkt)(trace, t, MESSAGE_PACKET, data, t);
     441                        *packet = (*trace->callbacks.message_packet)(trace, t, trace->global_blob, t->user_data, *packet);
     442                else if (trace->per_msg)
     443                        *packet = (*trace->per_msg)(trace, t, MESSAGE_PACKET, data, t);
    383444                trace_fin_packet(*packet);
    384445        } else {
    385446                assert((*packet)->error == READ_TICK);
    386447                libtrace_generic_t data = {.uint64 = trace_packet_get_order(*packet)};
    387                 (*trace->per_pkt)(trace, t, MESSAGE_TICK_COUNT, data, t);
     448                send_message(trace, t, MESSAGE_TICK_COUNT, data, t);
    388449        }
    389450        return 0;
    … …  
    452513
    453514        /* Let the user thread know we are going to pause */
    454         (*trace->per_pkt)(trace, t, MESSAGE_PAUSING, (libtrace_generic_t){0}, t);
     515        send_message(trace, t, MESSAGE_PAUSING, gen_zero, t);
    455516
    456517        /* Send through any remaining packets (or messages) without delay */
    … …  
    493554        /* Now we do the actual pause, this returns when we resumed */
    494555        trace_thread_pause(trace, t);
    495         (*trace->per_pkt)(trace, t, MESSAGE_RESUMING, (libtrace_generic_t){0}, t);
     556        send_message(trace, t, MESSAGE_RESUMING, gen_zero, t);
    496557        return 1;
    497558}
    … …  
    538599
    539600        /* Let the per_packet function know we have started */
    540         if (trace->callbacks.message_starting)
    541                 (*trace->callbacks.message_starting)(trace, t, (libtrace_generic_t){0}, trace->global_blob, t->user_data);
    542         else
    543                 (*trace->per_pkt)(trace, t, MESSAGE_STARTING, (libtrace_generic_t){0}, t);
    544 
    545         if (trace->callbacks.message_resuming)
    546                 (*trace->callbacks.message_resuming)(trace, t, (libtrace_generic_t){0}, trace->global_blob, t->user_data);
    547         else
    548                 (*trace->per_pkt)(trace, t, MESSAGE_RESUMING, (libtrace_generic_t){0}, t);
     601        send_message(trace, t, MESSAGE_STARTING, gen_zero, t);
     602        send_message(trace, t, MESSAGE_RESUMING, gen_zero, t);
    549603
    550604        for (;;) {
    … …  
    566620                                        goto eof;
    567621                        }
    568                         (*trace->per_pkt)(trace, t, message.code, message.data, message.sender);
     622                        (*trace->per_msg)(trace, t, message.code, message.data, message.sender);
     623                        (*trace->per_msg)(trace, t, message.code, message.data, message.sender);
    569624                        /* Continue and the empty messages out before packets */
    570625                        continue;
    … …  
    629684
    630685        // Let the per_packet function know we have stopped
    631         if (trace->callbacks.message_pausing)
    632                 (*trace->callbacks.message_pausing)(trace, t, (libtrace_generic_t){0}, trace->global_blob, t->user_data);
    633         else
    634                 (*trace->per_pkt)(trace, t, MESSAGE_PAUSING, (libtrace_generic_t){0}, t);
    635         if (trace->callbacks.message_stopping)
    636                 (*trace->callbacks.message_stopping)(trace, t, (libtrace_generic_t){0}, trace->global_blob, t->user_data);
    637         else
    638                 (*trace->per_pkt)(trace, t, MESSAGE_STOPPING, (libtrace_generic_t){0}, t);
    639 
     686        send_message(trace, t, MESSAGE_PAUSING, gen_zero, t);
     687        send_message(trace, t, MESSAGE_STOPPING, gen_zero, t);
    640688
    641689        // Free any remaining packets
    … …  
    12631311 */
    12641312static int trace_prestart(libtrace_t * libtrace, void *global_blob,
    1265                           fn_per_pkt per_pkt, fn_reporter reporter) {
     1313                          fn_cb_msg per_msg, fn_reporter reporter) {
    12661314        int i, err = 0;
    12671315        if (libtrace->state != STATE_PAUSED) {
    … …  
    13061354
    13071355        /* Update functions if requested */
    1308         if (per_pkt)
    1309                 libtrace->per_pkt = per_pkt;
    1310         assert(libtrace->per_pkt);
     1356        if (per_msg)
     1357                libtrace->per_msg = per_msg;
     1358        assert(libtrace->per_msg);
    13111359        if (reporter)
    13121360                libtrace->reporter = reporter;
    … …  
    15301578
    15311579DLLEXPORT int trace_pstart(libtrace_t *libtrace, void* global_blob,
    1532                            fn_per_pkt per_pkt, fn_reporter reporter) {
     1580                           fn_cb_msg per_msg, fn_reporter reporter) {
    15331581        int i;
    15341582        int ret = -1;
    … …  
    15431591
    15441592        if (libtrace->state == STATE_PAUSED) {
    1545                 ret = trace_prestart(libtrace, global_blob, per_pkt, reporter);
     1593                ret = trace_prestart(libtrace, global_blob, per_msg, reporter);
    15461594                ASSERT_RET(pthread_mutex_unlock(&libtrace->libtrace_lock), == 0);
    15471595                return ret;
    … …  
    15581606        /* Store the user defined things against the trace */
    15591607        libtrace->global_blob = global_blob;
    1560         libtrace->per_pkt = per_pkt;
     1608        libtrace->per_msg = per_msg;
    15611609        libtrace->reporter = reporter;
    15621610        /* And zero other fields */
    … …  
    17371785}
    17381786
    1739 DLLEXPORT int trace_set_handler(libtrace_t *libtrace, enum libtrace_messages message, fn_handler handler) {
    1740         switch (message) {
    1741         case MESSAGE_STARTING:
    1742                 libtrace->callbacks.message_starting = handler;
    1743                 return 0;
    1744         case MESSAGE_STOPPING:
    1745                 libtrace->callbacks.message_stopping = handler;
    1746                 return 0;
    1747         case MESSAGE_RESUMING:
    1748                 libtrace->callbacks.message_resuming = handler;
    1749                 return 0;
    1750         case MESSAGE_PAUSING:
    1751                 libtrace->callbacks.message_pausing = handler;
    1752                 return 0;
    1753         case MESSAGE_PACKET:
    1754                 libtrace->callbacks.message_packet = handler;
    1755                 return 0;
    1756         default:
    1757                 return -1;
    1758         }
    1759         return -1;
    1760 }
    1761 
     1787DLLEXPORT int trace_cb_starting(libtrace_t *libtrace, fn_cb_starting handler) {
     1788        libtrace->callbacks.message_starting = handler;
     1789        return 0;
     1790}
     1791
     1792DLLEXPORT int trace_cb_pausing(libtrace_t *libtrace, fn_cb_dataless handler) {
     1793        libtrace->callbacks.message_pausing = handler;
     1794        return 0;
     1795}
     1796
     1797DLLEXPORT int trace_cb_resuming(libtrace_t *libtrace, fn_cb_dataless handler) {
     1798        libtrace->callbacks.message_resuming = handler;
     1799        return 0;
     1800}
     1801
     1802DLLEXPORT int trace_cb_stopping(libtrace_t *libtrace, fn_cb_dataless handler) {
     1803        libtrace->callbacks.message_stopping = handler;
     1804        return 0;
     1805}
     1806
     1807DLLEXPORT int trace_cb_packet(libtrace_t *libtrace, fn_cb_packet handler) {
     1808        libtrace->callbacks.message_packet = handler;
     1809        return 0;
     1810}
     1811
     1812DLLEXPORT int trace_cb_first_packet(libtrace_t *libtrace, fn_cb_first_packet handler) {
     1813        libtrace->callbacks.message_first_packet = handler;
     1814        return 0;
     1815}
     1816
     1817DLLEXPORT int trace_cb_tick_count(libtrace_t *libtrace, fn_cb_tick handler) {
     1818        libtrace->callbacks.message_tick_count = handler;
     1819        return 0;
     1820}
     1821
     1822DLLEXPORT int trace_cb_tick_interval(libtrace_t *libtrace, fn_cb_tick handler) {
     1823        libtrace->callbacks.message_tick_interval = handler;
     1824        return 0;
     1825}
    17621826
    17631827/*
    … …  
    17691833 *
    17701834 * Once done you should be able to modify the trace setup and call pstart again
    1771  * TODO handle changing thread numbers
     1835 * TODO add support to change the number of threads.
    17721836 */
    17731837DLLEXPORT int trace_ppause(libtrace_t *libtrace)
Note: See TracChangeset for help on using the changeset viewer.