File broker_admin_so.h¶

FileList > broker > broker_admin_so.h

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

Classes¶

Type	Name
struct	t_as_info
struct	t_br_conf
struct	t_br_info
struct	t_job_info
struct	t_uc_conf
struct	t_uc_conf_item

Public Types¶

Type	Name
typedef struct t_as_info	T_AS_INFO
typedef enum t_as_status	T_AS_STATUS
typedef struct t_br_conf	T_BR_CONF
typedef struct t_br_info	T_BR_INFO
typedef struct t_job_info	T_JOB_INFO
typedef void (	T_UCA_AS_SHM_OPEN
typedef void (	T_UCA_BROKER_SHM_OPEN
typedef int(*	T_UCA_GET_AS_NUM_WITH_OPENED_SHM
typedef int(*	T_UCA_GET_AS_QUERY_PROCESSED_WITH_OPENED_SHM
typedef int(*	T_UCA_GET_AS_REQS_RECEIVED_WITH_OPENED_SHM
typedef int(*	T_UCA_GET_AS_TRAN_PROCESSED_WITH_OPENED_SHM
typedef int(*	T_UCA_GET_BR_NAME_WITH_OPENED_SHM
typedef int(*	T_UCA_GET_BR_NUM_WITH_OPENED_SHM
typedef int(*	T_UCA_SHM_DETACH
typedef int(*	T_UC_ADD_F
typedef int(*	T_UC_AS_INFO_F
typedef int(*	T_UC_BR_INFO_F
typedef int(*	T_UC_CHANGER_F
typedef void(*	T_UC_CHANGE_CONFIG_F
typedef struct t_uc_conf	T_UC_CONF
typedef int(*	T_UC_CONF_BROKER_ADD_F
typedef struct t_uc_conf_item	T_UC_CONF_ITEM
typedef int(*	T_UC_DEL_CAS_LOG_F
typedef int(*	T_UC_DROP_F
typedef int(*	T_UC_GET_ACTIVE_SESSION_WITH_OPENED_SHM
typedef void(*	T_UC_INFO_FREE_F
typedef int(*	T_UC_JOB_FIRST_F
typedef int(*	T_UC_JOB_QUEUE_F
typedef int(*	T_UC_OFF_F
typedef int(*	T_UC_ON_F
typedef int(*	T_UC_RESTART_F
typedef int(*	T_UC_RESUME_F
typedef int(*	T_UC_START_F
typedef int(*	T_UC_STOP_F
typedef int(*	T_UC_SUSPEND_F
typedef int(*	T_UC_UNICAS_CONF_F
typedef void(*	T_UC_UNICAS_CONF_FREE_F
typedef char (	T_UC_VERSION_F
enum	t_as_status

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 * errmsg)
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 (void)

Macros¶

Type	Name
define	DLL_EXPORT
define	FLAG_OFF `0`
define	FLAG_ON `1`
define	FLAG_READ_ONLY `1`
define	FLAG_READ_WRITE `0`
define	FLAG_SLAVE_ONLY `2`
define	FLAG_SUSPEND `2`
define	SRV_CON_DBNAME_SIZE `32`

Public Types Documentation¶

typedef T_AS_INFO¶

typedef struct t_as_info T_AS_INFO;

typedef T_AS_STATUS¶

typedef enum t_as_status T_AS_STATUS;

typedef T_BR_CONF¶

typedef struct t_br_conf T_BR_CONF;

typedef T_BR_INFO¶

typedef struct t_br_info T_BR_INFO;

typedef T_JOB_INFO¶

typedef struct t_job_info T_JOB_INFO;

typedef T_UCA_AS_SHM_OPEN¶

typedef void *(* T_UCA_AS_SHM_OPEN) (void *shm_br, int br_index, char *err_msg);

typedef T_UCA_BROKER_SHM_OPEN¶

typedef void *(* T_UCA_BROKER_SHM_OPEN) (char *err_msg);

typedef T_UCA_GET_AS_NUM_WITH_OPENED_SHM¶

typedef int(* T_UCA_GET_AS_NUM_WITH_OPENED_SHM) (void *shm_br, int br_index, char *err_msg);

typedef T_UCA_GET_AS_QUERY_PROCESSED_WITH_OPENED_SHM¶

typedef int(* T_UCA_GET_AS_QUERY_PROCESSED_WITH_OPENED_SHM) (void *shm_as, long long array[], int array_size, char *err_msg);

typedef T_UCA_GET_AS_REQS_RECEIVED_WITH_OPENED_SHM¶

typedef int(* T_UCA_GET_AS_REQS_RECEIVED_WITH_OPENED_SHM) (void *shm_as, long long array[], int array_size, char *err_msg);

typedef T_UCA_GET_AS_TRAN_PROCESSED_WITH_OPENED_SHM¶

typedef int(* T_UCA_GET_AS_TRAN_PROCESSED_WITH_OPENED_SHM) (void *shm_as, long long array[], int array_size, char *err_msg);

typedef T_UCA_GET_BR_NAME_WITH_OPENED_SHM¶

typedef int(* T_UCA_GET_BR_NAME_WITH_OPENED_SHM) (void *shm_br, int br_index, char *name, int buffer_size, char *err_msg);

typedef T_UCA_GET_BR_NUM_WITH_OPENED_SHM¶

typedef int(* T_UCA_GET_BR_NUM_WITH_OPENED_SHM) (void *shm_br, char *err_msg);

typedef T_UCA_SHM_DETACH¶

typedef int(* T_UCA_SHM_DETACH) (void *p);

typedef T_UC_ADD_F¶

typedef int(* T_UC_ADD_F) (char *, char *);

typedef T_UC_AS_INFO_F¶

typedef int(* T_UC_AS_INFO_F) (char *, T_AS_INFO **, T_JOB_INFO **, int *, char *);

typedef T_UC_BR_INFO_F¶

typedef int(* T_UC_BR_INFO_F) (T_BR_INFO **, char *);

typedef T_UC_CHANGER_F¶

typedef int(* T_UC_CHANGER_F) (char *, char *, char *, char *);

typedef T_UC_CHANGE_CONFIG_F¶

typedef void(* T_UC_CHANGE_CONFIG_F) (T_UC_CONF *, const char *, const char *, const char *);

typedef T_UC_CONF¶

typedef struct t_uc_conf T_UC_CONF;

typedef T_UC_CONF_BROKER_ADD_F¶

typedef int(* T_UC_CONF_BROKER_ADD_F) (T_UC_CONF *, char *, char *);

typedef T_UC_CONF_ITEM¶

typedef struct t_uc_conf_item T_UC_CONF_ITEM;

typedef T_UC_DEL_CAS_LOG_F¶

typedef int(* T_UC_DEL_CAS_LOG_F) (char *, int, char *);

typedef T_UC_DROP_F¶

typedef int(* T_UC_DROP_F) (char *, char *);

typedef T_UC_GET_ACTIVE_SESSION_WITH_OPENED_SHM¶

typedef int(* T_UC_GET_ACTIVE_SESSION_WITH_OPENED_SHM) (void *, char *);

typedef T_UC_INFO_FREE_F¶

typedef void(* T_UC_INFO_FREE_F) (void *);

typedef T_UC_JOB_FIRST_F¶

typedef int(* T_UC_JOB_FIRST_F) (char *, int, char *);

typedef T_UC_JOB_QUEUE_F¶

typedef int(* T_UC_JOB_QUEUE_F) (char *, char *);

typedef T_UC_OFF_F¶

typedef int(* T_UC_OFF_F) (char *, char *);

typedef T_UC_ON_F¶

typedef int(* T_UC_ON_F) (char *, char *);

typedef T_UC_RESTART_F¶

typedef int(* T_UC_RESTART_F) (char *, int, char *);

typedef T_UC_RESUME_F¶

typedef int(* T_UC_RESUME_F) (char *, char *);

typedef T_UC_START_F¶

typedef int(* T_UC_START_F) (char *);

typedef T_UC_STOP_F¶

typedef int(* T_UC_STOP_F) (char *);

typedef T_UC_SUSPEND_F¶

typedef int(* T_UC_SUSPEND_F) (char *, char *);

typedef T_UC_UNICAS_CONF_F¶

typedef int(* T_UC_UNICAS_CONF_F) (T_UC_CONF *, int *, char *);

typedef T_UC_UNICAS_CONF_FREE_F¶

typedef void(* T_UC_UNICAS_CONF_FREE_F) (T_UC_CONF *);

typedef T_UC_VERSION_F¶

typedef char *(* T_UC_VERSION_F) (void);

enum t_as_status¶

enum t_as_status {
    AS_STATUS_IDLE,
    AS_STATUS_BUSY,
    AS_STATUS_RESTART,
    AS_STATUS_CLIENT_WAIT,
    AS_STATUS_CLOSE_WAIT
};

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 * errmsg
)

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 (
    void
)

Macro Definition Documentation¶

define DLL_EXPORT¶

#define DLL_EXPORT

define FLAG_OFF¶

#define FLAG_OFF `0`

define FLAG_ON¶

#define FLAG_ON `1`

define FLAG_READ_ONLY¶

#define FLAG_READ_ONLY `1`

define FLAG_READ_WRITE¶

#define FLAG_READ_WRITE `0`

define FLAG_SLAVE_ONLY¶

#define FLAG_SLAVE_ONLY `2`

define FLAG_SUSPEND¶

#define FLAG_SUSPEND `2`

define SRV_CON_DBNAME_SIZE¶

#define SRV_CON_DBNAME_SIZE `32`

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