#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <signal.h>
#include <math.h>
#include <pthread.h>
#include <unistd.h>
#include "cubrid_getopt.h"
#include "cas_common.h"
#include "porting.h"
#include "cas_cci.h"
#include "broker_log_util.h"

Include dependency graph for cas_runner.c:

Classes
struct	t_bind_info

struct	t_node_info

Macros
#define	PRINT_CCI_ERROR(ERRCODE, CCI_ERROR, result_fp)

#define	FREE_BIND_INFO(NUM_BIND, BIND_INFO)

#define	MAX_NODE_INFO 100

#define	MAX_IGN_SRV_ERR 100

#define	THREAD_FUNC void*

#define	SLEEP_SEC(X) sleep(X)

#define	SLEEP_MILISEC(sec, msec)

#define	STRDUP(TARGET, SOURCE)

#define	SERVER_HANDLE_ALLOC_SIZE (MAX_SERVER_H_ID + 1)

Typedefs
typedef struct t_bind_info	T_BIND_INFO

typedef struct t_node_info	T_NODE_INFO

Functions
static double	calc_stddev (double *t, double avg, int count)

static double	calc_avg (double *t, int count)

static void	calc_min_max (double t, int count, double min, double *max)

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

static int	read_conf (void)

static void	cas_runner (FILE fp, FILE result_fp, double ret_exec_time, double ret_prepare_time)

static THREAD_FUNC	thr_main (void *arg)

static int	process_execute (char msg, int req_h, int num_bind, T_BIND_INFO bind_info, FILE result_fp, double *sum_execute_time)

static int	process_bind (char msg, int num_bind_p, T_BIND_INFO *bind_info)

static int	process_endtran (int con_h, int req_h, FILE result_fp)

static int	process_close_req (char linebuf, int req_h, FILE *result_fp)

static void	print_result (int cci_res, int req_id, FILE *fp)

static void	free_node (T_NODE_INFO *node)

static int	make_node_info (T_NODE_INFO node, char node_name, char *info_str)

static int	set_args_with_node_info (char *node_name)

static int	ignore_error (int code)

static char *	make_sql_stmt (char *src)

int	main (int argc, char *argv[])

Variables
const char *	cci_client_name = "JDBC"

static char *	broker_host = NULL

static int	broker_port = 0

static char *	dbname = NULL

static char *	dbuser = NULL

static char *	dbpasswd = NULL

static int	num_thread = 1

static int	repeat_count = 1

static char *	exec_script_file

static int	batch_mode = 0

static char *	result_file = NULL

static char *	cas_err_file = NULL

static int	fork_delay = 0

static char *	node_name = NULL

static int	think_time = 0

static int	qa_test_flag = 0

static int	num_replica = 1

static int	dump_query_plan = 0

static int	autocommit_mode = 0

static int	statdump_mode = 0

static double *	run_time_exec

static FILE *	cas_error_fp

static int	cas_error_flag = 0

static int	cubrid_manager_run = 0

static T_NODE_INFO	node_table [MAX_NODE_INFO]

static int	num_node = 0

static int	ign_srv_err_list [MAX_IGN_SRV_ERR]

static int	num_ign_srv_err = 0

Macro Definition Documentation

#define FREE_BIND_INFO	(	NUM_BIND,
		BIND_INFO
	)

Value:

do {                    \
      int i;                \
	  for (i=0 ; i < NUM_BIND ; i++) { \
	    FREE_MEM(BIND_INFO[i].value);  \
      }                 \
      NUM_BIND = 0;             \
    } while (0)

Definition at line 82 of file cas_runner.c.

Referenced by cas_runner().

#define MAX_IGN_SRV_ERR 100

Definition at line 92 of file cas_runner.c.

Referenced by read_conf().

#define MAX_NODE_INFO 100

Definition at line 91 of file cas_runner.c.

Referenced by read_conf().

#define PRINT_CCI_ERROR	(	ERRCODE,
		CCI_ERROR,
		result_fp
	)

Definition at line 48 of file cas_runner.c.

Referenced by cas_runner(), print_result(), process_close_req(), process_endtran(), and process_execute().

#define SERVER_HANDLE_ALLOC_SIZE (MAX_SERVER_H_ID + 1)

Definition at line 120 of file cas_runner.c.

Referenced by cas_runner(), process_close_req(), process_endtran(), and process_execute().

#define SLEEP_MILISEC	(	sec,
		msec
	)

Value:

do {                        \
      struct timeval sleep_time_val;        \
      sleep_time_val.tv_sec = sec;          \
      sleep_time_val.tv_usec = (msec) * 1000;   \
      select(0, 0, 0, 0, &sleep_time_val);      \
    } while(0)

Definition at line 105 of file cas_runner.c.

#define SLEEP_SEC ( X ) sleep(X)

Definition at line 104 of file cas_runner.c.

Referenced by main(), and thr_main().

#define STRDUP	(	TARGET,
		SOURCE
	)

Value:

do {                                          \
          if(TARGET != NULL) free(TARGET);    \
          TARGET = strdup (SOURCE);            \
        } while(0)