File cas_network.c¶

FileList > broker > cas_network.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <errno.h>
#include <assert.h>
#include <sys/time.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/un.h>
#include <poll.h>
#include "porting.h"
#include "cas_common.h"
#include "cas_common_vars.h"
#include "cas_network.h"
#include "cas_error.h"
#include "cas_protocol.h"
#include "broker_config.h"
#include "broker_shm.h"
#include "error_code.h"
#include "broker_util.h"
#include "cas_ssl.h"

Public Static Attributes¶

Type	Name
char	net_error_flag
int	net_timeout = `60`
bool	net_timeout_flag = `[false](broker__monitor_8c.md#function-timeout)`

Public Functions¶

Type	Name
void	init_msg_header (MSG_HEADER * header)
bool	is_net_timed_out (void)
SOCKET	net_connect_client (SOCKET srv_sock_fd)
SOCKET	net_connect_proxy (void)
int	net_decode_str (char * msg, int msg_size, char * func_code, void *** ret_argv)
SOCKET	net_init_env (char * port_name)
int	net_read_header (SOCKET sock_fd, MSG_HEADER * header)
int	net_read_int (SOCKET sock_fd, int * value)
int	net_read_stream (SOCKET sock_fd, char * buf, int size)
int	net_read_to_file (SOCKET sock_fd, int file_size, char * filename)
void	net_timeout_set (int timeout_sec)
void	net_write_error (SOCKET sock, int version, char * driver_info, char * cas_info, int cas_info_size, int indicator, int code, const char * msg)
int	net_write_from_file (SOCKET sock_fd, int file_size, char * filename)
int	net_write_header (SOCKET sock_fd, MSG_HEADER * header)
int	net_write_int (SOCKET sock_fd, int value)
int	net_write_stream (SOCKET sock_fd, const char * buf, int size)

Public Static Functions¶

Type	Name
int	read_buffer (SOCKET sock_fd, char * buf, int size)
void	set_net_timeout_flag (void)
void	unset_net_timeout_flag (void)
int	write_buffer (SOCKET sock_fd, const char * buf, int size)

Macros¶

Type	Name
define	READ_FROM_NET (sd, buf, size) `/* multi line expression */`
define	SELECT_MASK `[fd\_set](broker__monitor_8c.md#function-timeout)`
define	WRITE_TO_NET (sd, buf, size) `/* multi line expression */`

Public Static Attributes Documentation¶

variable net_error_flag¶

char net_error_flag;

variable net_timeout¶

int net_timeout;

variable net_timeout_flag¶

bool net_timeout_flag;

Public Functions Documentation¶

function init_msg_header¶

void init_msg_header (
    MSG_HEADER * header
)

function is_net_timed_out¶

bool is_net_timed_out (
    void
)

function net_connect_client¶

SOCKET net_connect_client (
    SOCKET srv_sock_fd
)

function net_connect_proxy¶

SOCKET net_connect_proxy (
    void
)

function net_decode_str¶

int net_decode_str (
    char * msg,
    int msg_size,
    char * func_code,
    void *** ret_argv
)

function net_init_env¶

SOCKET net_init_env (
    char * port_name
)

function net_read_header¶

int net_read_header (
    SOCKET sock_fd,
    MSG_HEADER * header
)

function net_read_int¶

int net_read_int (
    SOCKET sock_fd,
    int * value
)

function net_read_stream¶

int net_read_stream (
    SOCKET sock_fd,
    char * buf,
    int size
)

function net_read_to_file¶

int net_read_to_file (
    SOCKET sock_fd,
    int file_size,
    char * filename
)

function net_timeout_set¶

void net_timeout_set (
    int timeout_sec
)

function net_write_error¶

void net_write_error (
    SOCKET sock,
    int version,
    char * driver_info,
    char * cas_info,
    int cas_info_size,
    int indicator,
    int code,
    const  char * msg
)

function net_write_from_file¶

int net_write_from_file (
    SOCKET sock_fd,
    int file_size,
    char * filename
)

function net_write_header¶

int net_write_header (
    SOCKET sock_fd,
    MSG_HEADER * header
)

function net_write_int¶

int net_write_int (
    SOCKET sock_fd,
    int value
)

function net_write_stream¶

int net_write_stream (
    SOCKET sock_fd,
    const  char * buf,
    int size
)

Public Static Functions Documentation¶

function read_buffer¶

static int read_buffer (
    SOCKET sock_fd,
    char * buf,
    int size
)

function set_net_timeout_flag¶

static void set_net_timeout_flag (
    void
)

function unset_net_timeout_flag¶

static void unset_net_timeout_flag (
    void
)

function write_buffer¶

static int write_buffer (
    SOCKET sock_fd,
    const  char * buf,
    int size
)

Macro Definition Documentation¶

define READ_FROM_NET¶

#define READ_FROM_NET (
    sd,
    buf,
    size
) `ssl_client ? cas_ssl_read ( sd , buf, size) : \ READ_FROM_SOCKET ( sd , buf, size)`

define SELECT_MASK¶

#define SELECT_MASK `fd_set`

define WRITE_TO_NET¶

#define WRITE_TO_NET (
    sd,
    buf,
    size
) `ssl_client ? cas_ssl_write ( sd , buf, size) : \ WRITE_TO_SOCKET ( sd , buf, size)`

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