sub_db_sybase_cfg.c

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

			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,"gettempdbspcfreeradio.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"gettempdbspcfreeradio.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			gettempdbspcfreeradio(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_gettempdbspcfreeradio End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif

	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getpmdblogfreeradio								|
| Description	: for KPI PM-00-03-01-10:										|
|				  get logsegment free space radio								|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getpmdblogfreeradio()
{
	char FuncName[128] = {"sub_db_sybase_getpmdblogfreeradio"};
	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_getpmdblogfreeradio 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,"getpmdblogfreeradio.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getpmdblogfreeradio.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getpmdblogfreeradio(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getpmdblogfreeradio End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getpmdbloguseradio								|
| Description	: for KPI PM-00-03-01-11:										|
|				  get logsegment use space radio								|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getpmdbloguseradio()
{
	char FuncName[128] = {"sub_db_sybase_getpmdbloguseradio"};	
	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_getpmdbloguseradio 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,"getpmdbloguseradio.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getpmdbloguseradio.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getpmdbloguseradio(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getpmdbloguseradio End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getfmdbalonelocks								|
| Description	: for KPI FM-00-03-01-07:										|
|				  get the number of alone locks									|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getfmdbalonelocks()
{
	char FuncName[128] = {"sub_db_sybase_getfmdbalonelocks"};
	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_getfmdbalonelocks 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,"getfmdbalonelocks.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmdbalonelocks.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getfmdbalonelocks(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmdbalonelocks End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getfmconnections								|
| Description	: for KPI FM-00-03-01-09:										|
|				  get the number of database connections						|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getfmconnections()
{
	char FuncName[128] = {"sub_db_sybase_getfmconnections"};
	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_getfmconnections 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,"getfmconnections.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmconnections.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getfmconnections(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmconnections End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getfmdeadlocknum								|
| Description	: for KPI FM-00-03-01-06:										|
|				  get database dead lock count									|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getfmdeadlocknum()
{
	char FuncName[128] = {"sub_db_sybase_getfmdeadlocknum"};
	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_getfmdeadlocknum 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,'