File broker_admin_so.c¶

FileList > broker > broker_admin_so.c

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include "porting.h"
#include "cas_common.h"
#include "broker_admin_so.h"
#include "broker_filename.h"
#include "broker_config.h"
#include "broker_util.h"
#include "broker_admin_pub.h"
#include "broker_shm.h"
#include "broker_process_size.h"
#include "broker_process_info.h"

Public Functions¶

Type	Name
int	uc_add (const char * br_name, char * err_msg)
int	uc_as_info (const char * br_name, T_AS_INFO ret_as_info, T_JOB_INFO job_info, int * num_job, char * err_msg)
void *	uc_as_shm_open (void * shm_br, int br_index, char * err_msg)
int	uc_br_info (T_BR_INFO ret_br_info, char** * err_msg)
void *	uc_broker_shm_open (char * err_msg)
int	uc_cas_changer (const char * br_name, const char * name, const char * value, int as_number, char * err_msg)
void	uc_change_config (T_UC_CONF * unicas_conf, const char * br_name, const char * name, const char * value)
int	uc_changer (const char * br_name, const char * name, const char * value, char * err_msg)
int	uc_conf_broker_add (T_UC_CONF * unicas_conf, const char * br_name, char * err_msg)
int	uc_del_cas_log (const char * br_name, int asid, char * err_msg)
int	uc_drop (const char * br_name, char * err_msg)
int	uc_get_active_session_with_opened_shm (void * shm_p, char * err_msg)
int	uc_get_as_num_with_opened_shm (void * shm_br, int br_index, char * err_msg)
int	uc_get_as_query_processed_with_opened_shm (void * shm_as, long long array, int array_size, char * err_msg)
int	uc_get_as_reqs_received_with_opened_shm (void * shm_as, long long array, int array_size, char * err_msg)
int	uc_get_as_tran_processed_with_opened_shm (void * shm_as, long long array, int array_size, char * err_msg)
int	uc_get_br_name_with_opened_shm (void * shm_br, int br_index, char * name, int buffer_size, char * err_msg)
int	uc_get_br_num_with_opened_shm (void * shm_br, char * err_msg)
void	uc_info_free (void * info)
int	uc_off (const char * br_name, char * err_msg)
int	uc_on (const char * br_name, char * err_msg)
int	uc_restart (const char * br_name, int as_index, char * err_msg)
void	uc_shm_detach (void * p)
int	uc_start (char * err_msg)
int	uc_stop (char * err_msg)
int	uc_unicas_conf (T_UC_CONF * unicas_conf, int * ret_mst_shmid, char * err_msg)
void	uc_unicas_conf_free (T_UC_CONF * unicas_conf)
const char *	uc_version ()

Public Static Functions¶

Type	Name
int	admin_common (T_BROKER_INFO * br_info, int * num_broker, int * master_shm_id, char * admin_log_file, char * err_msg, char admin_flag, bool * acl_flag, char * acl_file, bool * acl_default_policy)
void	admin_log_write (const char * log_file, const char * msg)
void	change_conf_as_type (T_BR_CONF * br_conf, int old_as_type, int new_as_type)
int	conf_copy_broker (T_UC_CONF * unicas_conf, T_BROKER_INFO * br_conf, int num_br, char * err_msg)
int	conf_copy_header (T_UC_CONF * unicas_conf, int master_shm_id, char * admin_log_file, char * err_msg)
void	conf_item_free (T_UC_CONF_ITEM * conf_item, int num)
int	copy_job_info (T_JOB_INFO job_info, T_MAX_HEAP_NODE** * job_q)
int	get_as_type (const char * type_str)
const char *	get_as_type_str (char as_type)
char *	get_broker_name (T_BR_CONF * br_conf)
void	reset_conf_value (int num_item, T_UC_CONF_ITEM * item, const char * name)
int	uc_changer_internal (const char * br_name, const char * name, const char * value, int as_number, char * err_msg)

Macros¶

Type	Name
define	CHECK_SHARED_MEMORY (p_shm, err_msg) `/* multi line expression */`
define	CP_ADMIN_ERR_MSG (BUF) `[sprintf](broker__monitor_8c.md#function-timeout)([BUF](broker__monitor_8c.md#function-timeout), "Error: %[s"](broker__monitor_8c.md#function-timeout), [admin\_err\_msg](broker__admin__pub_8c.md#variable-admin_err_msg))`
define	FMT_D `"%d"`
define	FMT_X `"%X"`
define	MAX_NUM_CONF `35`
define	SET_CONF_ITEM (CONF_ITEM, IDX, NAME, VALUE) `/* multi line expression */`
define	SET_CONF_ITEM_INT (CONF_ITEM, IDX, NAME, VALUE, FMT) `/* multi line expression */`
define	SET_CONF_ITEM_KEEP_CON (CONF_ITEM, IDX, NAME, VALUE) `/* multi line expression */`
define	SET_CONF_ITEM_ONOFF (CONF_ITEM, IDX, NAME, VALUE) `/* multi line expression */`
define	SET_CONF_ITEM_SQL_LOG_MODE (CONF_ITEM, IDX, NAME, VALUE) `/* multi line expression */`
define	SET_CONF_ITEM_STR (CONF_ITEM, IDX, NAME, VALUE) `/* multi line expression */`
define	SET_FLAG (ONOFF) `(([ONOFF](broker__monitor_8c.md#function-timeout)) == [ON](cas__common_8h.md#define-on) ? [FLAG\_ON](broker__admin__so_8h.md#define-flag_on) : [FLAG\_OFF](broker__admin__so_8h.md#define-flag_off))`
define	UC_CONF_PARAM_ACCESS_LIST `"ACCESS\_LIST"`
define	UC_CONF_PARAM_ACCESS_LOG `"ACCESS\_LOG"`
define	UC_CONF_PARAM_ADMIN_LOG_FILE `"ADMIN\_LOG\_FILE"`
define	UC_CONF_PARAM_APPL_SERVER `"APPL\_SERVER"`
define	UC_CONF_PARAM_APPL_SERVER_HARD_LIMIT `"APPL\_SERVER\_MAX\_SIZE\_HARD\_LIMIT"`
define	UC_CONF_PARAM_APPL_SERVER_MAX_SIZE `"APPL\_SERVER\_MAX\_SIZE"`
define	UC_CONF_PARAM_APPL_SERVER_SHM_ID `"APPL\_SERVER\_SHM\_ID"`
define	UC_CONF_PARAM_AUTO_ADD_APPL_SERVER `"AUTO\_ADD\_APPL\_SERVER"`
define	UC_CONF_PARAM_BROKER_NAME `"%"`
define	UC_CONF_PARAM_BROKER_PORT `"BROKER\_PORT"`
define	UC_CONF_PARAM_ERROR_LOG_DIR `"ERROR\_LOG\_DIR"`
define	UC_CONF_PARAM_JOB_QUEUE_SIZE `"JOB\_QUEUE\_SIZE"`
define	UC_CONF_PARAM_KEEP_CONNECTION `"KEEP\_CONNECTION"`
define	UC_CONF_PARAM_LOG_BACKUP `"LOG\_BACKUP"`
define	UC_CONF_PARAM_LOG_DIR `"LOG\_DIR"`
define	UC_CONF_PARAM_LONG_QUERY_TIME `"LONG\_QUERY\_TIME"`
define	UC_CONF_PARAM_LONG_TRANSACTION_TIME `"LONG\_TRANSACTION\_TIME"`
define	UC_CONF_PARAM_MASTER_SHM_ID `"MASTER\_SHM\_ID"`
define	UC_CONF_PARAM_MAX_NUM_APPL_SERVER `"MAX\_NUM\_APPL\_SERVER"`
define	UC_CONF_PARAM_MAX_STRING_LENGTH `"MAX\_STRING\_LENGTH"`
define	UC_CONF_PARAM_MIN_NUM_APPL_SERVER `"MIN\_NUM\_APPL\_SERVER"`
define	UC_CONF_PARAM_SERVICE `"SERVICE"`
define	UC_CONF_PARAM_SESSION_TIMEOUT `"SESSION\_TIMEOUT"`
define	UC_CONF_PARAM_SLOW_LOG `"SLOW\_LOG"`
define	UC_CONF_PARAM_SLOW_LOG_DIR `"SLOW\_LOG\_DIR"`
define	UC_CONF_PARAM_SOURCE_ENV `"SOURCE\_ENV"`
define	UC_CONF_PARAM_SQL_LOG `"SQL\_LOG"`
define	UC_CONF_PARAM_SQL_LOG2 `"SQL\_LOG2"`
define	UC_CONF_PARAM_SQL_LOG_MAX_SIZE `"SQL\_LOG\_MAX\_SIZE"`
define	UC_CONF_PARAM_STRIPPED_COLUMN_NAME `"STRIPPED\_COLUMN\_NAME"`
define	UC_CONF_PARAM_TIME_TO_KILL `"TIME\_TO\_KILL"`

Public Functions Documentation¶

function uc_add¶

int uc_add (
    const  char * br_name,
    char * err_msg
)

function uc_as_info¶

int uc_as_info (
    const  char * br_name,
    T_AS_INFO ** ret_as_info,
    T_JOB_INFO ** job_info,
    int * num_job,
    char * err_msg
)

function uc_as_shm_open¶

void * uc_as_shm_open (
    void * shm_br,
    int br_index,
    char * err_msg
)

function uc_br_info¶

int uc_br_info (
    T_BR_INFO ** ret_br_info,
    char * err_msg
)

function uc_broker_shm_open¶

void * uc_broker_shm_open (
    char * err_msg
)

function uc_cas_changer¶

int uc_cas_changer (
    const  char * br_name,
    const  char * name,
    const  char * value,
    int as_number,
    char * err_msg
)

function uc_change_config¶

void uc_change_config (
    T_UC_CONF * unicas_conf,
    const  char * br_name,
    const  char * name,
    const  char * value
)

function uc_changer¶

int uc_changer (
    const  char * br_name,
    const  char * name,
    const  char * value,
    char * err_msg
)

function uc_conf_broker_add¶

int uc_conf_broker_add (
    T_UC_CONF * unicas_conf,
    const  char * br_name,
    char * err_msg
)

function uc_del_cas_log¶

int uc_del_cas_log (
    const  char * br_name,
    int asid,
    char * err_msg
)

function uc_drop¶

int uc_drop (
    const  char * br_name,
    char * err_msg
)

function uc_get_active_session_with_opened_shm¶

int uc_get_active_session_with_opened_shm (
    void * shm_p,
    char * err_msg
)

function uc_get_as_num_with_opened_shm¶

int uc_get_as_num_with_opened_shm (
    void * shm_br,
    int br_index,
    char * err_msg
)

function uc_get_as_query_processed_with_opened_shm¶

int uc_get_as_query_processed_with_opened_shm (
    void * shm_as,
    long  long array,
    int array_size,
    char * err_msg
)

function uc_get_as_reqs_received_with_opened_shm¶

int uc_get_as_reqs_received_with_opened_shm (
    void * shm_as,
    long  long array,
    int array_size,
    char * err_msg
)

function uc_get_as_tran_processed_with_opened_shm¶

int uc_get_as_tran_processed_with_opened_shm (
    void * shm_as,
    long  long array,
    int array_size,
    char * err_msg
)

function uc_get_br_name_with_opened_shm¶

int uc_get_br_name_with_opened_shm (
    void * shm_br,
    int br_index,
    char * name,
    int buffer_size,
    char * err_msg
)

function uc_get_br_num_with_opened_shm¶

int uc_get_br_num_with_opened_shm (
    void * shm_br,
    char * err_msg
)

function uc_info_free¶

void uc_info_free (
    void * info
)

function uc_off¶

int uc_off (
    const  char * br_name,
    char * err_msg
)

function uc_on¶

int uc_on (
    const  char * br_name,
    char * err_msg
)

function uc_restart¶

int uc_restart (
    const  char * br_name,
    int as_index,
    char * err_msg
)

function uc_shm_detach¶

void uc_shm_detach (
    void * p
)

function uc_start¶

int uc_start (
    char * err_msg
)

function uc_stop¶

int uc_stop (
    char * err_msg
)

function uc_unicas_conf¶

int uc_unicas_conf (
    T_UC_CONF * unicas_conf,
    int * ret_mst_shmid,
    char * err_msg
)

function uc_unicas_conf_free¶

void uc_unicas_conf_free (
    T_UC_CONF * unicas_conf
)

function uc_version¶

const  char * uc_version ()

Public Static Functions Documentation¶

function admin_common¶

static int admin_common (
    T_BROKER_INFO * br_info,
    int * num_broker,
    int * master_shm_id,
    char * admin_log_file,
    char * err_msg,
    char admin_flag,
    bool * acl_flag,
    char * acl_file,
    bool * acl_default_policy
)

function admin_log_write¶

static void admin_log_write (
    const  char * log_file,
    const  char * msg
)

function change_conf_as_type¶

static void change_conf_as_type (
    T_BR_CONF * br_conf,
    int old_as_type,
    int new_as_type
)

function conf_copy_broker¶

static int conf_copy_broker (
    T_UC_CONF * unicas_conf,
    T_BROKER_INFO * br_conf,
    int num_br,
    char * err_msg
)

function conf_copy_header¶

static int conf_copy_header (
    T_UC_CONF * unicas_conf,
    int master_shm_id,
    char * admin_log_file,
    char * err_msg
)

function conf_item_free¶

static void conf_item_free (
    T_UC_CONF_ITEM * conf_item,
    int num
)

function copy_job_info¶

static int copy_job_info (
    T_JOB_INFO ** job_info,
    T_MAX_HEAP_NODE * job_q
)

function get_as_type¶

static int get_as_type (
    const  char * type_str
)

function get_as_type_str¶

static const  char * get_as_type_str (
    char as_type
)

function get_broker_name¶

static char * get_broker_name (
    T_BR_CONF * br_conf
)

function reset_conf_value¶

static void reset_conf_value (
    int num_item,
    T_UC_CONF_ITEM * item,
    const  char * name
)

function uc_changer_internal¶

static int uc_changer_internal (
    const  char * br_name,
    const  char * name,
    const  char * value,
    int as_number,
    char * err_msg
)

Macro Definition Documentation¶

define CHECK_SHARED_MEMORY¶

#define CHECK_SHARED_MEMORY (
    p_shm,
    err_msg
) `/* multi line expression */`

define CP_ADMIN_ERR_MSG¶

#define CP_ADMIN_ERR_MSG (
    BUF
) `sprintf ( BUF , "Error: % s" , admin_err_msg )`

define FMT_D¶

#define FMT_D `"%d"`

define FMT_X¶

#define FMT_X `"%X"`

define MAX_NUM_CONF¶

#define MAX_NUM_CONF `35`

define SET_CONF_ITEM¶

#define SET_CONF_ITEM (
    CONF_ITEM,
    IDX,
    NAME,
    VALUE
) `/* multi line expression */`

define SET_CONF_ITEM_INT¶

#define SET_CONF_ITEM_INT (
    CONF_ITEM,
    IDX,
    NAME,
    VALUE,
    FMT
) `/* multi line expression */`

define SET_CONF_ITEM_KEEP_CON¶

#define SET_CONF_ITEM_KEEP_CON (
    CONF_ITEM,
    IDX,
    NAME,
    VALUE
) `/* multi line expression */`

define SET_CONF_ITEM_ONOFF¶

#define SET_CONF_ITEM_ONOFF (
    CONF_ITEM,
    IDX,
    NAME,
    VALUE
) `/* multi line expression */`

define SET_CONF_ITEM_SQL_LOG_MODE¶

#define SET_CONF_ITEM_SQL_LOG_MODE (
    CONF_ITEM,
    IDX,
    NAME,
    VALUE
) `/* multi line expression */`

define SET_CONF_ITEM_STR¶

#define SET_CONF_ITEM_STR (
    CONF_ITEM,
    IDX,
    NAME,
    VALUE
) `/* multi line expression */`

define SET_FLAG¶

#define SET_FLAG (
    ONOFF
) `(( ONOFF ) == ON ? FLAG_ON : FLAG_OFF )`

define UC_CONF_PARAM_ACCESS_LIST¶

#define UC_CONF_PARAM_ACCESS_LIST `"ACCESS_LIST"`

define UC_CONF_PARAM_ACCESS_LOG¶

#define UC_CONF_PARAM_ACCESS_LOG `"ACCESS_LOG"`

define UC_CONF_PARAM_ADMIN_LOG_FILE¶

#define UC_CONF_PARAM_ADMIN_LOG_FILE `"ADMIN_LOG_FILE"`

define UC_CONF_PARAM_APPL_SERVER¶

#define UC_CONF_PARAM_APPL_SERVER `"APPL_SERVER"`

define UC_CONF_PARAM_APPL_SERVER_HARD_LIMIT¶

#define UC_CONF_PARAM_APPL_SERVER_HARD_LIMIT `"APPL_SERVER_MAX_SIZE_HARD_LIMIT"`

define UC_CONF_PARAM_APPL_SERVER_MAX_SIZE¶

#define UC_CONF_PARAM_APPL_SERVER_MAX_SIZE `"APPL_SERVER_MAX_SIZE"`

define UC_CONF_PARAM_APPL_SERVER_SHM_ID¶

#define UC_CONF_PARAM_APPL_SERVER_SHM_ID `"APPL_SERVER_SHM_ID"`

define UC_CONF_PARAM_AUTO_ADD_APPL_SERVER¶

#define UC_CONF_PARAM_AUTO_ADD_APPL_SERVER `"AUTO_ADD_APPL_SERVER"`

define UC_CONF_PARAM_BROKER_NAME¶

#define UC_CONF_PARAM_BROKER_NAME `"%"`

define UC_CONF_PARAM_BROKER_PORT¶

#define UC_CONF_PARAM_BROKER_PORT `"BROKER_PORT"`

define UC_CONF_PARAM_ERROR_LOG_DIR¶

#define UC_CONF_PARAM_ERROR_LOG_DIR `"ERROR_LOG_DIR"`

define UC_CONF_PARAM_JOB_QUEUE_SIZE¶

#define UC_CONF_PARAM_JOB_QUEUE_SIZE `"JOB_QUEUE_SIZE"`

define UC_CONF_PARAM_KEEP_CONNECTION¶

#define UC_CONF_PARAM_KEEP_CONNECTION `"KEEP_CONNECTION"`

define UC_CONF_PARAM_LOG_BACKUP¶

#define UC_CONF_PARAM_LOG_BACKUP `"LOG_BACKUP"`

define UC_CONF_PARAM_LOG_DIR¶

#define UC_CONF_PARAM_LOG_DIR `"LOG_DIR"`

define UC_CONF_PARAM_LONG_QUERY_TIME¶

#define UC_CONF_PARAM_LONG_QUERY_TIME `"LONG_QUERY_TIME"`

define UC_CONF_PARAM_LONG_TRANSACTION_TIME¶

#define UC_CONF_PARAM_LONG_TRANSACTION_TIME `"LONG_TRANSACTION_TIME"`

define UC_CONF_PARAM_MASTER_SHM_ID¶

#define UC_CONF_PARAM_MASTER_SHM_ID `"MASTER_SHM_ID"`

define UC_CONF_PARAM_MAX_NUM_APPL_SERVER¶

#define UC_CONF_PARAM_MAX_NUM_APPL_SERVER `"MAX_NUM_APPL_SERVER"`

define UC_CONF_PARAM_MAX_STRING_LENGTH¶

#define UC_CONF_PARAM_MAX_STRING_LENGTH `"MAX_STRING_LENGTH"`

define UC_CONF_PARAM_MIN_NUM_APPL_SERVER¶

#define UC_CONF_PARAM_MIN_NUM_APPL_SERVER `"MIN_NUM_APPL_SERVER"`

define UC_CONF_PARAM_SERVICE¶

#define UC_CONF_PARAM_SERVICE `"SERVICE"`

define UC_CONF_PARAM_SESSION_TIMEOUT¶

#define UC_CONF_PARAM_SESSION_TIMEOUT `"SESSION_TIMEOUT"`

define UC_CONF_PARAM_SLOW_LOG¶

#define UC_CONF_PARAM_SLOW_LOG `"SLOW_LOG"`

define UC_CONF_PARAM_SLOW_LOG_DIR¶

#define UC_CONF_PARAM_SLOW_LOG_DIR `"SLOW_LOG_DIR"`

define UC_CONF_PARAM_SOURCE_ENV¶

#define UC_CONF_PARAM_SOURCE_ENV `"SOURCE_ENV"`

define UC_CONF_PARAM_SQL_LOG¶

#define UC_CONF_PARAM_SQL_LOG `"SQL_LOG"`

define UC_CONF_PARAM_SQL_LOG2¶

#define UC_CONF_PARAM_SQL_LOG2 `"SQL_LOG2"`

define UC_CONF_PARAM_SQL_LOG_MAX_SIZE¶

#define UC_CONF_PARAM_SQL_LOG_MAX_SIZE `"SQL_LOG_MAX_SIZE"`

define UC_CONF_PARAM_STRIPPED_COLUMN_NAME¶

#define UC_CONF_PARAM_STRIPPED_COLUMN_NAME `"STRIPPED_COLUMN_NAME"`

define UC_CONF_PARAM_TIME_TO_KILL¶

#define UC_CONF_PARAM_TIME_TO_KILL `"TIME_TO_KILL"`

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