Skip to content

File broker_util.h

FileList > broker > broker_util.h

Go to the source code of this file

  • #include <time.h>
  • #include "cas_common.h"
  • #include "porting.h"

Public Functions

Type Name
void as_db_err_log_set (char * br_name, int proxy_index, int shard_id, int shard_cas_id, int as_index, int shard_flag)
void as_pid_file_create (char * br_name, int as_index)
int ut_access_log (int as_index, struct timeval * start_time, char err_flag, int e_offset)
void ut_cd_root_dir (void)
void ut_cd_work_dir (void)
int ut_file_lock (char * lock_file)
void ut_file_unlock (char * lock_file)
void ut_get_as_pid_name (char * pid_name, char * br_name, int as_index, int len)
void ut_get_as_port_name (char * port_name, char * broker_name, int as_id, int len)
float ut_get_avg_from_array (int array, int size)
void ut_get_broker_port_name (char * port_name, char * broker_name, int len)
char * ut_get_ipv4_string (char * ip_str, int len, const unsigned char * ip_addr)
void ut_get_proxy_port_name (char * port_name, char * broker_name, int proxy_id, int len)
bool ut_is_appl_server_ready (int pid, char * ready_flag)
int ut_kill_as_process (int pid, char * br_name, int as_id, int shard_flag)
int ut_kill_broker_process (int pid, char * br_name)
int ut_kill_process (int pid)
int ut_kill_proxy_process (int pid, char * br_name, int proxy_id)
int ut_set_keepalive (int sock)
double ut_size_string_to_kbyte (const char * size_str, const char * default_unit)
int ut_time_string (char * buf, struct timeval * log_time)
double ut_time_string_to_sec (const char * time_str, const char * default_unit)

Macros

Type Name
define CAS_INVALID_ID ([**PROXY\_INVALID\_CAS**](broker__util_8h.md#define-proxy_invalid_cas))
define MAKE_FILEPATH (dest, src, dest_len) /* multi line expression */
define PROXY_INVALID_CAS ([**PROXY\_INVALID\_ID**](broker__util_8h.md#define-proxy_invalid_id))
define PROXY_INVALID_ID (-1)
define PROXY_INVALID_SHARD ([**PROXY\_INVALID\_ID**](broker__util_8h.md#define-proxy_invalid_id))
define SERVICE_READY_WAIT_COUNT 6000
define SHARD_INVALID_ID ([**PROXY\_INVALID\_SHARD**](broker__util_8h.md#define-proxy_invalid_shard))

Public Functions Documentation

function as_db_err_log_set

void as_db_err_log_set (
    char * br_name,
    int proxy_index,
    int shard_id,
    int shard_cas_id,
    int as_index,
    int shard_flag
) 

function as_pid_file_create

void as_pid_file_create (
    char * br_name,
    int as_index
) 

function ut_access_log

int ut_access_log (
    int as_index,
    struct  timeval * start_time,
    char err_flag,
    int e_offset
) 

function ut_cd_root_dir

void ut_cd_root_dir (
    void
) 

function ut_cd_work_dir

void ut_cd_work_dir (
    void
) 

function ut_file_lock

int ut_file_lock (
    char * lock_file
) 

function ut_file_unlock

void ut_file_unlock (
    char * lock_file
) 

function ut_get_as_pid_name

void ut_get_as_pid_name (
    char * pid_name,
    char * br_name,
    int as_index,
    int len
) 

function ut_get_as_port_name

void ut_get_as_port_name (
    char * port_name,
    char * broker_name,
    int as_id,
    int len
) 

function ut_get_avg_from_array

float ut_get_avg_from_array (
    int array,
    int size
) 

function ut_get_broker_port_name

void ut_get_broker_port_name (
    char * port_name,
    char * broker_name,
    int len
) 

function ut_get_ipv4_string

char * ut_get_ipv4_string (
    char * ip_str,
    int len,
    const  unsigned  char * ip_addr
) 

function ut_get_proxy_port_name

void ut_get_proxy_port_name (
    char * port_name,
    char * broker_name,
    int proxy_id,
    int len
) 

function ut_is_appl_server_ready

bool ut_is_appl_server_ready (
    int pid,
    char * ready_flag
) 

function ut_kill_as_process

int ut_kill_as_process (
    int pid,
    char * br_name,
    int as_id,
    int shard_flag
) 

function ut_kill_broker_process

int ut_kill_broker_process (
    int pid,
    char * br_name
) 

function ut_kill_process

int ut_kill_process (
    int pid
) 

function ut_kill_proxy_process

int ut_kill_proxy_process (
    int pid,
    char * br_name,
    int proxy_id
) 

function ut_set_keepalive

int ut_set_keepalive (
    int sock
) 

function ut_size_string_to_kbyte

double ut_size_string_to_kbyte (
    const  char * size_str,
    const  char * default_unit
) 

function ut_time_string

int ut_time_string (
    char * buf,
    struct  timeval * log_time
) 

function ut_time_string_to_sec

double ut_time_string_to_sec (
    const  char * time_str,
    const  char * default_unit
) 

Macro Definition Documentation

define CAS_INVALID_ID

#define CAS_INVALID_ID `( PROXY_INVALID_CAS )`

define MAKE_FILEPATH

#define MAKE_FILEPATH (
    dest,
    src,
    dest_len
) `/* multi line expression */`

define PROXY_INVALID_CAS

#define PROXY_INVALID_CAS `( PROXY_INVALID_ID )`

define PROXY_INVALID_ID

#define PROXY_INVALID_ID `(-1)`

define PROXY_INVALID_SHARD

#define PROXY_INVALID_SHARD `( PROXY_INVALID_ID )`

define SERVICE_READY_WAIT_COUNT

#define SERVICE_READY_WAIT_COUNT `6000`

define SHARD_INVALID_ID

#define SHARD_INVALID_ID `( PROXY_INVALID_SHARD )`


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