#include "config.h"
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include "connection_cl.h"
#include "tcp.h"
#include "system_parameter.h"
#include "connection_list_cl.h"

Include dependency graph for connection_list_cl.c:

Functions
static CSS_QUEUE_ENTRY *	css_make_queue_entry (unsigned int key, char buffer, int size, CSS_QUEUE_ENTRY next, int rc, int transid, int invalidate_snapshot, int db_error)

static void	css_free_queue_entry (CSS_QUEUE_ENTRY *entry_p)

static int	css_add_entry_to_header (CSS_QUEUE_ENTRY *anchor, unsigned short request_id, char buffer, int buffer_size, int rc, int transid, int invalidate_snapshot, int db_error)

static bool	css_is_request_aborted (CSS_CONN_ENTRY *conn, unsigned short request_id)

static void	css_queue_data_packet (CSS_CONN_ENTRY conn, unsigned short request_id, NET_HEADER header)

static void	css_queue_error_packet (CSS_CONN_ENTRY conn, unsigned short request_id, NET_HEADER header)

static void	css_queue_command_packet (CSS_CONN_ENTRY conn, unsigned short request_id, NET_HEADER header, int size)

static void	css_process_abort_packet (CSS_CONN_ENTRY *conn, unsigned short request_id)

CSS_QUEUE_ENTRY *	css_find_queue_entry (CSS_QUEUE_ENTRY *header, unsigned int key)

void	css_queue_remove_header (CSS_QUEUE_ENTRY **anchor)

void	css_queue_remove_header_entry (CSS_QUEUE_ENTRY **anchor, unsigned short request_id)

void	css_queue_remove_header_entry_ptr (CSS_QUEUE_ENTRY *anchor, CSS_QUEUE_ENTRY entry)

static int	css_queue_packet (CSS_CONN_ENTRY conn, CSS_QUEUE_ENTRY queue_p, unsigned short request_id, char buffer, int size, int rc)

int	css_queue_user_data_buffer (CSS_CONN_ENTRY conn, unsigned short request_id, int size, char buffer)

static bool	css_recv_and_queue_packet (CSS_CONN_ENTRY conn, unsigned short request_id, char buffer, int size, CSS_QUEUE_ENTRY **queue_p)

void	css_queue_unexpected_data_packet (CSS_CONN_ENTRY conn, unsigned short request_id, char buffer, int size, int rc)

void	css_queue_unexpected_error_packet (CSS_CONN_ENTRY conn, unsigned short request_id, char buffer, int size, int rc)

static void	css_process_close_packet (CSS_CONN_ENTRY *conn)

void	css_queue_unexpected_packet (int type, CSS_CONN_ENTRY conn, unsigned short request_id, NET_HEADER header, int size)

Function Documentation

static int css_add_entry_to_header	(	CSS_QUEUE_ENTRY **	anchor,
		unsigned short	request_id,
		char *	buffer,
		int	buffer_size,
		int	rc,
		int	transid,
		int	invalidate_snapshot,
		int	db_error
	)

static

Definition at line 147 of file connection_list_cl.c.

References CANT_ALLOC_BUFFER, css_make_queue_entry(), css_queue_entry::next, NO_ERRORS, and NULL.

Referenced by css_process_abort_packet(), css_queue_command_packet(), css_queue_packet(), and css_recv_and_queue_packet().

Here is the caller graph for this function:

CSS_QUEUE_ENTRY* css_find_queue_entry	(	CSS_QUEUE_ENTRY *	header,
		unsigned int	key
	)

Definition at line 117 of file connection_list_cl.c.

References css_queue_entry::key, css_queue_entry::next, and NULL.

Referenced by css_connect_to_cubrid_server(), css_is_request_aborted(), css_is_valid_request_id(), css_process_abort_packet(), css_return_data_buffer(), css_return_queued_data(), and css_return_queued_error().

Here is the caller graph for this function:

static void css_free_queue_entry ( CSS_QUEUE_ENTRY * entry_p )

static

Definition at line 98 of file connection_list_cl.c.

References css_queue_entry::buffer, free_and_init, and NULL.

Referenced by css_queue_remove_header(), css_queue_remove_header_entry(), and css_queue_remove_header_entry_ptr().

Here is the caller graph for this function:

static bool css_is_request_aborted	(	CSS_CONN_ENTRY *	conn,
		unsigned short	request_id
	)

static

Definition at line 306 of file connection_list_cl.c.

References css_conn_entry::abort_queue, css_find_queue_entry(), and NULL.

Referenced by css_queue_command_packet(), css_queue_packet(), and css_recv_and_queue_packet().

Here is the caller graph for this function:

static CSS_QUEUE_ENTRY * css_make_queue_entry	(	unsigned int	key,
		char *	buffer,
		int	size,
		CSS_QUEUE_ENTRY *	next,
		int	rc,
		int	transid,
		int	invalidate_snapshot,
		int	db_error
	)