File master_request.c

FileList > cubrid > src > executables > master_request.c

Go to the source code of this file

• #include "config.h"
• #include <stdio.h>
• #include <stdlib.h>
• #include <string.h>
• #include <time.h>
• #include <signal.h>
• #include <sys/time.h>
• #include <sys/param.h>
• #include <netinet/in.h>
• #include <pthread.h>
• #include "system_parameter.h"
• #include "connection_globals.h"
• #include "client_support.h"
• #include "error_manager.h"
• #include "utility.h"
• #include "message_catalog.h"
• #include "memory_alloc.h"
• #include "porting.h"
• #include "release_string.h"
• #include "tcp.h"
• #include "master_util.h"
• #include "master_request.h"
• #include "master_heartbeat.h"
• #include "master_server_monitor.hpp"

Public Functions

Type	Name
void	css_process_heartbeat_request (CSS_CONN_ENTRY * conn)
void	css_process_info_request (CSS_CONN_ENTRY * conn)
void	css_process_start_shutdown (SOCKET_QUEUE_ENTRY * sock_entq, int timeout, char * buffer)
void	css_process_start_shutdown_by_name (char * server_name)
void	css_process_stop_shutdown (void)

Public Static Functions

Type	Name
void	css_cleanup_info_connection (CSS_CONN_ENTRY * conn)
void	css_process_activate_heartbeat (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_all_count_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_all_list_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_change_ha_mode (CSS_CONN_ENTRY * conn)
void	css_process_deact_confirm_no_server (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_deact_confirm_stop_all (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_deact_stop_all (CSS_CONN_ENTRY * conn, unsigned short request_id, char * deact_immediately)
void	css_process_deactivate_heartbeat (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_deregister_ha_process (CSS_CONN_ENTRY * conn)
void	css_process_get_eof (CSS_CONN_ENTRY * conn)
void	css_process_get_server_ha_mode (CSS_CONN_ENTRY * conn, unsigned short request_id, char * server_name)
void	css_process_ha_admin_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_ha_deregister_by_args (CSS_CONN_ENTRY * conn, unsigned short request_id, char * args)
void	css_process_ha_deregister_by_pid (CSS_CONN_ENTRY * conn, unsigned short request_id, char * pid_p)
void	css_process_ha_node_list_info (CSS_CONN_ENTRY * conn, unsigned short request_id, bool verbose_yn)
void	css_process_ha_ping_host_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_ha_process_list_info (CSS_CONN_ENTRY * conn, unsigned short request_id, bool verbose_yn)
void	css_process_ha_start_util_process (CSS_CONN_ENTRY * conn, unsigned short request_id, char * args)
void	css_process_is_registered_ha_proc (CSS_CONN_ENTRY * conn, unsigned short request_id, char * buf)
void	css_process_kill_all_ha_process (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_kill_immediate (CSS_CONN_ENTRY * conn, unsigned short request_id, char * server_name)
void	css_process_kill_master (void)
void	css_process_kill_slave (CSS_CONN_ENTRY * conn, unsigned short request_id, char * server_name)
void	css_process_reconfig_heartbeat (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_register_ha_process (CSS_CONN_ENTRY * conn)
void	css_process_request_count_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_server_count_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_server_list_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_server_state (CSS_CONN_ENTRY * conn, unsigned short request_id, char * server_name)
void	css_process_shutdown (char * time_buffer)
void	css_process_shutdown_reviving_server (CSS_CONN_ENTRY * conn, unsigned short request_id, char * server_name)
void	css_process_shutdown_time_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_process_start_time_info (CSS_CONN_ENTRY * conn, unsigned short request_id)
void	css_send_command_to_server (const SOCKET_QUEUE_ENTRY * sock_entry, int command)
void	css_send_message_to_server (const SOCKET_QUEUE_ENTRY * sock_entry, const char * message)
void	css_send_term_signal (int pid)

Macros

Type	Name
define	HA_APPLYLOGDB_FORMAT_STRING " HA-[**applylogdb**](util__cs_8c.md#function-applylogdb) %s ([**rel**](broker__monitor_8c.md#function-timeout) %s, [**pid**](dynamic__load_8c.md#variable-pid) %d)\[**n"**](broker__monitor_8c.md#function-timeout)
define	HA_COPYLOGDB_FORMAT_STRING " HA-[**copylogdb**](util__cs_8c.md#function-copylogdb) %s ([**rel**](broker__monitor_8c.md#function-timeout) %s, [**pid**](dynamic__load_8c.md#variable-pid) %d)\[**n"**](broker__monitor_8c.md#function-timeout)
define	HA_SERVER_FORMAT_STRING " HA-[**Server**](broker__monitor_8c.md#function-timeout) %s ([**rel**](broker__monitor_8c.md#function-timeout) %s, [**pid**](dynamic__load_8c.md#variable-pid) %d)\[**n"**](broker__monitor_8c.md#function-timeout)
define	IS_MASTER_SOCKET_FD (FD) (([**FD**](broker__monitor_8c.md#function-timeout)) == [**css\_Master\_socket\_fd**](master_8c.md#variable-css_master_socket_fd)[0] \|\| ([**FD**](broker__monitor_8c.md#function-timeout)) == [**css\_Master\_socket\_fd**](master_8c.md#variable-css_master_socket_fd)[1])
define	SERVER_FORMAT_STRING " Server %s ([**rel**](broker__monitor_8c.md#function-timeout) %s, [**pid**](dynamic__load_8c.md#variable-pid) %d)\[**n"**](broker__monitor_8c.md#function-timeout)

Public Functions Documentation

function css_process_heartbeat_request

void css_process_heartbeat_request (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_info_request

void css_process_info_request (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_start_shutdown

void css_process_start_shutdown (
    SOCKET_QUEUE_ENTRY * sock_entq,
    int timeout,
    char * buffer
) 

---

function css_process_start_shutdown_by_name

void css_process_start_shutdown_by_name (
    char * server_name
) 

---

function css_process_stop_shutdown

void css_process_stop_shutdown (
    void
) 

---

Public Static Functions Documentation

function css_cleanup_info_connection

static void css_cleanup_info_connection (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_activate_heartbeat

static void css_process_activate_heartbeat (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_all_count_info

static void css_process_all_count_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_all_list_info

static void css_process_all_list_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_change_ha_mode

static void css_process_change_ha_mode (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_deact_confirm_no_server

static void css_process_deact_confirm_no_server (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_deact_confirm_stop_all

static void css_process_deact_confirm_stop_all (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_deact_stop_all

static void css_process_deact_stop_all (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * deact_immediately
) 

---

function css_process_deactivate_heartbeat

static void css_process_deactivate_heartbeat (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_deregister_ha_process

static void css_process_deregister_ha_process (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_get_eof

static void css_process_get_eof (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_get_server_ha_mode

static void css_process_get_server_ha_mode (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * server_name
) 

---

function css_process_ha_admin_info

static void css_process_ha_admin_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_ha_deregister_by_args

static void css_process_ha_deregister_by_args (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * args
) 

---

function css_process_ha_deregister_by_pid

static void css_process_ha_deregister_by_pid (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * pid_p
) 

---

function css_process_ha_node_list_info

static void css_process_ha_node_list_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    bool verbose_yn
) 

---

function css_process_ha_ping_host_info

static void css_process_ha_ping_host_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_ha_process_list_info

static void css_process_ha_process_list_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    bool verbose_yn
) 

---

function css_process_ha_start_util_process

static void css_process_ha_start_util_process (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * args
) 

---

function css_process_is_registered_ha_proc

static void css_process_is_registered_ha_proc (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * buf
) 

---

function css_process_kill_all_ha_process

static void css_process_kill_all_ha_process (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_kill_immediate

static void css_process_kill_immediate (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * server_name
) 

---

function css_process_kill_master

static void css_process_kill_master (
    void
) 

---

function css_process_kill_slave

static void css_process_kill_slave (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * server_name
) 

---

function css_process_reconfig_heartbeat

static void css_process_reconfig_heartbeat (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_register_ha_process

static void css_process_register_ha_process (
    CSS_CONN_ENTRY * conn
) 

---

function css_process_request_count_info

static void css_process_request_count_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_server_count_info

static void css_process_server_count_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_server_list_info

static void css_process_server_list_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_server_state

static void css_process_server_state (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * server_name
) 

---

function css_process_shutdown

static void css_process_shutdown (
    char * time_buffer
) 

---

function css_process_shutdown_reviving_server

static void css_process_shutdown_reviving_server (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id,
    char * server_name
) 

---

function css_process_shutdown_time_info

static void css_process_shutdown_time_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_process_start_time_info

static void css_process_start_time_info (
    CSS_CONN_ENTRY * conn,
    unsigned  short request_id
) 

---

function css_send_command_to_server

static void css_send_command_to_server (
    const  SOCKET_QUEUE_ENTRY * sock_entry,
    int command
) 

---

function css_send_message_to_server

static void css_send_message_to_server (
    const  SOCKET_QUEUE_ENTRY * sock_entry,
    const  char * message
) 

---

function css_send_term_signal

static void css_send_term_signal (
    int pid
) 

---

Macro Definition Documentation

define HA_APPLYLOGDB_FORMAT_STRING

#define HA_APPLYLOGDB_FORMAT_STRING `" HA- applylogdb %s ( rel %s, pid %d)\ n"`

---

define HA_COPYLOGDB_FORMAT_STRING

#define HA_COPYLOGDB_FORMAT_STRING `" HA- copylogdb %s ( rel %s, pid %d)\ n"`

---

define HA_SERVER_FORMAT_STRING

#define HA_SERVER_FORMAT_STRING `" HA- Server %s ( rel %s, pid %d)\ n"`

---

define IS_MASTER_SOCKET_FD

#define IS_MASTER_SOCKET_FD (
    FD
) `(( FD ) == css_Master_socket_fd [0] || ( FD ) == css_Master_socket_fd [1])`

---

define SERVER_FORMAT_STRING

#define SERVER_FORMAT_STRING `" Server %s ( rel %s, pid %d)\ n"`

---

---

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