as_async.h File Reference

#include <aerospike/as_async_proto.h>
#include <aerospike/as_command.h>
#include <aerospike/as_cluster.h>
#include <aerospike/as_event_internal.h>
#include <aerospike/as_listener.h>
#include <citrusleaf/alloc.h>

Include dependency graph for as_async.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	as_async_info_command
struct	as_async_record_command
struct	as_async_value_command
struct	as_async_write_command

Macros
#define	AS_ASYNC_CONNECTION_COMPLETE   0
#define	AS_ASYNC_CONNECTION_ERROR   2
#define	AS_ASYNC_CONNECTION_PENDING   1
#define	AS_ASYNC_TYPE_BATCH   3
#define	AS_ASYNC_TYPE_CONNECTOR   9
#define	AS_ASYNC_TYPE_INFO   6
#define	AS_ASYNC_TYPE_QUERY   5
#define	AS_ASYNC_TYPE_QUERY_PARTITION   8
#define	AS_ASYNC_TYPE_RECORD   1
#define	AS_ASYNC_TYPE_SCAN   4
#define	AS_ASYNC_TYPE_SCAN_PARTITION   7
#define	AS_ASYNC_TYPE_VALUE   2
#define	AS_ASYNC_TYPE_WRITE   0
#define	AS_AUTHENTICATION_MAX_SIZE   158

Functions
static as_event_command *	as_async_info_command_create (as_node *node, const as_policy_info *policy, as_async_info_listener listener, void *udata, as_event_loop *event_loop, size_t size)
static as_event_command *	as_async_record_command_create (as_cluster *cluster, const as_policy_base *policy, as_partition_info *pi, as_policy_replica replica, uint8_t replica_index, bool deserialize, bool heap_rec, uint8_t flags, as_async_record_listener listener, void *udata, as_event_loop *event_loop, as_pipe_listener pipe_listener, size_t size, as_event_parse_results_fn parse_results, as_latency_type latency_type)
static as_event_command *	as_async_value_command_create (as_cluster *cluster, const as_policy_base *policy, as_partition_info *pi, as_policy_replica replica, as_async_value_listener listener, void *udata, as_event_loop *event_loop, as_pipe_listener pipe_listener, size_t size, as_event_parse_results_fn parse_results)
static as_event_command *	as_async_write_command_create (as_cluster *cluster, const as_policy_base *policy, as_partition_info *pi, as_policy_replica replica, as_async_write_listener listener, void *udata, as_event_loop *event_loop, as_pipe_listener pipe_listener, size_t size, as_event_parse_results_fn parse_results)

Macro Definition Documentation

AS_ASYNC_CONNECTION_COMPLETE

#define AS_ASYNC_CONNECTION_COMPLETE   0

Definition at line 47 of file as_async.h.

AS_ASYNC_CONNECTION_ERROR

#define AS_ASYNC_CONNECTION_ERROR   2

Definition at line 49 of file as_async.h.

AS_ASYNC_CONNECTION_PENDING

#define AS_ASYNC_CONNECTION_PENDING   1

Definition at line 48 of file as_async.h.

AS_ASYNC_TYPE_BATCH

#define AS_ASYNC_TYPE_BATCH   3

Definition at line 37 of file as_async.h.

AS_ASYNC_TYPE_CONNECTOR

#define AS_ASYNC_TYPE_CONNECTOR   9

Definition at line 43 of file as_async.h.

AS_ASYNC_TYPE_INFO

#define AS_ASYNC_TYPE_INFO   6

Definition at line 40 of file as_async.h.

AS_ASYNC_TYPE_QUERY

#define AS_ASYNC_TYPE_QUERY   5

Definition at line 39 of file as_async.h.

AS_ASYNC_TYPE_QUERY_PARTITION

#define AS_ASYNC_TYPE_QUERY_PARTITION   8

Definition at line 42 of file as_async.h.

AS_ASYNC_TYPE_RECORD

#define AS_ASYNC_TYPE_RECORD   1

Definition at line 35 of file as_async.h.

AS_ASYNC_TYPE_SCAN

#define AS_ASYNC_TYPE_SCAN   4

Definition at line 38 of file as_async.h.

AS_ASYNC_TYPE_SCAN_PARTITION

#define AS_ASYNC_TYPE_SCAN_PARTITION   7

Definition at line 41 of file as_async.h.

AS_ASYNC_TYPE_VALUE

#define AS_ASYNC_TYPE_VALUE   2

Definition at line 36 of file as_async.h.

AS_ASYNC_TYPE_WRITE

#define AS_ASYNC_TYPE_WRITE   0

Definition at line 34 of file as_async.h.

AS_AUTHENTICATION_MAX_SIZE

#define AS_AUTHENTICATION_MAX_SIZE   158

Definition at line 45 of file as_async.h.

Function Documentation

as_async_info_command_create()

static as_event_command * as_async_info_command_create ( as_node * node, const as_policy_info * policy, as_async_info_listener listener, void * udata, as_event_loop * event_loop, size_t size )

inlinestatic

Definition at line 212 of file as_async.h.

References AS_ASYNC_STATE_UNREGISTERED, AS_ASYNC_TYPE_INFO, AS_AUTHENTICATION_MAX_SIZE, as_cluster_add_tran(), as_event_assign(), as_event_command_parse_info(), AS_INFO_MESSAGE_TYPE, AS_LATENCY_TYPE_NONE, AS_POLICY_REPLICA_MASTER, as_event_command::buf, as_event_command::cluster, as_node::cluster, as_event_command::event_loop, as_event_command::flags, as_event_command::iteration, as_event_command::latency_type, as_async_info_command::listener, as_event_command::max_retries, as_event_command::node, as_event_command::ns, as_event_command::parse_results, as_event_command::partition, as_event_command::pipe_listener, as_event_command::proto_type, as_event_command::read_capacity, as_event_command::replica, as_event_command::replica_index, as_event_command::replica_size, as_event_command::socket_timeout, as_async_info_command::space, as_event_command::state, as_policy_info::timeout, as_event_command::total_deadline, as_event_command::type, and as_event_command::udata.

as_async_record_command_create()

static as_event_command * as_async_record_command_create ( as_cluster * cluster, const as_policy_base * policy, as_partition_info * pi, as_policy_replica replica, uint8_t replica_index, bool deserialize, bool heap_rec, uint8_t flags, as_async_record_listener listener, void * udata, as_event_loop * event_loop, as_pipe_listener pipe_listener, size_t size, as_event_parse_results_fn parse_results, as_latency_type latency_type )

inlinestatic

Definition at line 120 of file as_async.h.

References AS_ASYNC_FLAGS_DESERIALIZE, AS_ASYNC_FLAGS_HEAP_REC, AS_ASYNC_STATE_UNREGISTERED, AS_ASYNC_TYPE_RECORD, AS_AUTHENTICATION_MAX_SIZE, as_cluster_add_tran(), as_event_assign(), AS_MESSAGE_TYPE, as_event_command::buf, as_event_command::cluster, as_event_command::event_loop, as_event_command::flags, as_event_command::iteration, as_event_command::latency_type, as_async_record_command::listener, as_event_command::max_retries, as_policy_base::max_retries, as_event_command::node, as_event_command::ns, as_partition_info::ns, as_event_command::parse_results, as_event_command::partition, as_partition_info::partition, as_event_command::pipe_listener, as_event_command::proto_type, as_event_command::read_capacity, as_event_command::replica, as_event_command::replica_index, as_event_command::replica_size, as_partition_info::replica_size, as_event_command::socket_timeout, as_policy_base::socket_timeout, as_async_record_command::space, as_event_command::state, as_event_command::total_deadline, as_policy_base::total_timeout, as_event_command::type, and as_event_command::udata.

as_async_value_command_create()

static as_event_command * as_async_value_command_create ( as_cluster * cluster, const as_policy_base * policy, as_partition_info * pi, as_policy_replica replica, as_async_value_listener listener, void * udata, as_event_loop * event_loop, as_pipe_listener pipe_listener, size_t size, as_event_parse_results_fn parse_results )

inlinestatic

Definition at line 171 of file as_async.h.

References AS_ASYNC_STATE_UNREGISTERED, AS_ASYNC_TYPE_VALUE, AS_AUTHENTICATION_MAX_SIZE, as_cluster_add_tran(), as_command_write_replica(), as_event_assign(), AS_LATENCY_TYPE_WRITE, AS_MESSAGE_TYPE, as_event_command::buf, as_event_command::cluster, as_event_command::event_loop, as_event_command::flags, as_event_command::iteration, as_event_command::latency_type, as_async_value_command::listener, as_event_command::max_retries, as_policy_base::max_retries, as_event_command::node, as_event_command::ns, as_partition_info::ns, as_event_command::parse_results, as_event_command::partition, as_partition_info::partition, as_event_command::pipe_listener, as_event_command::proto_type, as_event_command::read_capacity, as_event_command::replica, as_event_command::replica_index, as_event_command::replica_size, as_partition_info::replica_size, as_event_command::socket_timeout, as_policy_base::socket_timeout, as_async_value_command::space, as_event_command::state, as_event_command::total_deadline, as_policy_base::total_timeout, as_event_command::type, and as_event_command::udata.

as_async_write_command_create()

static as_event_command * as_async_write_command_create ( as_cluster * cluster, const as_policy_base * policy, as_partition_info * pi, as_policy_replica replica, as_async_write_listener listener, void * udata, as_event_loop * event_loop, as_pipe_listener pipe_listener, size_t size, as_event_parse_results_fn parse_results )

inlinestatic

Definition at line 80 of file as_async.h.

References AS_ASYNC_STATE_UNREGISTERED, AS_ASYNC_TYPE_WRITE, AS_AUTHENTICATION_MAX_SIZE, as_cluster_add_tran(), as_command_write_replica(), as_event_assign(), AS_LATENCY_TYPE_WRITE, AS_MESSAGE_TYPE, as_event_command::buf, as_event_command::cluster, as_event_command::event_loop, as_event_command::flags, as_event_command::iteration, as_event_command::latency_type, as_async_write_command::listener, as_event_command::max_retries, as_policy_base::max_retries, as_event_command::node, as_event_command::ns, as_partition_info::ns, as_event_command::parse_results, as_event_command::partition, as_partition_info::partition, as_event_command::pipe_listener, as_event_command::proto_type, as_event_command::read_capacity, as_event_command::replica, as_event_command::replica_index, as_event_command::replica_size, as_partition_info::replica_size, as_event_command::socket_timeout, as_policy_base::socket_timeout, as_async_write_command::space, as_event_command::state, as_event_command::total_deadline, as_policy_base::total_timeout, as_event_command::type, and as_event_command::udata.