hashmap.h

Go to the documentation of this file.

#ifndef HASHMAP_H
#define HASHMAP_H
 
#include <pthread.h>
#include <time.h>
#include <stdlib.h>
#include <string.h>
#include "window.h"
#include "../../include/trafilo.h"

typedef struct bucket_node {
    char *key; /* Bucket owned key*/
    void *state; /* User defined state */
    sliding_window_t *window; /* An embedded sliding window */
 
    struct bucket_node *next;
    struct timespec last_event_ts;
} bucket_node;

typedef struct hashmap_t {
    bucket_node **buckets; /* Array of chain buckets */
    pthread_mutex_t *locks; /* Array of per bucket locks*/
    size_t num_buckets; /* Number of buckets in hashmap */
} hashmap_t;

hashmap_t *hashmap_create(size_t num_buckets);

bucket_node *hashmap_find_or_create(hashmap_t *hashmap, const char *key);

void hashmap_destroy(hashmap_t *hashmap, trafilo_state_free_fn state_free);

void hashmap_for_each(hashmap_t *hashmap, 
        void (*fn)(bucket_node *bucket, void *arg), 
        void *arg);

void hashmap_unlock_bucket(hashmap_t *hashmap, const char *key);
 
#endif