File commdb.c¶

FileList > cubrid > src > executables > commdb.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <assert.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <unistd.h>
#include "connection_defs.h"
#include "client_support.h"
#include "error_manager.h"
#include "porting.h"
#include "heartbeat.h"
#include "master_util.h"
#include "message_catalog.h"
#include "utility.h"
#include "util_support.h"
#include "cubrid_getopt.h"

Public Types¶

Type	Name
enum	COMM_SERVER_TYPE

Public Static Attributes¶

Type	Name
bool	commdb_Arg_activate_heartbeat = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_deact_confirm_no_server = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_deact_confirm_stop_all = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_deact_immediately = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_deact_stop_all = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_deactivate_heartbeat = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_ha_deregister_args = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_ha_deregister_by_args = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_ha_deregister_by_pid = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_ha_deregister_pid = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_ha_mode_server_info = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_ha_mode_server_name = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_ha_start_util_process = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_ha_util_process_args = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_halt_shutdown = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_host_name = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_is_registered = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_is_registered_id = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_kill_all = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_kill_all_ha_utils = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_print_all_info = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_print_ha_admin_info = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_print_ha_node_info = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_print_ha_ping_hosts_info = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_print_ha_process_info = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_print_info = `[false](broker__monitor_8c.md#function-timeout)`
bool	commdb_Arg_reconfig_heartbeat = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_server_name = `[NULL](freelistheap_8h.md#define-null)`
bool	commdb_Arg_shutdown_reviving_server = `[false](broker__monitor_8c.md#function-timeout)`
char *	commdb_Arg_shutdown_reviving_server_name = `[NULL](freelistheap_8h.md#define-null)`
int	commdb_Arg_shutdown_time = `0`
bool	commdb_Arg_verbose_output = `[false](broker__monitor_8c.md#function-timeout)`

Public Functions¶

Type	Name
int	main (int argc, char ** argv)

Public Static Functions¶

Type	Name
int	process_activate_heartbeat (CSS_CONN_ENTRY * conn)
int	process_batch_command (CSS_CONN_ENTRY * conn)
int	process_deact_confirm_no_server (CSS_CONN_ENTRY * conn)
int	process_deact_confirm_stop_all (CSS_CONN_ENTRY * conn)
int	process_deact_stop_all (CSS_CONN_ENTRY * conn)
int	process_deactivate_heartbeat (CSS_CONN_ENTRY * conn)
void	process_ha_admin_info_query (CSS_CONN_ENTRY * conn)
int	process_ha_deregister_by_args (CSS_CONN_ENTRY * conn, char * args)
int	process_ha_deregister_by_pid (CSS_CONN_ENTRY * conn, char * pid_string)
void	process_ha_node_info_query (CSS_CONN_ENTRY * conn, int verbose_yn)
void	process_ha_ping_host_info_query (CSS_CONN_ENTRY * conn)
void	process_ha_process_info_query (CSS_CONN_ENTRY * conn, int verbose_yn)
void	process_ha_server_mode (CSS_CONN_ENTRY * conn, char * server_name)
int	process_ha_start_util_process (CSS_CONN_ENTRY * conn, char * args)
int	process_is_registered_proc (CSS_CONN_ENTRY * conn, char * args)
void	process_kill_all_ha_utils (CSS_CONN_ENTRY * conn)
void	process_master_kill (CSS_CONN_ENTRY * conn)
void	process_master_shutdown (CSS_CONN_ENTRY * conn, int minutes)
void	process_master_stop_shutdown (CSS_CONN_ENTRY * conn)
int	process_reconfig_heartbeat (CSS_CONN_ENTRY * conn)
int	process_server_info_pid (CSS_CONN_ENTRY * conn, const char * server, int server_type)
void	process_shutdown_reviving_server (CSS_CONN_ENTRY * conn, char * server_name)
void	process_slave_kill (CSS_CONN_ENTRY * conn, char * slave_name, int minutes, int pid)
void	process_status_query (CSS_CONN_ENTRY * conn, int server_type, char ** server_info)
int	return_integer_data (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	return_string (CSS_CONN_ENTRY * conn, unsigned short request_id, char buffer, int** * buffer_size)
int	send_for_all_count (CSS_CONN_ENTRY * conn)
int	send_for_all_stats (CSS_CONN_ENTRY * conn)
int	send_for_request_count (CSS_CONN_ENTRY * conn)
int	send_for_server_count (CSS_CONN_ENTRY * conn)
int	send_for_server_downtime (CSS_CONN_ENTRY * conn)
int	send_for_server_stats (CSS_CONN_ENTRY * conn)
unsigned short	send_for_start_time (CSS_CONN_ENTRY * conn)
unsigned short	send_request_no_args (CSS_CONN_ENTRY * conn, int command)
unsigned short	send_request_one_arg (CSS_CONN_ENTRY * conn, int command, char * buffer, int size)
unsigned short	send_request_two_args (CSS_CONN_ENTRY * conn, int command, char * buffer1, int size1, char * buffer2, int size2)

Macros¶

Type	Name
define	COMMDB_CMD_ALLOWED_ON_REMOTE () `/* multi line expression */`

Public Types Documentation¶

enum COMM_SERVER_TYPE¶

enum COMM_SERVER_TYPE {
    COMM_SERVER,
    COMM_ALL = 99
};

Public Static Attributes Documentation¶

variable commdb_Arg_activate_heartbeat¶

bool commdb_Arg_activate_heartbeat;

variable commdb_Arg_deact_confirm_no_server¶

bool commdb_Arg_deact_confirm_no_server;

variable commdb_Arg_deact_confirm_stop_all¶

bool commdb_Arg_deact_confirm_stop_all;

variable commdb_Arg_deact_immediately¶

bool commdb_Arg_deact_immediately;

variable commdb_Arg_deact_stop_all¶

bool commdb_Arg_deact_stop_all;

variable commdb_Arg_deactivate_heartbeat¶

bool commdb_Arg_deactivate_heartbeat;

variable commdb_Arg_ha_deregister_args¶

char* commdb_Arg_ha_deregister_args;

variable commdb_Arg_ha_deregister_by_args¶

bool commdb_Arg_ha_deregister_by_args;

variable commdb_Arg_ha_deregister_by_pid¶

bool commdb_Arg_ha_deregister_by_pid;

variable commdb_Arg_ha_deregister_pid¶

char* commdb_Arg_ha_deregister_pid;

variable commdb_Arg_ha_mode_server_info¶

bool commdb_Arg_ha_mode_server_info;

variable commdb_Arg_ha_mode_server_name¶

char* commdb_Arg_ha_mode_server_name;

variable commdb_Arg_ha_start_util_process¶

bool commdb_Arg_ha_start_util_process;

variable commdb_Arg_ha_util_process_args¶

char* commdb_Arg_ha_util_process_args;

variable commdb_Arg_halt_shutdown¶

bool commdb_Arg_halt_shutdown;

variable commdb_Arg_host_name¶

char* commdb_Arg_host_name;

variable commdb_Arg_is_registered¶

bool commdb_Arg_is_registered;

variable commdb_Arg_is_registered_id¶

char* commdb_Arg_is_registered_id;

variable commdb_Arg_kill_all¶

bool commdb_Arg_kill_all;

variable commdb_Arg_kill_all_ha_utils¶

bool commdb_Arg_kill_all_ha_utils;

variable commdb_Arg_print_all_info¶

bool commdb_Arg_print_all_info;

variable commdb_Arg_print_ha_admin_info¶

bool commdb_Arg_print_ha_admin_info;

variable commdb_Arg_print_ha_node_info¶

bool commdb_Arg_print_ha_node_info;

variable commdb_Arg_print_ha_ping_hosts_info¶

bool commdb_Arg_print_ha_ping_hosts_info;

variable commdb_Arg_print_ha_process_info¶

bool commdb_Arg_print_ha_process_info;

variable commdb_Arg_print_info¶

bool commdb_Arg_print_info;

variable commdb_Arg_reconfig_heartbeat¶

bool commdb_Arg_reconfig_heartbeat;

variable commdb_Arg_server_name¶

char* commdb_Arg_server_name;

variable commdb_Arg_shutdown_reviving_server¶

bool commdb_Arg_shutdown_reviving_server;

variable commdb_Arg_shutdown_reviving_server_name¶

char* commdb_Arg_shutdown_reviving_server_name;

variable commdb_Arg_shutdown_time¶

int commdb_Arg_shutdown_time;

variable commdb_Arg_verbose_output¶

bool commdb_Arg_verbose_output;

Public Functions Documentation¶

function main¶

int main (
    int argc,
    char ** argv
)

Public Static Functions Documentation¶

function process_activate_heartbeat¶

static int process_activate_heartbeat (
    CSS_CONN_ENTRY * conn
)

function process_batch_command¶

static int process_batch_command (
    CSS_CONN_ENTRY * conn
)

function process_deact_confirm_no_server¶

static int process_deact_confirm_no_server (
    CSS_CONN_ENTRY * conn
)

function process_deact_confirm_stop_all¶

static int process_deact_confirm_stop_all (
    CSS_CONN_ENTRY * conn
)

function process_deact_stop_all¶

static int process_deact_stop_all (
    CSS_CONN_ENTRY * conn
)

function process_deactivate_heartbeat¶

static int process_deactivate_heartbeat (
    CSS_CONN_ENTRY * conn
)

function process_ha_admin_info_query¶

static void process_ha_admin_info_query (
    CSS_CONN_ENTRY * conn
)

function process_ha_deregister_by_args¶

static int process_ha_deregister_by_args (
    CSS_CONN_ENTRY * conn,
    char * args
)

function process_ha_deregister_by_pid¶

static int process_ha_deregister_by_pid (
    CSS_CONN_ENTRY * conn,
    char * pid_string
)

function process_ha_node_info_query¶

static void process_ha_node_info_query (
    CSS_CONN_ENTRY * conn,
    int verbose_yn
)

function process_ha_ping_host_info_query¶

static void process_ha_ping_host_info_query (
    CSS_CONN_ENTRY * conn
)

function process_ha_process_info_query¶

static void process_ha_process_info_query (
    CSS_CONN_ENTRY * conn,
    int verbose_yn
)

function process_ha_server_mode¶

static void process_ha_server_mode (
    CSS_CONN_ENTRY * conn,
    char * server_name
)

function process_ha_start_util_process¶

static int process_ha_start_util_process (
    CSS_CONN_ENTRY * conn,
    char * args
)

function process_is_registered_proc¶

static int process_is_registered_proc (
    CSS_CONN_ENTRY * conn,
    char * args
)

function process_kill_all_ha_utils¶

static void process_kill_all_ha_utils (
    CSS_CONN_ENTRY * conn
)

function process_master_kill¶

static void process_master_kill (
    CSS_CONN_ENTRY * conn
)

function process_master_shutdown¶

static void process_master_shutdown (
    CSS_CONN_ENTRY * conn,
    int minutes
)

function process_master_stop_shutdown¶

static void process_master_stop_shutdown (
    CSS_CONN_ENTRY * conn
)

function process_reconfig_heartbeat¶

static int process_reconfig_heartbeat (
    CSS_CONN_ENTRY * conn
)

function process_server_info_pid¶

static int process_server_info_pid (
    CSS_CONN_ENTRY * conn,
    const  char * server,
    int server_type
)

function process_shutdown_reviving_server¶

static void process_shutdown_reviving_server (
    CSS_CONN_ENTRY * conn,
    char * server_name
)

function process_slave_kill¶

static void process_slave_kill (
    CSS_CONN_ENTRY * conn,
    char * slave_name,
    int minutes,
    int pid
)

function process_status_query¶

static void process_status_query (
    CSS_CONN_ENTRY * conn,
    int server_type,
    char ** server_info
)

function return_integer_data¶

static int return_integer_data (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
)

function return_string¶

static void return_string (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char ** buffer,
    int * buffer_size
)

function send_for_all_count¶

static int send_for_all_count (
    CSS_CONN_ENTRY * conn
)

function send_for_all_stats¶

static int send_for_all_stats (
    CSS_CONN_ENTRY * conn
)

function send_for_request_count¶

static int send_for_request_count (
    CSS_CONN_ENTRY * conn
)

function send_for_server_count¶

static int send_for_server_count (
    CSS_CONN_ENTRY * conn
)

function send_for_server_downtime¶

static int send_for_server_downtime (
    CSS_CONN_ENTRY * conn
)

function send_for_server_stats¶

static int send_for_server_stats (
    CSS_CONN_ENTRY * conn
)

function send_for_start_time¶

static unsigned  short send_for_start_time (
    CSS_CONN_ENTRY * conn
)

function send_request_no_args¶

static unsigned  short send_request_no_args (
    CSS_CONN_ENTRY * conn,
    int command
)

function send_request_one_arg¶

static unsigned  short send_request_one_arg (
    CSS_CONN_ENTRY * conn,
    int command,
    char * buffer,
    int size
)

function send_request_two_args¶

static unsigned  short send_request_two_args (
    CSS_CONN_ENTRY * conn,
    int command,
    char * buffer1,
    int size1,
    char * buffer2,
    int size2
)

Macro Definition Documentation¶

define COMMDB_CMD_ALLOWED_ON_REMOTE¶

#define COMMDB_CMD_ALLOWED_ON_REMOTE (

) `/* multi line expression */`

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