#include "lib/assert.h"
#include "lib/misc.h"
#include "motr/magic.h"
#include "addb2/consumer.h"
#include "addb2/addb2.h"
#include "addb2/internal.h"

Include dependency graph for consumer.c:

Go to the source code of this file.

Macros
#define	M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_ADDB

Functions
	M0_TL_DESCR_DEFINE (philter, "addb2 source philters", static, struct m0_addb2_philter, ph_linkage, ph_magix, M0_ADDB2_PHILTER_MAGIC, M0_ADDB2_PHILTER_HEAD_MAGIC)

	M0_TL_DEFINE (philter, static, struct m0_addb2_philter)

	M0_TL_DESCR_DEFINE (callback, "addb2 philter callbacks", static, struct m0_addb2_callback, ca_linkage, ca_magix, M0_ADDB2_CALLBACK_MAGIC, M0_ADDB2_CALLBACK_HEAD_MAGIC)

	M0_TL_DEFINE (callback, static, struct m0_addb2_callback)

static bool	true_matches (struct m0_addb2_philter philter, const struct m0_addb2_record rec)

static bool	id_matches (struct m0_addb2_philter philter, const struct m0_addb2_record rec)

void	m0_addb2_source_init (struct m0_addb2_source *src)

void	m0_addb2_source_fini (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)

void	m0_addb2_philter_fini (struct m0_addb2_philter *philter)

void	m0_addb2_philter_add (struct m0_addb2_source src, struct m0_addb2_philter ph)

void	m0_addb2_philter_del (struct m0_addb2_philter *ph)

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_callback_fini (struct m0_addb2_callback *callback)

void	m0_addb2_callback_add (struct m0_addb2_philter ph, struct m0_addb2_callback callback)

void	m0_addb2_callback_del (struct m0_addb2_callback *callback)

struct m0_addb2_source *	m0_addb2_cursor_source (struct m0_addb2_cursor *c)

static void	philter_consume (struct m0_addb2_source src, struct m0_addb2_philter ph, const struct m0_addb2_record *rec)

void	m0_addb2_consume (struct m0_addb2_source src, const struct m0_addb2_record rec)

void	m0_addb2_philter_true_init (struct m0_addb2_philter *ph)

void	m0_addb2_philter_id_init (struct m0_addb2_philter *ph, uint64_t id)

void	m0_addb2_philter_global_add (struct m0_addb2_philter *ph)

void	m0_addb2_philter_global_del (struct m0_addb2_philter *ph)

Macros

Functions