25 #ifndef __MOTR_ADDB2_CONSUMER_H__ 26 #define __MOTR_ADDB2_CONSUMER_H__
void m0_addb2_callback_fini(struct m0_addb2_callback *callback)
struct m0_addb2_source cu_src
static struct m0_addb2_mach * m
const struct m0_addb2_trace * cu_trace
static struct buffer * cur(struct m0_addb2_mach *mach, m0_bcount_t space)
struct m0_tlink ph_linkage
int m0_addb2_cursor_next(struct m0_addb2_cursor *cur)
void m0_addb2_cursor_fini(struct m0_addb2_cursor *cur)
void m0_addb2_philter_global_del(struct m0_addb2_philter *ph)
void m0_addb2_callback_add(struct m0_addb2_philter *ph, struct m0_addb2_callback *callback)
void m0_addb2_philter_id_init(struct m0_addb2_philter *ph, uint64_t id)
void m0_addb2_philter_true_init(struct m0_addb2_philter *ph)
static struct m0_addb2_callback c
struct m0_addb2_record cu_rec
void m0_addb2_consume(struct m0_addb2_source *src, const struct m0_addb2_record *rec)
struct m0_addb2_value ar_label[M0_ADDB2_LABEL_MAX]
void m0_addb2_cursor_init(struct m0_addb2_cursor *cur, const struct m0_addb2_trace *trace)
void m0_addb2_philter_global_add(struct m0_addb2_philter *ph)
void m0_addb2_callback_del(struct m0_addb2_callback *callback)
void m0_addb2_philter_fini(struct m0_addb2_philter *philter)
struct m0_tlink ca_linkage
bool(* ph_matches)(struct m0_addb2_philter *ph, const struct m0_addb2_record *rec)
struct m0_addb2_value ar_val
void m0_addb2_philter_add(struct m0_addb2_source *src, struct m0_addb2_philter *ph)
void(* ca_fire)(const struct m0_addb2_source *src, const struct m0_addb2_philter *ph, const struct m0_addb2_callback *callback, const struct m0_addb2_record *rec)
void m0_addb2_callback_init(struct m0_addb2_callback *callback, void(*fire)(const struct m0_addb2_source *, const struct m0_addb2_philter *, const struct m0_addb2_callback *, const struct m0_addb2_record *), void *datum)
void m0_addb2_source_fini(struct m0_addb2_source *src)
void m0_addb2_philter_del(struct m0_addb2_philter *ph)
void m0_addb2_source_init(struct m0_addb2_source *src)
void m0_addb2_philter_init(struct m0_addb2_philter *philter, bool(*matches)(struct m0_addb2_philter *, const struct m0_addb2_record *), void *datum)
struct m0_addb2_source * m0_addb2_mach_source(struct m0_addb2_mach *m)
struct m0_pdclust_src_addr src
static void(* fire)(const struct m0_addb2_source *, const struct m0_addb2_philter *, const struct m0_addb2_callback *, const struct m0_addb2_record *)
struct m0_addb2_source * m0_addb2_cursor_source(struct m0_addb2_cursor *c)