File cas_net_buf.c¶

FileList > broker > cas_net_buf.c

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <assert.h>
#include <arpa/inet.h>
#include "cas_common_vars.h"
#include "cas_error.h"
#include "broker_cas_cci.h"
#include "cas_net_buf.h"
#include "cas_util.h"
#include "dbi.h"
#include "error_code.h"
#include "dbtype.h"
#include "byte_order.h"

Public Static Attributes¶

Type	Name
int	_net_buf_size = `(16 \* 1024 )`

Public Functions¶

Type	Name
int	get_net_buf_size ()
void	net_arg_get_bigint (DB_BIGINT * value, void * arg)
void	net_arg_get_cache_time (void * ct, void * arg)
void	net_arg_get_cci_object (int * pageid, short * slotid, short * volid, void * arg)
void	net_arg_get_date (short * year, short * mon, short * day, void * arg)
void	net_arg_get_datetime (short * yr, short * mon, short * day, short * hh, short * mm, short * ss, short * ms, void * arg)
void	net_arg_get_datetimetz (short * yr, short * mon, short * day, short * hh, short * mm, short * ss, short * ms, char tz, int** * tz_size, void * arg)
void	net_arg_get_dbobject (DB_OBJECT obj, void** * arg)
void	net_arg_get_double (double * value, void * arg)
void	net_arg_get_float (float * value, void * arg)
void	net_arg_get_int (int * value, void * arg)
void	net_arg_get_lob_handle (T_LOB_HANDLE * lob, void * arg)
void	net_arg_get_lob_value (DB_VALUE * db_lob, void * arg)
void	net_arg_get_object (T_OBJECT * obj, void * arg)
void	net_arg_get_short (short * value, void * arg)
void	net_arg_get_size (int * size, void * arg)
void	net_arg_get_str (char value, int** * size, void * arg)
void	net_arg_get_time (short * hh, short * mm, short * ss, void * arg)
void	net_arg_get_timestamp (short * yr, short * mon, short * day, short * hh, short * mm, short * ss, void * arg)
void	net_arg_get_timestamptz (short * yr, short * mon, short * day, short * hh, short * mm, short * ss, char tz, int** * tz_size, void * arg)
void	net_arg_put_int (void * arg, int * value)
void	net_buf_clear (T_NET_BUF * net_buf)
void	net_buf_column_info_set (T_NET_BUF * net_buf, char ut, short scale, int prec, char charset, const char * name)
int	net_buf_cp_bigint (T_NET_BUF * net_buf, DB_BIGINT value, int * begin_offset)
int	net_buf_cp_byte (T_NET_BUF * net_buf, char ch)
int	net_buf_cp_cas_type_and_charset (T_NET_BUF * net_buf, unsigned char cas_type, unsigned char charset)
int	net_buf_cp_double (T_NET_BUF * net_buf, double value)
int	net_buf_cp_float (T_NET_BUF * net_buf, float value)
int	net_buf_cp_int (T_NET_BUF * net_buf, int value, int * begin_offset)
int	net_buf_cp_lob_handle (T_NET_BUF * net_buf, T_LOB_HANDLE * lob)
int	net_buf_cp_object (T_NET_BUF * net_buf, T_OBJECT * oid)
int	net_buf_cp_post_send_file (T_NET_BUF * net_buf, int size, char * filename)
int	net_buf_cp_short (T_NET_BUF * net_buf, short value)
int	net_buf_cp_str (T_NET_BUF * net_buf, const char * buf, int size)
void	net_buf_destroy (T_NET_BUF * net_buf)
void	net_buf_error_msg_set (T_NET_BUF * net_buf, int err_indicator, int err_code, char * err_str, const char * file, int line)
void	net_buf_init (T_NET_BUF * net_buf, T_BROKER_VERSION client_version)
void	net_buf_overwrite_bigint (T_NET_BUF * net_buf, int offset, DB_BIGINT value)
void	net_buf_overwrite_int (T_NET_BUF * net_buf, int offset, int value)
size_t	net_error_append_shard_info (char * err_buf, const char * err_msg, int buf_size)
double	net_htond (double from)
float	net_htonf (float from)
INT64	net_htoni64 (INT64 from)
void	set_net_buf_size ()

Public Static Functions¶

Type	Name
int	net_buf_realloc (T_NET_BUF * net_buf, int size)

Public Static Attributes Documentation¶

variable _net_buf_size¶

int _net_buf_size;

Public Functions Documentation¶

function get_net_buf_size¶

int get_net_buf_size ()

function net_arg_get_bigint¶

void net_arg_get_bigint (
    DB_BIGINT * value,
    void * arg
)

function net_arg_get_cache_time¶

void net_arg_get_cache_time (
    void * ct,
    void * arg
)

function net_arg_get_cci_object¶

void net_arg_get_cci_object (
    int * pageid,
    short * slotid,
    short * volid,
    void * arg
)

function net_arg_get_date¶

void net_arg_get_date (
    short * year,
    short * mon,
    short * day,
    void * arg
)

function net_arg_get_datetime¶

void net_arg_get_datetime (
    short * yr,
    short * mon,
    short * day,
    short * hh,
    short * mm,
    short * ss,
    short * ms,
    void * arg
)

function net_arg_get_datetimetz¶

void net_arg_get_datetimetz (
    short * yr,
    short * mon,
    short * day,
    short * hh,
    short * mm,
    short * ss,
    short * ms,
    char ** tz,
    int * tz_size,
    void * arg
)

function net_arg_get_dbobject¶

void net_arg_get_dbobject (
    DB_OBJECT ** obj,
    void * arg
)

function net_arg_get_double¶

void net_arg_get_double (
    double * value,
    void * arg
)

function net_arg_get_float¶

void net_arg_get_float (
    float * value,
    void * arg
)

function net_arg_get_int¶

void net_arg_get_int (
    int * value,
    void * arg
)

function net_arg_get_lob_handle¶

void net_arg_get_lob_handle (
    T_LOB_HANDLE * lob,
    void * arg
)

function net_arg_get_lob_value¶

void net_arg_get_lob_value (
    DB_VALUE * db_lob,
    void * arg
)

function net_arg_get_object¶

void net_arg_get_object (
    T_OBJECT * obj,
    void * arg
)

function net_arg_get_short¶

void net_arg_get_short (
    short * value,
    void * arg
)

function net_arg_get_size¶

void net_arg_get_size (
    int * size,
    void * arg
)

function net_arg_get_str¶

void net_arg_get_str (
    char ** value,
    int * size,
    void * arg
)

function net_arg_get_time¶

void net_arg_get_time (
    short * hh,
    short * mm,
    short * ss,
    void * arg
)

function net_arg_get_timestamp¶

void net_arg_get_timestamp (
    short * yr,
    short * mon,
    short * day,
    short * hh,
    short * mm,
    short * ss,
    void * arg
)

function net_arg_get_timestamptz¶

void net_arg_get_timestamptz (
    short * yr,
    short * mon,
    short * day,
    short * hh,
    short * mm,
    short * ss,
    char ** tz,
    int * tz_size,
    void * arg
)

function net_arg_put_int¶

void net_arg_put_int (
    void * arg,
    int * value
)

function net_buf_clear¶

void net_buf_clear (
    T_NET_BUF * net_buf
)

function net_buf_column_info_set¶

void net_buf_column_info_set (
    T_NET_BUF * net_buf,
    char ut,
    short scale,
    int prec,
    char charset,
    const  char * name
)

function net_buf_cp_bigint¶

int net_buf_cp_bigint (
    T_NET_BUF * net_buf,
    DB_BIGINT value,
    int * begin_offset
)

function net_buf_cp_byte¶

int net_buf_cp_byte (
    T_NET_BUF * net_buf,
    char ch
)

function net_buf_cp_cas_type_and_charset¶

int net_buf_cp_cas_type_and_charset (
    T_NET_BUF * net_buf,
    unsigned  char cas_type,
    unsigned  char charset
)

function net_buf_cp_double¶

int net_buf_cp_double (
    T_NET_BUF * net_buf,
    double value
)

function net_buf_cp_float¶

int net_buf_cp_float (
    T_NET_BUF * net_buf,
    float value
)

function net_buf_cp_int¶

int net_buf_cp_int (
    T_NET_BUF * net_buf,
    int value,
    int * begin_offset
)

function net_buf_cp_lob_handle¶

int net_buf_cp_lob_handle (
    T_NET_BUF * net_buf,
    T_LOB_HANDLE * lob
)

function net_buf_cp_object¶

int net_buf_cp_object (
    T_NET_BUF * net_buf,
    T_OBJECT * oid
)

function net_buf_cp_post_send_file¶

int net_buf_cp_post_send_file (
    T_NET_BUF * net_buf,
    int size,
    char * filename
)

function net_buf_cp_short¶

int net_buf_cp_short (
    T_NET_BUF * net_buf,
    short value
)

function net_buf_cp_str¶

int net_buf_cp_str (
    T_NET_BUF * net_buf,
    const  char * buf,
    int size
)

function net_buf_destroy¶

void net_buf_destroy (
    T_NET_BUF * net_buf
)

function net_buf_error_msg_set¶

void net_buf_error_msg_set (
    T_NET_BUF * net_buf,
    int err_indicator,
    int err_code,
    char * err_str,
    const  char * file,
    int line
)

function net_buf_init¶

void net_buf_init (
    T_NET_BUF * net_buf,
    T_BROKER_VERSION client_version
)

function net_buf_overwrite_bigint¶

void net_buf_overwrite_bigint (
    T_NET_BUF * net_buf,
    int offset,
    DB_BIGINT value
)

function net_buf_overwrite_int¶

void net_buf_overwrite_int (
    T_NET_BUF * net_buf,
    int offset,
    int value
)

function net_error_append_shard_info¶

size_t net_error_append_shard_info (
    char * err_buf,
    const  char * err_msg,
    int buf_size
)

function net_htond¶

double net_htond (
    double from
)

function net_htonf¶

float net_htonf (
    float from
)

function net_htoni64¶

INT64 net_htoni64 (
    INT64 from
)

function set_net_buf_size¶

void set_net_buf_size ()

Public Static Functions Documentation¶

function net_buf_realloc¶

static int net_buf_realloc (
    T_NET_BUF * net_buf,
    int size
)

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