#include <aerospike/as_async.h>
#include <aerospike/as_log.h>
#include <aerospike/as_log_macros.h>
#include <aerospike/as_node.h>
#include <aerospike/as_socket.h>
#include <citrusleaf/alloc.h>
#include <citrusleaf/cf_ll.h>
#include <assert.h>
#include <fcntl.h>
#include <inttypes.h>
#include <stddef.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <sys/socket.h>
#include <unistd.h>
Go to the source code of this file.
Data Structures | |
struct | as_pipe_connection |
Functions | |
void | as_pipe_get_connection (as_event_command *cmd) |
int | as_pipe_get_recv_buffer_size (void) |
int | as_pipe_get_send_buffer_size (void) |
static as_event_command * | as_pipe_link_to_command (cf_ll_element *link) |
bool | as_pipe_modify_fd (as_socket_fd fd) |
void | as_pipe_read_start (as_event_command *cmd) |
void | as_pipe_response_complete (as_event_command *cmd) |
void | as_pipe_response_error (as_event_command *cmd, as_error *err) |
void | as_pipe_socket_error (as_event_command *cmd, as_error *err, bool retry) |
void | as_pipe_timeout (as_event_command *cmd, bool retry) |
void | as_pipe_write_start (as_event_command *cmd) |
void as_pipe_get_connection | ( | as_event_command * | cmd | ) |
int as_pipe_get_recv_buffer_size | ( | void | ) |
int as_pipe_get_send_buffer_size | ( | void | ) |
|
inlinestatic |
bool as_pipe_modify_fd | ( | as_socket_fd | fd | ) |
void as_pipe_read_start | ( | as_event_command * | cmd | ) |
void as_pipe_response_complete | ( | as_event_command * | cmd | ) |
void as_pipe_response_error | ( | as_event_command * | cmd, |
as_error * | err | ||
) |
void as_pipe_socket_error | ( | as_event_command * | cmd, |
as_error * | err, | ||
bool | retry | ||
) |
void as_pipe_timeout | ( | as_event_command * | cmd, |
bool | retry | ||
) |
void as_pipe_write_start | ( | as_event_command * | cmd | ) |