Changeset a31e166


Ignore:
Timestamp:
09/15/15 15:08:34 (5 years ago)
Author:
Shane Alcock <salcock@…>
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:
ccb89e4
Parents:
c968cfc
Message:

Rename libtrace_get_perpkt_count to trace_get_perpkt_threads

This is to be consistent with trace_set_perpkt_threads.

Remove 'packet' parameter from the first_packet callback.
trace_get_first_packet should be used to get the first packet instead.

Location:
lib
Files:
5 edited

Legend:

Unmodified
Added
Removed
  • lib/combiner_ordered.c

    rf625817 ra31e166  
    99static int init_combiner(libtrace_t *t, libtrace_combine_t *c) {
    1010        int i = 0;
    11         assert(libtrace_get_perpkt_count(t) > 0);
     11        assert(trace_get_perpkt_threads(t) > 0);
    1212        libtrace_queue_t *queues;
    13         c->queues = calloc(sizeof(libtrace_queue_t), libtrace_get_perpkt_count(t));
     13        c->queues = calloc(sizeof(libtrace_queue_t), trace_get_perpkt_threads(t));
    1414        queues = c->queues;
    15         for (i = 0; i < libtrace_get_perpkt_count(t); ++i) {
     15        for (i = 0; i < trace_get_perpkt_threads(t); ++i) {
    1616                libtrace_deque_init(&queues[i], sizeof(libtrace_result_t));
    1717        }
     
    116116        libtrace_queue_t *queues = c->queues;
    117117        bool allactive = true;
    118         bool live[libtrace_get_perpkt_count(trace)]; // Set if a trace is alive
    119         uint64_t key[libtrace_get_perpkt_count(trace)]; // Cached keys
     118        bool live[trace_get_perpkt_threads(trace)]; // Set if a trace is alive
     119        uint64_t key[trace_get_perpkt_threads(trace)]; // Cached keys
    120120        uint64_t min_key = UINT64_MAX;
    121121        uint64_t prev_min = 0;
     
    124124
    125125        /* Loop through check all are alive (have data) and find the smallest */
    126         for (i = 0; i < libtrace_get_perpkt_count(trace); ++i) {
     126        for (i = 0; i < trace_get_perpkt_threads(trace); ++i) {
    127127                libtrace_queue_t *v = &queues[i];
    128128                if (libtrace_deque_get_size(v) != 0) {
     
    172172                                min_key = key[min_queue]; // Update our minimum
    173173                                // Check all find the smallest again - all are alive
    174                                 for (i = 0; i < libtrace_get_perpkt_count(trace); ++i) {
     174                                for (i = 0; i < trace_get_perpkt_threads(trace); ++i) {
    175175                                        if (live[i] && min_key >= key[i]) {
    176176                                                min_key = key[i];
     
    186186                        min_key = UINT64_MAX; // Update our minimum
    187187                        // Check all find the smallest again - all are alive
    188                         for (i = 0; i < libtrace_get_perpkt_count(trace); ++i) {
     188                        for (i = 0; i < trace_get_perpkt_threads(trace); ++i) {
    189189                                if (live[i] && min_key >= key[i]) {
    190190                                        min_key = key[i];
     
    207207                read_internal(trace, c, true);
    208208                empty = 0;
    209                 for (i = 0; i < libtrace_get_perpkt_count(trace); ++i) {
     209                for (i = 0; i < trace_get_perpkt_threads(trace); ++i) {
    210210                        if (libtrace_deque_get_size(&q[i]) == 0)
    211211                                empty ++;
    212212                }
    213213        }
    214         while (empty < libtrace_get_perpkt_count(trace));
     214        while (empty < trace_get_perpkt_threads(trace));
    215215}
    216216
     
    219219        libtrace_queue_t *queues = c->queues;
    220220
    221         for (i = 0; i < libtrace_get_perpkt_count(trace); i++) {
     221        for (i = 0; i < trace_get_perpkt_threads(trace); i++) {
    222222                assert(libtrace_deque_get_size(&queues[i]) == 0);
    223223        }
     
    230230        libtrace_queue_t *queues = c->queues;
    231231        int i;
    232         for (i = 0; i < libtrace_get_perpkt_count(trace); i++) {
     232        for (i = 0; i < trace_get_perpkt_threads(trace); i++) {
    233233                libtrace_deque_apply_function(&queues[i], (deque_data_fn) libtrace_make_result_safe);
    234234        }
  • lib/combiner_sorted.c

    rf625817 ra31e166  
    77static int init_combiner(libtrace_t *t, libtrace_combine_t *c) {
    88        int i = 0;
    9         assert(libtrace_get_perpkt_count(t) > 0);
     9        assert(trace_get_perpkt_threads(t) > 0);
    1010        libtrace_vector_t *queues;
    11         c->queues = calloc(sizeof(libtrace_vector_t), libtrace_get_perpkt_count(t));
     11        c->queues = calloc(sizeof(libtrace_vector_t), trace_get_perpkt_threads(t));
    1212        queues = c->queues;
    13         for (i = 0; i < libtrace_get_perpkt_count(t); ++i) {
     13        for (i = 0; i < trace_get_perpkt_threads(t); ++i) {
    1414                libtrace_vector_init(&queues[i], sizeof(libtrace_result_t));
    1515        }
     
    4141        libtrace_vector_t *queues = c->queues;
    4242        int i;
    43         for (i = 0; i < libtrace_get_perpkt_count(trace); ++i) {
     43        for (i = 0; i < trace_get_perpkt_threads(trace); ++i) {
    4444                libtrace_vector_apply_function(&queues[i], (vector_data_fn) libtrace_make_result_safe);
    4545        }
     
    5151        size_t a;
    5252        // Combine all results into queue 1
    53         for (i = 1; i < libtrace_get_perpkt_count(trace); ++i)
     53        for (i = 1; i < trace_get_perpkt_threads(trace); ++i)
    5454        {
    5555                libtrace_vector_append(&queues[0],&queues[i]);
     
    7777        libtrace_vector_t *queues = c->queues;
    7878
    79         for (i = 0; i < libtrace_get_perpkt_count(trace); i++) {
     79        for (i = 0; i < trace_get_perpkt_threads(trace); i++) {
    8080                assert(libtrace_vector_get_size(&queues[i]) == 0);
    8181                libtrace_vector_destroy(&queues[i]);
  • lib/combiner_unordered.c

    rf625817 ra31e166  
    77static int init_combiner(libtrace_t *t, libtrace_combine_t *c) {
    88        int i = 0;
    9         assert(libtrace_get_perpkt_count(t) > 0);
     9        assert(trace_get_perpkt_threads(t) > 0);
    1010        libtrace_queue_t *queues;
    11         c->queues = calloc(sizeof(libtrace_queue_t), libtrace_get_perpkt_count(t));
     11        c->queues = calloc(sizeof(libtrace_queue_t), trace_get_perpkt_threads(t));
    1212        queues = c->queues;
    13         for (i = 0; i < libtrace_get_perpkt_count(t); ++i) {
     13        for (i = 0; i < trace_get_perpkt_threads(t); ++i) {
    1414                libtrace_deque_init(&queues[i], sizeof(libtrace_result_t));
    1515        }
     
    3131
    3232        /* Loop through and read all that are here */
    33         for (i = 0; i < libtrace_get_perpkt_count(trace); ++i) {
     33        for (i = 0; i < trace_get_perpkt_threads(trace); ++i) {
    3434                libtrace_queue_t *v = &queues[i];
    3535                while (libtrace_deque_get_size(v) != 0) {
     
    5959        libtrace_queue_t *queues = c->queues;
    6060
    61         for (i = 0; i < libtrace_get_perpkt_count(trace); i++) {
     61        for (i = 0; i < trace_get_perpkt_threads(trace); i++) {
    6262                assert(libtrace_deque_get_size(&queues[i]) == 0);
    6363        }
  • lib/libtrace_parallel.h

    rf625817 ra31e166  
    509509                                   void *global,
    510510                                   void *tls,
    511                                    libtrace_packet_t *first_packet,
    512511                                   libtrace_thread_t *sender);
    513512
     
    12811280DLLEXPORT int trace_set_configuration_file(libtrace_t *trace, FILE *file);
    12821281
    1283 DLLEXPORT int libtrace_get_perpkt_count(libtrace_t* t); // TODO MATCH WITH THE SET_PERPKT
     1282DLLEXPORT int trace_get_perpkt_threads(libtrace_t* t);
    12841283
    12851284/**
  • lib/trace_parallel.c

    r2b4444f ra31e166  
    205205                                (*cbs->message_first_packet)(trace, thread,
    206206                                trace->global_blob, thread->user_data,
    207                                 data.pkt, sender);
     207                                sender);
    208208                return;
    209209        case MESSAGE_TICK_COUNT:
     
    287287 * @return
    288288 */
    289 DLLEXPORT int libtrace_get_perpkt_count(libtrace_t * t) {
     289DLLEXPORT int trace_get_perpkt_threads(libtrace_t * t) {
    290290        return t->perpkt_thread_count;
    291291}
Note: See TracChangeset for help on using the changeset viewer.