File broker_log_top.c¶

FileList > broker > broker_log_top.c

#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <assert.h>
#include <dirent.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include "cubrid_getopt.h"
#include "cas_common.h"
#include "cas_query_info.h"
#include "broker_log_time.h"
#include "broker_log_sql_list.h"
#include "log_top_string.h"
#include "broker_log_top.h"
#include "broker_log_util.h"
#include "broker_config.h"

Public Attributes¶

Type	Name
int	conf_argc_allocated = `0`
char **	conf_argv_allocated = `[NULL](freelistheap_8h.md#define-null)`
char	from_conf_flag = `0`
T_LOG_TOP_MODE	log_top_mode = `MODE\_PROC\_TIME`
T_OUTPUT_MODE	output_mode = `OUTPUT\_MERGE`
char **	virtual_new_argv = `[NULL](freelistheap_8h.md#define-null)`

Public Static Attributes¶

Type	Name
char	from_date = `""`
int	mode_max_handle_lower_bound
char	mode_tran = `0`
char *	sql_info_file = `[NULL](freelistheap_8h.md#define-null)`
char	to_date = `""`

Public Functions¶

Type	Name
int	check_log_time (char * start_date, char * end_date)
const char *	get_basename (const char * path)
void	get_brokername_from_filename (const char * filename, char * prefix, int max_len)
int	get_file_offset (char * filename, long * start_offset, long * end_offset)
int	main (int argc, char * argv)
int	make_change_split_brokerdir (char * splitdir, char * broker)
int	make_splitdir (char * splitdir)

Public Static Functions¶

Type	Name
int	collect_log_files_from_conf (char *** out_argv)
int	compare_by_brokername (const void * a, const void * b)
void	free_conf_allocated_argv ()
int	get_args (int * argc, char ** argv)
int	log_execute (T_QUERY_INFO * qi, char * linebuf, char ** query_p)
int	log_top (FILE * fp, char * filename, long start_offset, long end_offset)
int	log_top_query (int argc, char * argv, int arg_start)
char *	organize_query_string (const char * sql)
int	read_bind_value (FILE * fp, T_STRING * t_str, char linebuf, int** * lineno, T_STRING * cas_log_buf)
int	read_execute_end_msg (char * msg_p, int * res_code, int * runtime_msec)
int	read_multi_line_sql (FILE * fp, T_STRING * t_str, char linebuf, int** * lineno, T_STRING * sql_buf, T_STRING * cas_log_buf)
int	search_offset (FILE * fp, char * string, long * offset, bool start)

Macros¶

Type	Name
define	CLIENT_MSG_BUF_SIZE `1024`
define	CONNECT_MSG_BUF_SIZE `1024`
define	MAX_SRV_HANDLE `3000`

Public Attributes Documentation¶

variable conf_argc_allocated¶

int conf_argc_allocated;

variable conf_argv_allocated¶

char** conf_argv_allocated;

variable from_conf_flag¶

char from_conf_flag;

variable log_top_mode¶

T_LOG_TOP_MODE log_top_mode;

variable output_mode¶

T_OUTPUT_MODE output_mode;

variable virtual_new_argv¶

char** virtual_new_argv;

Public Static Attributes Documentation¶

variable from_date¶

char from_date[128];

variable mode_max_handle_lower_bound¶

int mode_max_handle_lower_bound;

variable mode_tran¶

char mode_tran;

variable sql_info_file¶

char* sql_info_file;

variable to_date¶

char to_date[128];

Public Functions Documentation¶

function check_log_time¶

int check_log_time (
    char * start_date,
    char * end_date
)

function get_basename¶

const  char * get_basename (
    const  char * path
)

function get_brokername_from_filename¶

void get_brokername_from_filename (
    const  char * filename,
    char * prefix,
    int max_len
)

function get_file_offset¶

int get_file_offset (
    char * filename,
    long * start_offset,
    long * end_offset
)

function main¶

int main (
    int argc,
    char * argv
)

function make_change_split_brokerdir¶

int make_change_split_brokerdir (
    char * splitdir,
    char * broker
)

function make_splitdir¶

int make_splitdir (
    char * splitdir
)

Public Static Functions Documentation¶

function collect_log_files_from_conf¶

static int collect_log_files_from_conf (
    char *** out_argv
)

function compare_by_brokername¶

static int compare_by_brokername (
    const  void * a,
    const  void * b
)

function free_conf_allocated_argv¶

static void free_conf_allocated_argv ()

function get_args¶

static int get_args (
    int * argc,
    char ** argv
)

function log_execute¶

static int log_execute (
    T_QUERY_INFO * qi,
    char * linebuf,
    char ** query_p
)

function log_top¶

static int log_top (
    FILE * fp,
    char * filename,
    long start_offset,
    long end_offset
)

function log_top_query¶

static int log_top_query (
    int argc,
    char * argv,
    int arg_start
)

function organize_query_string¶

static char * organize_query_string (
    const  char * sql
)

function read_bind_value¶

static int read_bind_value (
    FILE * fp,
    T_STRING * t_str,
    char ** linebuf,
    int * lineno,
    T_STRING * cas_log_buf
)

function read_execute_end_msg¶

static int read_execute_end_msg (
    char * msg_p,
    int * res_code,
    int * runtime_msec
)

function read_multi_line_sql¶

static int read_multi_line_sql (
    FILE * fp,
    T_STRING * t_str,
    char ** linebuf,
    int * lineno,
    T_STRING * sql_buf,
    T_STRING * cas_log_buf
)

function search_offset¶

static int search_offset (
    FILE * fp,
    char * string,
    long * offset,
    bool start
)

Macro Definition Documentation¶

define CLIENT_MSG_BUF_SIZE¶

#define CLIENT_MSG_BUF_SIZE `1024`

define CONNECT_MSG_BUF_SIZE¶

#define CONNECT_MSG_BUF_SIZE `1024`

define MAX_SRV_HANDLE¶

#define MAX_SRV_HANDLE `3000`

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