/* * Copyright (C) 2008 Search Solution Corporation. All rights reserved by Search Solution. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; version 2 of the License. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * */ /* * cmd_exec.c - */ #ident "$Id$" #include #include #include #include #include #ifdef WIN32 #include #else #include #endif #include "cm_porting.h" #include "cm_command_execute.h" #include "cm_config.h" #include "cm_server_util.h" #include "utility.h" #ifdef _DEBUG_ #include "deb.h" #endif #define new_commdb_result() (T_COMMDB_RESULT*) new_cmd_result() #define new_csql_result() (T_CSQL_RESULT*) new_cmd_result() static T_CMD_RESULT *new_cmd_result (); static T_SPACEDB_RESULT *new_spacedb_result (); static char *get_cubrid_mode_opt (T_CUBRID_MODE mode); static void read_commdb_output (T_COMMDB_RESULT * res, char *out_file); static void read_spacedb_output (T_SPACEDB_RESULT * res, char *out_file); static void set_spacedb_info (T_SPACEDB_INFO * vol_info, int volid, char *purpose, int total_page, int free_page, char *vol_name); static int parse_volume_line (T_SPACEDB_INFO * vol_info, char *str_buf); char * cubrid_cmd_name (char *buf) { buf[0] = '\0'; sprintf (buf, "%s/%s%s", sco.szCubrid, CUBRID_DIR_BIN, UTIL_ADMIN_NAME); return buf; } T_CSQL_RESULT * cmd_csql (char *dbname, char *uid, char *passwd, T_CUBRID_MODE mode, char *infile, char *command) { char *cubrid_err_file; char out_file[512]; T_CSQL_RESULT *res; char cmd_name[CUBRID_CMD_NAME_LEN]; char *argv[15]; int argc = 0; cmd_name[0] = '\0'; sprintf (cmd_name, "%s/%s%s", sco.szCubrid, CUBRID_DIR_BIN, UTIL_CSQL_NAME); argv[argc++] = cmd_name; argv[argc++] = get_cubrid_mode_opt (mode); if (uid) { argv[argc++] = "--" CSQL_USER_L; argv[argc++] = uid; if (passwd) { argv[argc++] = "--" CSQL_PASSWORD_L; argv[argc++] = passwd; } } if (infile) { argv[argc++] = "--" CSQL_INPUT_FILE_L; argv[argc++] = infile; } else if (command) { argv[argc++] = "--" CSQL_COMMAND_L; argv[argc++] = command; } else { return NULL; } argv[argc++] = dbname; argv[argc++] = NULL; sprintf (out_file, "%s/tmp/DBMT_util_003.%d", sco.szCubrid, (int) getpid ()); INIT_CUBRID_ERROR_FILE (cubrid_err_file); SET_TRANSACTION_NO_WAIT_MODE_ENV (); run_child (argv, 1, NULL, NULL, cubrid_err_file, NULL); /* csql */ res = new_csql_result (); if (res == NULL) return NULL; read_error_file (cubrid_err_file, res->err_msg, ERR_MSG_SIZE); unlink (out_file); return res; } void cmd_spacedb_result_free (T_SPACEDB_RESULT * res) { if (res) { if (res->vol_info) free (res->vol_info); if (res->tmp_vol_info) free (res->tmp_vol_info); free (res); } } void cmd_result_free (T_CMD_RESULT * res) { if (res) { if (res->result) free (res->result); free (res); } } T_SPACEDB_RESULT * cmd_spacedb (char *dbname, T_CUBRID_MODE mode) { T_SPACEDB_RESULT *res; char out_file[128]; char *cubrid_err_file; char cmd_name[CUBRID_CMD_NAME_LEN]; char *argv[10]; res = new_spacedb_result (); if (res == NULL) { return NULL; } sprintf (out_file, "%s/DBMT_util_002.%d", sco.dbmt_tmp_dir, (int) getpid ()); cubrid_cmd_name (cmd_name); argv[0] = cmd_name; argv[1] = UTIL_OPTION_SPACEDB; argv[2] = get_cubrid_mode_opt (mode); argv[3] = "--" SPACE_OUTPUT_FILE_L; argv[4] = out_file; argv[5] = dbname; argv[6] = NULL; INIT_CUBRID_ERROR_FILE (cubrid_err_file); run_child (argv, 1, NULL, NULL, cubrid_err_file, NULL); /* spacedb */ read_error_file (cubrid_err_file, res->err_msg, ERR_MSG_SIZE); read_spacedb_output (res, out_file); unlink (out_file); return res; } T_COMMDB_RESULT * cmd_commdb () { T_COMMDB_RESULT *res; char out_file[512]; char cmd_name[CUBRID_CMD_NAME_LEN]; char *argv[5]; res = new_commdb_result (); if (res == NULL) return NULL; sprintf (out_file, "%s/DBMT_util_001.%d", sco.dbmt_tmp_dir, (int) getpid ()); cmd_name[0] = '\0'; sprintf (cmd_name, "%s/%s%s", sco.szCubrid, CUBRID_DIR_BIN, UTIL_COMMDB_NAME); argv[0] = cmd_name; argv[1] = COMMDB_SERVER_STATUS; argv[2] = NULL; run_child (argv, 1, NULL, out_file, NULL, NULL); /* commdb */ read_commdb_output (res, out_file); unlink (out_file); return res; } int cmd_start_server (char *dbname, char *err_buf, int err_buf_size) { char err_log_file[512]; int pid, ret_val, i; char cmd_name[CUBRID_CMD_NAME_LEN]; char cubrid_error_log_env[512]; char *argv[3]; struct tm start_tm; time_t start_time; #ifdef HPUX char jvm_env_string[32]; #endif cmd_start_master (); start_time = time (NULL); start_tm = *localtime (&start_time); sprintf (err_log_file, "%s/%s/%s_%04d%02d%02d_%02d%02d.err", sco.szCubrid, CUBRID_ERROR_LOG_DIR, dbname, start_tm.tm_year + 1900, start_tm.tm_mon + 1, start_tm.tm_mday, start_tm.tm_hour, start_tm.tm_min); unlink (err_log_file); sprintf (cubrid_error_log_env, "CUBRID_ERROR_LOG=%s", err_log_file); putenv (cubrid_error_log_env); cmd_name[0] = '\0'; sprintf (cmd_name, "%s/%s%s", sco.szCubrid, CUBRID_DIR_BIN, UTIL_CUBRID_NAME); argv[0] = cmd_name; argv[1] = dbname; argv[2] = NULL; #ifdef HPUX #ifdef HPUX_IA64 strcpy (jvm_env_string, "LD_PRELOAD=libjvm.so"); #else /* pa-risc */ strcpy (jvm_env_string, "LD_PRELOAD=libjvm.sl"); #endif putenv (jvm_env_string); #endif pid = run_child (argv, 0, NULL, NULL, NULL, NULL); /* start server */ #ifdef HPUX putenv ("LD_PRELOAD="); #endif if (pid < 0) { if (err_buf) sprintf (err_buf, "system error : %s %s %s", UTIL_CUBRID_NAME, PRINT_CMD_START, dbname); return -1; } SLEEP_MILISEC (3, 0); for (i = 0; i < 10; i++) { ret_val = read_error_file (err_log_file, err_buf, err_buf_size); if (ret_val < 0) return ret_val; /* check database active succeed */ if (uIsDatabaseActive (dbname)) { return ret_val; } SLEEP_MILISEC (3, 0); } /* if doesn't active when check 10 times then return error. */ if (err_buf) sprintf (err_buf, "system error : %s %s %s", UTIL_CUBRID_NAME, PRINT_CMD_START, dbname); return -1; } #if 0 int cmd_start_diag (char *err_buf, int err_buf_size) { char *argv[3]; char cmd_name[512]; char param[10]; int pid; #ifdef WIN32 sprintf (cmd_name, "%s/bin/diag.exe", sco.szCubrid); #else sprintf (cmd_name, "%s/bin/diag", sco.szCubrid); #endif sprintf (param, "start"); argv[0] = cmd_name; argv[1] = param; argv[2] = NULL; pid = run_child (argv, 0, NULL, NULL, NULL); /* diag */ if (pid < 0) { if (err_buf) sprintf (err_buf, "diag server start error"); return -1; } return 0; } #endif int cmd_stop_server (char *dbname, char *err_buf, int err_buf_size) { char strbuf[1024]; int t, timeout = 30, interval = 3; /* sec */ char cmd_name[CUBRID_CMD_NAME_LEN]; char *argv[5]; if (err_buf) memset (err_buf, 0, err_buf_size); cmd_name[0] = '\0'; sprintf (cmd_name, "%s/%s%s", sco.szCubrid, CUBRID_DIR_BIN, UTIL_COMMDB_NAME); argv[0] = cmd_name; argv[1] = COMMDB_SERVER_STOP; argv[2] = dbname; argv[3] = NULL; if (run_child (argv, 1, NULL, NULL, NULL, NULL) < 0) { /* stop_server */ if (err_buf) { sprintf (strbuf, "Command returned error : %s %s %s", UTIL_COMMDB_NAME, COMMDB_SERVER_STOP, dbname); strncpy (err_buf, strbuf, err_buf_size - 1); } return -1; } for (t = timeout; t > 0; t -= interval) { SLEEP_MILISEC (interval, 0); if (!uIsDatabaseActive (dbname)) return 0; } if (err_buf) { sprintf (strbuf, "%s server hasn't shut down after %d seconds", dbname, timeout); strncpy (err_buf, strbuf, err_buf_size - 1); } return -1; } void cmd_start_master () { int pid; char cmd_name[CUBRID_CMD_NAME_LEN]; char *argv[2]; cmd_name[0] = '\0'; sprintf (cmd_name, "%s/%s%s", sco.szCubrid, CUBRID_DIR_BIN, UTIL_MASTER_NAME); argv[0] = cmd_name; argv[1] = NULL; pid = run_child (argv, 0, NULL, NULL, NULL, NULL); /* cub_master */ SLEEP_MILISEC (0, 500); } int read_csql_error_file (char *err_file, char *err_buf, int err_buf_size) { FILE *fp; char buf[1024]; int msg_size = 0; if (err_buf) memset (err_buf, 0, err_buf_size); if (err_file == NULL || err_file[0] == '\0') return 0; fp = fopen (err_file, "r"); if (fp == NULL) return 0; while (1) { memset (buf, 0, sizeof (buf)); if (fgets (buf, sizeof (buf) - 1, fp) == NULL) break; ut_trim (buf); #ifdef WIN32 if ((_strnicmp (buf, "ERROR", 5) == 0) || (_strnicmp (buf, "에러", 4) == 0)) #else if ((strncasecmp (buf, "ERROR", 5) == 0) || (strncasecmp (buf, "에러", 4) == 0)) #endif { if (err_buf) { strcpy (err_buf, buf + 6); } msg_size = strlen (buf + 6); break; } else if (strstr (buf, "*** ERROR") != NULL) { memset (buf, 0, sizeof (buf)); if (fgets (buf, sizeof (buf) - 1, fp) == NULL) break; strcpy (err_buf, buf); msg_size = strlen (buf); break; } } fclose (fp); return (msg_size > 0 ? -1 : 0); } int read_error_file (char *err_file, char *err_buf, int err_buf_size) { FILE *fp; char buf[1024]; int msg_size = 0; char rm_prev_flag = 0; int i; if (err_buf) memset (err_buf, 0, err_buf_size); if (err_file == NULL || err_file[0] == '\0') return 0; fp = fopen (err_file, "r"); if (fp == NULL) return 0; while (1) { memset (buf, 0, sizeof (buf)); if (fgets (buf, sizeof (buf) - 1, fp) == NULL) break; for (i = 0; i < sizeof (buf) - 2; i++) { if (buf[i] == '\0') { if (buf[i + 1] == '\0') break; buf[i] = ' '; } } ut_trim (buf); if (buf[0] == '\0') continue; if (strncmp (buf, "---", 3) == 0 || strncmp (buf, "***", 3) == 0 || strncmp (buf, "<<<", 3) == 0 || strncmp (buf, "Time:", 5) == 0) { rm_prev_flag = 1; continue; } if (rm_prev_flag) { msg_size = 0; } strcat (buf, "\n"); if (err_buf) { strncpy (err_buf + msg_size, buf, err_buf_size - msg_size - 1); } msg_size += strlen (buf); rm_prev_flag = 0; } fclose (fp); return (msg_size > 0 ? -1 : 0); } static T_SPACEDB_RESULT * new_spacedb_result () { T_SPACEDB_RESULT *res; res = (T_SPACEDB_RESULT *) malloc (sizeof (T_SPACEDB_RESULT)); if (res == NULL) return NULL; memset (res, 0, sizeof (T_SPACEDB_RESULT)); return res; } static T_CMD_RESULT * new_cmd_result () { T_CMD_RESULT *res; res = (T_CMD_RESULT *) malloc (sizeof (T_CMD_RESULT)); if (res == NULL) return NULL; memset (res, 0, sizeof (T_CMD_RESULT)); return res; } static char * get_cubrid_mode_opt (T_CUBRID_MODE mode) { if (mode == CUBRID_MODE_SA) return ("--" CSQL_SA_MODE_L); return ("--" CSQL_CS_MODE_L); } static void read_commdb_output (T_COMMDB_RESULT * res, char *out_file) { T_COMMDB_INFO *info; int num_info, num_alloc; char str_buf[512]; char tmp_str[64], db_name[64]; FILE *fp; fp = fopen (out_file, "r"); if (fp == NULL) return; num_info = 0; num_alloc = 5; info = (T_COMMDB_INFO *) malloc (sizeof (T_COMMDB_INFO) * num_alloc); if (info == NULL) return; while (fgets (str_buf, sizeof (str_buf), fp)) { char *tmp_p; if (sscanf (str_buf, "%s %s", tmp_str, db_name) < 2) continue; if (strcmp (tmp_str, "Server") != 0) continue; tmp_p = strchr (db_name, ','); if (tmp_p) *tmp_p = '\0'; num_info++; if (num_info > num_alloc) { num_alloc += 5; info = (T_COMMDB_INFO *) realloc (info, sizeof (T_COMMDB_INFO) * num_alloc); if (info == NULL) { fclose (fp); return; } } strcpy (info[num_info - 1].db_name, db_name); } fclose (fp); res->num_result = num_info; res->result = info; } static int parse_volume_line (T_SPACEDB_INFO * vol_info, char *str_buf) { int volid, total_page, free_page; char purpose[128], vol_name[PATH_MAX]; char *token = NULL; volid = total_page = free_page = 0; purpose[0] = vol_name[0] = '\0'; token = strtok (str_buf, " "); if (token == NULL) { return FALSE; } volid = atoi (token); token = strtok (NULL, " "); if (token == NULL) { return FALSE; } strcpy (purpose, token); if (strcmp (purpose, "GENERIC") != 0 && strcmp (purpose, "DATA") != 0 && strcmp (purpose, "INDEX") != 0 && strcmp (purpose, "TEMP") != 0) { return FALSE; } token = strtok (NULL, " "); if (token == NULL) { return FALSE; } total_page = atoi (token); token = strtok (NULL, " "); if (token == NULL) { return FALSE; } free_page = atoi (token); token = strtok (NULL, "\n"); if (token == NULL) { return FALSE; } strcpy (vol_name, token + 1); set_spacedb_info (vol_info, volid, purpose, total_page, free_page, vol_name); return TRUE; } static void read_spacedb_output (T_SPACEDB_RESULT * res, char *out_file) { FILE *fp; char str_buf[1024]; int page_size = 0; int num_vol = 0, num_tmp_vol = 0; T_SPACEDB_INFO *vol_info = NULL, *tmp_vol_info = NULL; fp = fopen (out_file, "r"); if (fp == NULL) return; vol_info = (T_SPACEDB_INFO *) malloc (sizeof (T_SPACEDB_INFO)); tmp_vol_info = (T_SPACEDB_INFO *) malloc (sizeof (T_SPACEDB_INFO)); if (vol_info == NULL || tmp_vol_info == NULL) goto spacedb_error; while (fgets (str_buf, sizeof (str_buf), fp)) { char *tmp_p; ut_trim (str_buf); if (strncmp (str_buf, "Space", 5) == 0) { tmp_p = strrchr (str_buf, ' '); if (tmp_p == NULL) { goto spacedb_error; } page_size = atoi (tmp_p + 1); } else if ((strncmp (str_buf, "데이타베이스", strlen ("데이타베이스")) == 0) || (strncmp (str_buf, "데이터베이스", strlen ("데이터베이스")) == 0)) { tmp_p = strrchr (str_buf, ')'); if (tmp_p == NULL) goto spacedb_error; *tmp_p = '\0'; tmp_p = strrchr (str_buf, ' '); if (tmp_p == NULL) goto spacedb_error; page_size = atoi (tmp_p + 1); } else if (strncmp (str_buf, "Volid", 5) == 0 || strncmp (str_buf, "번호", strlen ("번호")) == 0) { break; } } while (fgets (str_buf, sizeof (str_buf), fp)) { ut_trim (str_buf); if (str_buf[0] == '\0' || str_buf[0] == '-') { continue; } if (strncmp (str_buf, "Volid", 5) == 0 || strncmp (str_buf, "번호", strlen ("번호")) == 0) { break; } if (strncmp (str_buf, "Space", 5) == 0) { continue; } if (!parse_volume_line (&(vol_info[num_vol]), str_buf)) { continue; } num_vol++; vol_info = (T_SPACEDB_INFO *) realloc (vol_info, sizeof (T_SPACEDB_INFO) * (num_vol + 1)); if (vol_info == NULL) goto spacedb_error; } while (fgets (str_buf, sizeof (str_buf), fp)) { ut_trim (str_buf); if (str_buf[0] == '\0' || str_buf[0] == '-') { continue; } if (strncmp (str_buf, "Volid", 5) == 0 || strncmp (str_buf, "번호", strlen ("번호")) == 0) { break; } if (!parse_volume_line (&(tmp_vol_info[num_tmp_vol]), str_buf)) { continue; } num_tmp_vol++; tmp_vol_info = (T_SPACEDB_INFO *) realloc (tmp_vol_info, sizeof (T_SPACEDB_INFO) * (num_tmp_vol + 1)); if (tmp_vol_info == NULL) goto spacedb_error; } fclose (fp); res->page_size = page_size; res->num_vol = num_vol; res->num_tmp_vol = num_tmp_vol; res->vol_info = vol_info; res->tmp_vol_info = tmp_vol_info; return; spacedb_error: fclose (fp); if (tmp_vol_info) free (tmp_vol_info); if (vol_info) free (vol_info); } static void set_spacedb_info (T_SPACEDB_INFO * vol_info, int volid, char *purpose, int total_page, int free_page, char *vol_name) { char *p; struct stat statbuf; vol_info->volid = volid; strcpy (vol_info->purpose, purpose); vol_info->total_page = total_page; vol_info->free_page = free_page; #ifdef WIN32 unix_style_path (vol_name); #endif p = strrchr (vol_name, '/'); if (p == NULL) { vol_info->location[0] = '\0'; vol_info->vol_name[0] = '\0'; } else { *p = '\0'; strcpy (vol_info->location, vol_name); strcpy (vol_info->vol_name, p + 1); *p = '/'; } stat (vol_name, &statbuf); vol_info->date = statbuf.st_mtime; }