File network_cl.c¶

FileList > communication > network_cl.c

#include "config.h"
#include <stdio.h>
#include <string.h>
#include <assert.h>
#include <sys/time.h>
#include <sys/resource.h>
#include <vector>
#include "network.h"
#include "network_interface_cl.h"
#include "chartype.h"
#include "server_interface.h"
#include "memory_alloc.h"
#include "databases_file.h"
#include "error_manager.h"
#include "system_parameter.h"
#include "environment_variable.h"
#include "boot_cl.h"
#include "query_method.hpp"
#include "method_callback.hpp"
#include "release_string.h"
#include "log_comm.h"
#include "file_io.h"
#include "locator.h"
#include "db.h"
#include "client_support.h"
#include "perf_monitor.h"
#include "log_writer.h"
#include "object_representation.h"
#include "packer.hpp"
#include "network_histogram.hpp"

Namespaces¶

Type	Name
namespace	anonymous_namespace{network_cl.c}

Classes¶

Type	Name
struct	deferred_flush_guard

Public Attributes¶

Type	Name
unsigned short	method_request_id

Public Static Attributes¶

Type	Name
char	net_Server_host = `{ 0x00, }`
char	net_Server_name = `{ 0x00, }`

Public Functions¶

Type	Name
void	net_cleanup_client_queues (void)
int	net_client_check_log_header (LOGWR_CONTEXT * ctx_ptr, char * argbuf, int argsize, char * replybuf, int replysize, char logpg_area_buf, bool** verbose)
int	net_client_final (bool server_error)
int	net_client_get_next_log_pages (int rc, char * replybuf, int replysize, int length)
int	net_client_init (const char * dbname, const char * hostname)
void	net_client_logwr_send_end_msg (int rc, int error)
int	net_client_ping_server (int client_val, int * server_val, int timeout)
int	net_client_ping_server_with_handshake (int client_type, bool check_capabilities, int opt_cap)
int	net_client_receive_action (int rc, int * action)
int	net_client_recv_copyarea (int request, char * replybuf, int replysize, char * recvbuffer, int recvbuffer_size, LC_COPYAREA reply_copy_area, int** rc)
int	net_client_request (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char * replydata, int replydatasize)
int	net_client_request2 (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char replydata_ptr, int** * replydatasize_ptr)
int	net_client_request2_no_malloc (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char * replydata, int * replydatasize_ptr)
int	net_client_request_2recv_copyarea (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char * recvbuffer, int recvbuffer_size, LC_COPYAREA reply_copy_area, int** * eid)
int	net_client_request_3_data (int request, char * argbuf, int argsize, char * databuf1, int datasize1, char * databuf2, int datasize2, char * reply0, int replysize0, char * reply1, int replysize1, char * reply2, int replysize2)
int	net_client_request_3_data_recv_copyarea (int request, char * argbuf, int argsize, char * databuf1, int datasize1, char * databuf2, int datasize2, char * replybuf, int replysize, LC_COPYAREA ** reply_copy_area)
int	net_client_request_3recv_copyarea (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char recvbuffer, int** * recvbuffer_size, LC_COPYAREA ** reply_copy_area)
int	net_client_request_method_callback (int request, char * argbuf, int argsize, char * replybuf, int replysize, char replydata_ptr, int** * replydatasize_ptr)
int	net_client_request_no_reply (int request, char * argbuf, int argsize)
int	net_client_request_recv_copyarea (int request, char * argbuf, int argsize, char * replybuf, int replysize, LC_COPYAREA ** reply_copy_area)
int	net_client_request_recv_large_data (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char * replydata, INT64 * replydatasize_ptr)
int	net_client_request_recv_stream (int request, char * argbuf, int argsize, char * replybuf, int replybuf_size, char * databuf, int datasize, FILE * outfp)
int	net_client_request_send_large_data (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, INT64 datasize, char * replydata, int replydatasize)
int	net_client_request_with_callback (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf1, int datasize1, char * databuf2, int datasize2, char replydata_listid, int** * replydatasize_listid, char replydata_page, int** * replydatasize_page, char replydata_plan, int** * replydatasize_plan)
int	net_client_request_with_logwr_context (LOGWR_CONTEXT * ctx_ptr, int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf1, int datasize1, char * databuf2, int datasize2)
int	net_client_send_data (unsigned int rc, char * databuf, int datasize)
void	net_client_shutdown_server (void)

Public Static Functions¶

Type	Name
int	check_server_capabilities (int server_cap, int client_type, int rel_compare, REL_COMPATIBILITY * compatibility, const char * server_host, int opt_cap)
int	client_capabilities (void)
int	compare_size_and_buffer (int * replysize, int size, char replybuf, char** * buf, const char * file, const int line)
int	net_client_request_internal (int request, char * argbuf, int argsize, char * replybuf, int replysize, char * databuf, int datasize, char * replydata, int replydatasize)
void	net_consume_expected_packets (int rc, int num_packets)
int	net_set_alloc_err_if_not_set (int err, const char * file, const int line)
void	return_error_to_server (char * host, unsigned int eid)
int	set_server_error (int error)

Macros¶

Type	Name
define	COMPARE_AND_FREE_BUFFER (queued, reply) `/* multi line expression */`
define	COMPARE_SIZE_AND_BUFFER (replysize, size, replybuf, buf) `/* multi line expression */`
define	PLAN_DUMP_STREAM_CHUNK_SIZE `(64 \* 1024)`

Public Attributes Documentation¶

variable method_request_id¶

unsigned short method_request_id;

Public Static Attributes Documentation¶

variable net_Server_host¶

char net_Server_host[CUB_MAXHOSTNAMELEN+1];

variable net_Server_name¶

char net_Server_name[DB_MAX_IDENTIFIER_LENGTH+1];

Public Functions Documentation¶

function net_cleanup_client_queues¶

void net_cleanup_client_queues (
    void
)

function net_client_check_log_header¶

int net_client_check_log_header (
    LOGWR_CONTEXT * ctx_ptr,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char ** logpg_area_buf,
    bool verbose
)

function net_client_final¶

int net_client_final (
    bool server_error
)

function net_client_get_next_log_pages¶

int net_client_get_next_log_pages (
    int rc,
    char * replybuf,
    int replysize,
    int length
)

function net_client_init¶

int net_client_init (
    const  char * dbname,
    const  char * hostname
)

function net_client_logwr_send_end_msg¶

void net_client_logwr_send_end_msg (
    int rc,
    int error
)

function net_client_ping_server¶

int net_client_ping_server (
    int client_val,
    int * server_val,
    int timeout
)

function net_client_ping_server_with_handshake¶

int net_client_ping_server_with_handshake (
    int client_type,
    bool check_capabilities,
    int opt_cap
)

function net_client_receive_action¶

int net_client_receive_action (
    int rc,
    int * action
)

function net_client_recv_copyarea¶

int net_client_recv_copyarea (
    int request,
    char * replybuf,
    int replysize,
    char * recvbuffer,
    int recvbuffer_size,
    LC_COPYAREA ** reply_copy_area,
    int rc
)

function net_client_request¶

int net_client_request (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char * replydata,
    int replydatasize
)

function net_client_request2¶

int net_client_request2 (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char ** replydata_ptr,
    int * replydatasize_ptr
)

function net_client_request2_no_malloc¶

int net_client_request2_no_malloc (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char * replydata,
    int * replydatasize_ptr
)

function net_client_request_2recv_copyarea¶

int net_client_request_2recv_copyarea (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char * recvbuffer,
    int recvbuffer_size,
    LC_COPYAREA ** reply_copy_area,
    int * eid
)

function net_client_request_3_data¶

int net_client_request_3_data (
    int request,
    char * argbuf,
    int argsize,
    char * databuf1,
    int datasize1,
    char * databuf2,
    int datasize2,
    char * reply0,
    int replysize0,
    char * reply1,
    int replysize1,
    char * reply2,
    int replysize2
)

function net_client_request_3_data_recv_copyarea¶

int net_client_request_3_data_recv_copyarea (
    int request,
    char * argbuf,
    int argsize,
    char * databuf1,
    int datasize1,
    char * databuf2,
    int datasize2,
    char * replybuf,
    int replysize,
    LC_COPYAREA ** reply_copy_area
)

function net_client_request_3recv_copyarea¶

int net_client_request_3recv_copyarea (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char ** recvbuffer,
    int * recvbuffer_size,
    LC_COPYAREA ** reply_copy_area
)

function net_client_request_method_callback¶

int net_client_request_method_callback (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char ** replydata_ptr,
    int * replydatasize_ptr
)

function net_client_request_no_reply¶

int net_client_request_no_reply (
    int request,
    char * argbuf,
    int argsize
)

function net_client_request_recv_copyarea¶

int net_client_request_recv_copyarea (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    LC_COPYAREA ** reply_copy_area
)

function net_client_request_recv_large_data¶

int net_client_request_recv_large_data (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char * replydata,
    INT64 * replydatasize_ptr
)

function net_client_request_recv_stream¶

int net_client_request_recv_stream (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replybuf_size,
    char * databuf,
    int datasize,
    FILE * outfp
)

function net_client_request_send_large_data¶

int net_client_request_send_large_data (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    INT64 datasize,
    char * replydata,
    int replydatasize
)

function net_client_request_with_callback¶

int net_client_request_with_callback (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf1,
    int datasize1,
    char * databuf2,
    int datasize2,
    char ** replydata_listid,
    int * replydatasize_listid,
    char ** replydata_page,
    int * replydatasize_page,
    char ** replydata_plan,
    int * replydatasize_plan
)

function net_client_request_with_logwr_context¶

int net_client_request_with_logwr_context (
    LOGWR_CONTEXT * ctx_ptr,
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf1,
    int datasize1,
    char * databuf2,
    int datasize2
)

function net_client_send_data¶

int net_client_send_data (
    unsigned  int rc,
    char * databuf,
    int datasize
)

function net_client_shutdown_server¶

void net_client_shutdown_server (
    void
)

Public Static Functions Documentation¶

function check_server_capabilities¶

static int check_server_capabilities (
    int server_cap,
    int client_type,
    int rel_compare,
    REL_COMPATIBILITY * compatibility,
    const  char * server_host,
    int opt_cap
)

function client_capabilities¶

static int client_capabilities (
    void
)

function compare_size_and_buffer¶

static int compare_size_and_buffer (
    int * replysize,
    int size,
    char ** replybuf,
    char * buf,
    const  char * file,
    const  int line
)

function net_client_request_internal¶

static int net_client_request_internal (
    int request,
    char * argbuf,
    int argsize,
    char * replybuf,
    int replysize,
    char * databuf,
    int datasize,
    char * replydata,
    int replydatasize
)

function net_consume_expected_packets¶

static void net_consume_expected_packets (
    int rc,
    int num_packets
)

function net_set_alloc_err_if_not_set¶

static int net_set_alloc_err_if_not_set (
    int err,
    const  char * file,
    const  int line
)

function return_error_to_server¶

static void return_error_to_server (
    char * host,
    unsigned  int eid
)

function set_server_error¶

static int set_server_error (
    int error
)

Macro Definition Documentation¶

define COMPARE_AND_FREE_BUFFER¶

#define COMPARE_AND_FREE_BUFFER (
    queued,
    reply
) `/* multi line expression */`

define COMPARE_SIZE_AND_BUFFER¶

#define COMPARE_SIZE_AND_BUFFER (
    replysize,
    size,
    replybuf,
    buf
) `compare_size_and_buffer (( replysize ), (size), ( replybuf ), (buf),     \ __FILE__ , __LINE__ )`

define PLAN_DUMP_STREAM_CHUNK_SIZE¶

#define PLAN_DUMP_STREAM_CHUNK_SIZE `(64 * 1024)`

The documentation for this class was generated from the following file cubrid/src/communication/network_cl.c