29 #if defined(AS_USE_LIBEV) || defined(AS_USE_LIBUV) || defined(AS_USE_LIBEVENT)
30 #define AS_EVENT_LIB_DEFINED 1
33 #if defined(AS_USE_LIBEV)
35 #elif defined(AS_USE_LIBUV)
37 #elif defined(AS_USE_LIBEVENT)
38 #include <event2/event_struct.h>
108 #if defined(AS_USE_LIBEV)
109 struct ev_loop*
loop;
110 struct ev_async wakeup;
111 #elif defined(AS_USE_LIBUV)
114 #elif defined(AS_USE_LIBEVENT)
115 struct event_base*
loop;
369 return index < as_event_loop_size ? &as_event_loops[
index] : NULL;
385 as_event_loop_current = event_loop->
next;
411 static inline uint32_t
467 #if defined(AS_USE_LIBEVENT)
475 typedef void (*as_event_close_listener) (
void* udata);
487 as_event_set_single_thread(
bool single_thread)
489 as_event_single_thread = single_thread;
500 as_event_loop_register_aerospike(
as_event_loop* event_loop,
struct aerospike_s* as);
514 as_event_loop_close_aerospike(
515 as_event_loop* event_loop,
struct aerospike_s* as, as_event_close_listener listener,
void* udata
AS_EXTERN bool as_event_single_thread
AS_EXTERN bool as_event_set_external_loop_capacity(uint32_t capacity)
AS_EXTERN bool as_event_close_loops(void)
AS_EXTERN as_status as_set_external_event_loop(as_error *err, as_policy_event *policy, void *loop, as_event_loop **event_loop)
static uint32_t as_event_loop_get_queue_size(as_event_loop *event_loop)
AS_EXTERN uint32_t as_event_loop_size
AS_EXTERN void as_event_close_loop(as_event_loop *event_loop)
AS_EXTERN void as_event_destroy_loops(void)
struct as_event_loop * next
int max_commands_in_process
uint32_t max_commands_in_queue
uint32_t max_commands_in_queue
uint32_t queue_initial_capacity
AS_EXTERN as_status as_create_event_loops(as_error *err, as_policy_event *policy, uint32_t capacity, as_event_loop **event_loops)
static int as_event_loop_get_process_size(as_event_loop *event_loop)
AS_EXTERN as_event_loop * as_event_loops
static uint32_t as_queue_size(as_queue *queue)
static void as_policy_event_init(as_policy_event *policy)
AS_EXTERN as_event_loop * as_event_create_loops(uint32_t capacity)
static as_event_loop * as_event_loop_get()
AS_EXTERN as_event_loop * as_event_set_external_loop(void *loop)
AS_EXTERN as_event_loop * as_event_loop_current
static as_event_loop * as_event_loop_get_by_index(uint32_t index)
AS_EXTERN as_event_loop * as_event_loop_find(void *loop)
int max_commands_in_process