daos_event.h

 
#ifndef __DAOS_EVENT_H__
#define __DAOS_EVENT_H__
 
#if defined(__cplusplus)
extern "C" {
#endif
 
#include <daos_types.h>
#include <daos_errno.h>
 
#if !defined(container_of)
# define container_of(ptr, type, member)                \
        ((type *)((char *)(ptr)-(char *)(&((type *)0)->member)))
#endif

int
daos_eq_create(daos_handle_t *eqh);
 
#define DAOS_EQ_DESTROY_FORCE   1
int
daos_eq_destroy(daos_handle_t eqh, int flags);

int
daos_eq_poll(daos_handle_t eqh, int wait_running,
         int64_t timeout, unsigned int nevents, daos_event_t **events);

int
daos_eq_query(daos_handle_t eqh, daos_eq_query_t query,
          unsigned int nevents, daos_event_t **events);

int
daos_event_init(daos_event_t *ev, daos_handle_t eqh, daos_event_t *parent);

int
daos_event_fini(daos_event_t *ev);

daos_event_t *
daos_event_next(daos_event_t *parent, daos_event_t *child);

int
daos_event_test(struct daos_event *ev, int64_t timeout, bool *flag);
 
typedef int (*daos_event_comp_cb_t)(void *, daos_event_t *, int);

int
daos_event_register_comp_cb(struct daos_event *ev, daos_event_comp_cb_t cb,
                void *arg);

int
daos_event_parent_barrier(struct daos_event *ev);

int
daos_event_abort(daos_event_t *ev);
 
#if defined(__cplusplus)
}
#endif
 
#endif /*  __DAOS_EVENT_H__ */