lbmht.h

Go to the documentation of this file.

#ifndef LBMHT_H
#define LBMHT_H

#if defined(__cplusplus)
extern "C" {
#endif /* __cplusplus */

#include "lbm/lbm.h"

#define LBM_HT_BASE_MATCH_LEVEL         0
#define LBM_HT_TOKEN_GLOBNAME           0
#define LBM_HT_TOKEN_GLOBPATH           1
#define LBM_HT_TOKEN_NAME                       2

#define LBM_HT_INIT_BRANCH_SZ   16

#define LBM_HT_CBVEC_SZ 16

typedef struct lbm_hypertopic_rcv_stct lbm_hypertopic_rcv_t;

typedef int (*lbm_hypertopic_rcv_cb_proc)(lbm_hypertopic_rcv_t *hrcv, lbm_msg_t *msg, void *clientd);

typedef void (*lbm_delete_cb_proc)(int dispatch_thrd, void *clientd);

#define LBM_HT_CBVEC_FLAG_ACTIVE        1
#define LBM_HT_CBVEC_FLAG_DELETED       2


#ifdef LBM_HT_INTERNAL
struct htcbvec {
        union {
                lbm_hypertopic_rcv_cb_proc rcvproc;
                lbm_delete_cb_proc delproc;
        } u;
        void *clientd;
        int flags;
};

struct htcbvlist
{
        struct htcbvlist *next;
        struct htcbvlist *nextactv;
        int idx;
        struct htcbvec cbvec[LBM_HT_CBVEC_SZ];
};

struct lbm_hypertopic_rcv_stct
{
        mul_mutex_t lock;
        lbm_wildcard_rcv_t *wrcv;
        lbm_event_queue_t *evq;
        lbm_context_t *ctx;
        struct htbranch *root;
        size_t prelen;
        struct htcbvlist *activecbs;
};

struct htcbnode
{
        lbm_hypertopic_rcv_cb_proc rcvproc;
        void *clientd;
        struct htcbnode *next;
};

struct htnode
{
        char *cname;
        int refcnt;
        struct htcbnode *cblist;
        struct htbranch *next;
};

struct htbranch
{
        int nnodes;
        int size;
        int idx[LBM_HT_TOKEN_NAME+1];
        struct htnode htnodes[1];
};
#endif

typedef struct lbm_delete_cb_info_t_stct {
    lbm_delete_cb_proc cbproc;
    void *clientd;
} lbm_delete_cb_info_t;

LBMExpDLL int lbm_hypertopic_rcv_init(lbm_hypertopic_rcv_t **hrcvp, lbm_context_t *ctx, const char *prefix, lbm_event_queue_t *evq);

LBMExpDLL int lbm_hypertopic_rcv_add(lbm_hypertopic_rcv_t *hrcv, const char *pattern, lbm_hypertopic_rcv_cb_proc proc, void *clientd);

LBMExpDLL int lbm_hypertopic_rcv_delete(lbm_hypertopic_rcv_t *hrcv, const char *pattern, lbm_hypertopic_rcv_cb_proc proc, void *clientd, lbm_delete_cb_info_t *cbinfo);

LBMExpDLL int lbm_hypertopic_rcv_destroy(lbm_hypertopic_rcv_t *hrcv);

#if defined(__cplusplus)
}
#endif /* __cplusplus */

#endif