File broker_admin_pub.c¶

FileList > broker > broker_admin_pub.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <signal.h>
#include <time.h>
#include <errno.h>
#include <assert.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <math.h>
#include "porting.h"
#include "tcp.h"
#include "cas_common.h"
#include "broker_shm.h"
#include "shard_metadata.h"
#include "shard_shm.h"
#include "shard_key_func.h"
#include "broker_util.h"
#include "broker_env_def.h"
#include "broker_process_size.h"
#include "broker_admin_pub.h"
#include "broker_filename.h"
#include "broker_error.h"
#include "cas_sql_log2.h"
#include "broker_acl.h"
#include "chartype.h"
#include "cubrid_getopt.h"
#include "dbtype_def.h"
#include "host_lookup.h"
#include "system_parameter.h"

Public Attributes¶

Type	Name
char	admin_err_msg
char **	environ
T_SHM_PROXY *	shm_proxy_p = `[NULL](freelistheap_8h.md#define-null)`

Public Static Attributes¶

Type	Name
char	shard_db_password_env_str

Public Functions¶

Type	Name
int	admin_acl_reload_cmd (int master_shm_id, const char * broker_name)
int	admin_acl_status_cmd (int master_shm_id, const char * broker_name)
int	admin_add_cmd (int master_shm_id, const char * broker)
int	admin_conf_change (int master_shm_id, const char * br_name, const char * conf_name, const char * conf_value, int as_number)
int	admin_del_cas_log (int master_shmid, const char * broker, int asid)
int	admin_drop_cmd (int master_shm_id, const char * broker)
int	admin_getid_cmd (int master_shm_id, int argc, const char ** argv)
int	admin_info_cmd (int master_shm_id)
void	admin_init_env ()
int	admin_isstarted_cmd (int master_shm_id)
int	admin_off_cmd (int master_shm_id, const char * broker_name)
int	admin_on_cmd (int master_shm_id, const char * broker_name)
int	admin_reset_cmd (int master_shm_id, const char * broker_name)
int	admin_restart_cmd (int master_shm_id, const char * broker, int as_index)
int	admin_start_cmd (T_BROKER_INFO * br_info, int br_num, int master_shm_id, bool acl_flag, char * acl_file, bool acl_default_policy, char * admin_log_file)
int	admin_stop_cmd (int master_shm_id)

Public Static Functions¶

Type	Name
void	as_activate (T_SHM_BROKER * shm_br, T_BROKER_INFO * br_info, T_SHM_APPL_SERVER * shm_as_p, T_APPL_SERVER_INFO * as_info_p, int as_idex, char env, int** env_num)
void	as_inactivate (T_APPL_SERVER_INFO * as_info_p, char * broker_name, int shard_flag)
int	br_activate (T_BROKER_INFO * br_info, int master_shm_id, T_SHM_BROKER * shm_br)
int	br_inactivate (T_BROKER_INFO * br_info)
int	broker_create_dir (const char * new_dir)
int	check_shard_as_conn (T_SHM_APPL_SERVER * shm_as_p, T_SHARD_INFO * shard_info_p)
int	check_shard_conn (T_SHM_APPL_SERVER * shm_as_p, T_SHM_PROXY * shm_proxy_p)
void	free_env (char env, int** env_num)
int	get_cubrid_version (void)
void	get_shard_db_password (T_BROKER_INFO * br_info_p)
void	get_upper_str (char * upper_str, int size, const char * value)
bool	key_isdigit (const char * value)
char **	make_env (char * env_file, int * env_num)
int	make_sp_value (SP_VALUE * value_p, char * shard_key)
void	print_usage (void)
int	proxy_activate (T_BROKER_INFO * br_info_p, T_SHM_PROXY * shm_proxy_p, T_SHM_APPL_SERVER * shm_as_p, char env, int** env_num)
int	proxy_activate_internal (int proxy_shm_id, T_SHM_APPL_SERVER * shm_as_p, T_SHM_PROXY * shm_proxy_p, int proxy_id, char env, int** env_num)
void	proxy_inactivate (T_BROKER_INFO * br_info_p, T_PROXY_INFO * proxy_info_p)
void	rename_error_log_file_name (char * error_log_file, struct tm * ct)
int	shard_shm_check_max_file_open_limit (T_BROKER_INFO * br_info, T_SHM_PROXY * proxy_p)
int	shard_shm_set_param_as (T_PROXY_INFO * proxy_info_p, T_SHARD_INFO * shard_info_p, const char * param_name, const char * param_value, int as_number)
int	shard_shm_set_param_as_in_proxy (T_SHM_PROXY * proxy_p, const char * param_name, const char * param_value, int proxy_id, int shard_id, int as_number)
int	shard_shm_set_param_as_in_shard (T_PROXY_INFO * proxy_info_p, const char * param_name, const char * param_value, int shard_id, int as_number)
int	shard_shm_set_param_as_internal (T_APPL_SERVER_INFO * as_info, const char * param_name, const char * param_value)
int	shard_shm_set_param_proxy (T_SHM_PROXY * proxy_p, const char * param_name, const char * param_value, int proxy_id)
int	shard_shm_set_param_proxy_internal (T_PROXY_INFO * proxy_info_p, const char * param_name, const char * param_value)
int	shard_shm_set_param_shard (T_PROXY_INFO * proxy_info_p, const char * param_name, const char * param_value, int shard_id)
int	shard_shm_set_param_shard_in_proxy (T_SHM_PROXY * proxy_p, const char * param_name, const char * param_value, int proxy_id, int shard_id)
int	shard_shm_set_param_shard_internal (T_SHARD_CONN_INFO * shard_conn_info_p, const char * param_name, const char * param_value)

Macros¶

Type	Name
define	ADMIN_ERR_MSG_SIZE `[BROKER\_PATH\_MAX](broker__config_8h.md#define-broker_path_max) \* 2`
define	ALL_AS `-1`
define	ALL_PROXY `-1`
define	ALL_SHARD `-1`
define	MAKE_VERSION (MAJOR, MINOR) `((([MAJOR](broker__monitor_8c.md#function-timeout)) << 8) \\| ([MINOR](broker__monitor_8c.md#function-timeout)))`
define	MEMBER_SIZE (TYPE, MEMBER) `(([int](broker__monitor_8c.md#function-timeout)) [sizeof](broker__monitor_8c.md#function-timeout)((([TYPE](broker__monitor_8c.md#function-timeout) \)0)->[MEMBER*](broker__monitor_8c.md#function-timeout)))`
define	NUM_OF_DIGITS (NUMBER) `([int](broker__monitor_8c.md#function-timeout))[log10](broker__monitor_8c.md#function-timeout)([NUMBER](broker__monitor_8c.md#function-timeout)) + 1`
define	SHM_OPEN_ERR_MSG (BUF, ERRCODE, OSERRCODE) `/* multi line expression */`

Public Attributes Documentation¶

variable admin_err_msg¶

char admin_err_msg[(PATH_MAX) *2];

variable environ¶

char** environ;

variable shm_proxy_p¶

T_SHM_PROXY* shm_proxy_p;

Public Static Attributes Documentation¶

variable shard_db_password_env_str¶

char shard_db_password_env_str[50][128];

Public Functions Documentation¶

function admin_acl_reload_cmd¶

int admin_acl_reload_cmd (
    int master_shm_id,
    const  char * broker_name
)

function admin_acl_status_cmd¶

int admin_acl_status_cmd (
    int master_shm_id,
    const  char * broker_name
)

function admin_add_cmd¶

int admin_add_cmd (
    int master_shm_id,
    const  char * broker
)

function admin_conf_change¶

int admin_conf_change (
    int master_shm_id,
    const  char * br_name,
    const  char * conf_name,
    const  char * conf_value,
    int as_number
)

function admin_del_cas_log¶

int admin_del_cas_log (
    int master_shmid,
    const  char * broker,
    int asid
)

function admin_drop_cmd¶

int admin_drop_cmd (
    int master_shm_id,
    const  char * broker
)

function admin_getid_cmd¶

int admin_getid_cmd (
    int master_shm_id,
    int argc,
    const  char ** argv
)

function admin_info_cmd¶

int admin_info_cmd (
    int master_shm_id
)

function admin_init_env¶

void admin_init_env ()

function admin_isstarted_cmd¶

int admin_isstarted_cmd (
    int master_shm_id
)

function admin_off_cmd¶

int admin_off_cmd (
    int master_shm_id,
    const  char * broker_name
)

function admin_on_cmd¶

int admin_on_cmd (
    int master_shm_id,
    const  char * broker_name
)

function admin_reset_cmd¶

int admin_reset_cmd (
    int master_shm_id,
    const  char * broker_name
)

function admin_restart_cmd¶

int admin_restart_cmd (
    int master_shm_id,
    const  char * broker,
    int as_index
)

function admin_start_cmd¶

int admin_start_cmd (
    T_BROKER_INFO * br_info,
    int br_num,
    int master_shm_id,
    bool acl_flag,
    char * acl_file,
    bool acl_default_policy,
    char * admin_log_file
)

function admin_stop_cmd¶

int admin_stop_cmd (
    int master_shm_id
)

Public Static Functions Documentation¶

function as_activate¶

static void as_activate (
    T_SHM_BROKER * shm_br,
    T_BROKER_INFO * br_info,
    T_SHM_APPL_SERVER * shm_as_p,
    T_APPL_SERVER_INFO * as_info_p,
    int as_idex,
    char ** env,
    int env_num
)

function as_inactivate¶

static void as_inactivate (
    T_APPL_SERVER_INFO * as_info_p,
    char * broker_name,
    int shard_flag
)

function br_activate¶

static int br_activate (
    T_BROKER_INFO * br_info,
    int master_shm_id,
    T_SHM_BROKER * shm_br
)

function br_inactivate¶

static int br_inactivate (
    T_BROKER_INFO * br_info
)

function broker_create_dir¶

static int broker_create_dir (
    const  char * new_dir
)

function check_shard_as_conn¶

static int check_shard_as_conn (
    T_SHM_APPL_SERVER * shm_as_p,
    T_SHARD_INFO * shard_info_p
)

function check_shard_conn¶

static int check_shard_conn (
    T_SHM_APPL_SERVER * shm_as_p,
    T_SHM_PROXY * shm_proxy_p
)

function free_env¶

static void free_env (
    char ** env,
    int env_num
)

function get_cubrid_version¶

static int get_cubrid_version (
    void
)

function get_shard_db_password¶

static void get_shard_db_password (
    T_BROKER_INFO * br_info_p
)

function get_upper_str¶

static void get_upper_str (
    char * upper_str,
    int size,
    const  char * value
)

function key_isdigit¶

static bool key_isdigit (
    const  char * value
)

function make_env¶

static char ** make_env (
    char * env_file,
    int * env_num
)

function make_sp_value¶

static int make_sp_value (
    SP_VALUE * value_p,
    char * shard_key
)

function print_usage¶

static void print_usage (
    void
)

function proxy_activate¶

static int proxy_activate (
    T_BROKER_INFO * br_info_p,
    T_SHM_PROXY * shm_proxy_p,
    T_SHM_APPL_SERVER * shm_as_p,
    char ** env,
    int env_num
)

function proxy_activate_internal¶

static int proxy_activate_internal (
    int proxy_shm_id,
    T_SHM_APPL_SERVER * shm_as_p,
    T_SHM_PROXY * shm_proxy_p,
    int proxy_id,
    char ** env,
    int env_num
)

function proxy_inactivate¶

static void proxy_inactivate (
    T_BROKER_INFO * br_info_p,
    T_PROXY_INFO * proxy_info_p
)

function rename_error_log_file_name¶

static void rename_error_log_file_name (
    char * error_log_file,
    struct  tm * ct
)

function shard_shm_check_max_file_open_limit¶

static int shard_shm_check_max_file_open_limit (
    T_BROKER_INFO * br_info,
    T_SHM_PROXY * proxy_p
)

function shard_shm_set_param_as¶

static int shard_shm_set_param_as (
    T_PROXY_INFO * proxy_info_p,
    T_SHARD_INFO * shard_info_p,
    const  char * param_name,
    const  char * param_value,
    int as_number
)

function shard_shm_set_param_as_in_proxy¶

static int shard_shm_set_param_as_in_proxy (
    T_SHM_PROXY * proxy_p,
    const  char * param_name,
    const  char * param_value,
    int proxy_id,
    int shard_id,
    int as_number
)

function shard_shm_set_param_as_in_shard¶

static int shard_shm_set_param_as_in_shard (
    T_PROXY_INFO * proxy_info_p,
    const  char * param_name,
    const  char * param_value,
    int shard_id,
    int as_number
)

function shard_shm_set_param_as_internal¶

static int shard_shm_set_param_as_internal (
    T_APPL_SERVER_INFO * as_info,
    const  char * param_name,
    const  char * param_value
)

function shard_shm_set_param_proxy¶

static int shard_shm_set_param_proxy (
    T_SHM_PROXY * proxy_p,
    const  char * param_name,
    const  char * param_value,
    int proxy_id
)

function shard_shm_set_param_proxy_internal¶

static int shard_shm_set_param_proxy_internal (
    T_PROXY_INFO * proxy_info_p,
    const  char * param_name,
    const  char * param_value
)

function shard_shm_set_param_shard¶

static int shard_shm_set_param_shard (
    T_PROXY_INFO * proxy_info_p,
    const  char * param_name,
    const  char * param_value,
    int shard_id
)

function shard_shm_set_param_shard_in_proxy¶

static int shard_shm_set_param_shard_in_proxy (
    T_SHM_PROXY * proxy_p,
    const  char * param_name,
    const  char * param_value,
    int proxy_id,
    int shard_id
)

function shard_shm_set_param_shard_internal¶

static int shard_shm_set_param_shard_internal (
    T_SHARD_CONN_INFO * shard_conn_info_p,
    const  char * param_name,
    const  char * param_value
)

Macro Definition Documentation¶

define ADMIN_ERR_MSG_SIZE¶

#define ADMIN_ERR_MSG_SIZE `BROKER_PATH_MAX * 2`

define ALL_AS¶

#define ALL_AS `-1`

define ALL_PROXY¶

#define ALL_PROXY `-1`

define ALL_SHARD¶

#define ALL_SHARD `-1`

define MAKE_VERSION¶

#define MAKE_VERSION (
    MAJOR,
    MINOR
) `((( MAJOR ) << 8) | ( MINOR ))`

define MEMBER_SIZE¶

#define MEMBER_SIZE (
    TYPE,
    MEMBER
) `(( int ) sizeof ((( TYPE *)0)-> MEMBER ))`

define NUM_OF_DIGITS¶

#define NUM_OF_DIGITS (
    NUMBER
) `( int ) log10 ( NUMBER ) + 1`

define SHM_OPEN_ERR_MSG¶

#define SHM_OPEN_ERR_MSG (
    BUF,
    ERRCODE,
    OSERRCODE
) `/* multi line expression */`

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