dispatcher.h

Go to the documentation of this file.

#ifndef DISPATCHER_H
#define DISPATCHER_H
#include "bounded_queue.h"
#include "hashmap.h"

typedef struct dispatcher_t {
    bounded_queue_t *bounded_q; /* Working bounded queue*/
    hashmap_t *hash_m; /* Events map*/
    
    const trafilo_config_t *config;
    
    // Thread pools
    size_t num_workers; /* Number of wokrer threads, fetched from trafilo_conifg_t*/
    pthread_t *threads; /* Array of worker thread pool*/
 
    // Lifecycle
    volatile int done; /* Shutdown signaling*/
    int started; 
} dispatcher_t;

dispatcher_t *dispatcher_create(bounded_queue_t *bounded_q, 
        hashmap_t *hashmap, 
        const trafilo_config_t *trafilo_config);

int dispatcher_start(dispatcher_t *dispatcher);

void dispatcher_stop(dispatcher_t *dispatcher);

void dispatcher_destroy(dispatcher_t *dispatcher);
#endif