sub_db_sybase_cfg.c

电信硬件的信息数据采集程序

			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			
			getcmsvrshmsize(pKPIValues,EachDBEntityCfg);
#ifdef DEBUG_OUT
			sprintf(DebugMsg,"pKPIValues is: %s  %s %s %s\n",\
				pKPIValues->EntityID,pKPIValues->CollTime,pKPIValues->KPIID,pKPIValues->KPIValue);
			writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif	
			putKPIValueQueue(pKPIValues);
		}
	}
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvrshmsize End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbname										|
| Description	: for KPI CM-00-03-01-06: get database name			           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbname()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbname"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbname Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbname.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbname.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI value */
			getcmdbname(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbname End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}


/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbbelongSvr								|
| Description	: for KPI CM-00-03-01-07: get database belonged server        	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbbelongSvr()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbbelongSvr"};
	char shellCommandStr[MAX_STRING_LENGTH];
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbbelongSvr Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	memset(temp,'\0',sizeof(temp));
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbbelongSvr.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmdbbelongSvr.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;

			memset(shellCommandStr,'\0',sizeof(shellCommandStr));
			sprintf(shellCommandStr,"awk -F= '{if($1!~/^#/ && $1~/SERVERNAME/) print $2}' %s",EachDBEntityCfg);
			getSingleValueFromShell(shellCommandStr,pKPIValues);
			/* put KPI Value to Queue */
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbbelongSvr End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbsize										|
| Description	: for KPI CM-00-03-01-08 :get database size						|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbsize()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbsize"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbsize Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbsize.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbsize.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI value */
			getcmdbsize(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbsize End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdblogsize									|
| Description	: for KPI CM-00-03-01-09 :get database logfile size           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdblogsize()
{
	char FuncName[128] = {"sub_db_sybase_getcmdblogsize"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdblogsize Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdblogsize.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdblogsize.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI value */
			getcmdblogsize(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdblogsize End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbshmsize									|
| Description	: for KPI CM-00-03-01-10 :get database share memory size       	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbshmsize()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbshmsize"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbshmsize Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);