Changeset 17a3dff for lib/libtrace.h.in


Ignore:
Timestamp:
04/26/14 23:23:17 (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:
5ce14a5
Parents:
60e8e86
Message:

Rename from google map/reduce framework names to something more meaningful.
Rename mapper to perpkt since this is what it actually is in libtrace.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/libtrace.h.in

    rabda273 r17a3dff  
    31303130DLLEXPORT void trace_destroy_result(libtrace_result_t ** result);
    31313131
    3132 // Ways to access Global and TLS  storage that we provide the user
     3132// Ways to access Global and TLS storage that we provide the user
    31333133DLLEXPORT void * trace_get_global(libtrace_t *trace);
    31343134DLLEXPORT void * trace_set_global(libtrace_t *trace, void * data);
     
    31513151DLLEXPORT void trace_packet_set_hash(libtrace_packet_t * packet, uint64_t hash);
    31523152
     3153DLLEXPORT int retrive_first_packet(libtrace_t *libtrace, libtrace_packet_t **packet, struct timeval **tv);
    31533154
    31543155typedef enum {
     
    31753176         * A unblockable warning message will be printed to stderr in this case.
    31763177         */
    3177         TRACE_OPTION_SET_MAPPER_BUFFER_SIZE,
     3178        TRACE_OPTION_SET_PERPKT_BUFFER_SIZE,
    31783179       
    31793180        /**
    3180          * Libtrace set mapper thread count
     3181         * Libtrace set perpkt thread count
    31813182         */
    3182         TRACE_OPTION_SET_MAPPER_THREAD_COUNT,
     3183        TRACE_OPTION_SET_PERPKT_THREAD_COUNT,
    31833184       
    31843185        /**
     
    32203221        MESSAGE_STOPPED,
    32213222        MESSAGE_FIRST_PACKET,
    3222         MESSAGE_MAPPER_ENDED,
    3223         MESSAGE_MAPPER_RESUMED,
    3224         MESSAGE_MAPPER_PAUSED,
    3225         MESSAGE_MAPPER_EOF,
     3223        MESSAGE_PERPKT_ENDED,
     3224        MESSAGE_PERPKT_RESUMED,
     3225        MESSAGE_PERPKT_PAUSED,
     3226        MESSAGE_PERPKT_EOF,
    32263227        MESSAGE_POST_REDUCE,
    32273228        MESSAGE_POST_RANGE,
     
    32293230};
    32303231
     3232enum hasher_types {
     3233        HASHER_BALANCE, /** Balance load across CPUs best as possible this is basically to say don't care about hash, but this might still might be implemented using a hash or round robin etc.. */
     3234        HASHER_BIDIRECTIONAL, /** Use a hash which is uni-directional for TCP flows (IP src dest,TCP port src dest), non TCP
     3235                                                        Will be sent to the same place, with the exception of UDP which may or may not be sent to separate cores */
     3236        HASHER_UNIDIRECTIONAL, /** Use a hash which is uni-directional across TCP flow */
     3237        HASHER_CUSTOM, /** Always use the user supplied hasher */
     3238        HASHER_HARDWARE, /** Set by the format if the hashing is going to be done in hardware */
     3239};
     3240
    32313241DLLEXPORT int trace_parallel_config(libtrace_t *libtrace, trace_parallel_option_t option, void *value);
    32323242DLLEXPORT libtrace_packet_t* trace_result_packet(libtrace_t * libtrace, libtrace_packet_t * packet);
    32333243DLLEXPORT void trace_free_result_packet(libtrace_t * libtrace, libtrace_packet_t * packet);
     3244enum hasher_types;
     3245DLLEXPORT int trace_set_hasher(libtrace_t *trace, enum hasher_types type, fn_hasher hasher, void *data);
    32343246
    32353247#ifdef __cplusplus
Note: See TracChangeset for help on using the changeset viewer.