自学教程：C++ BOOST_LOG_FUNCTION函数代码示例

void  SQLCode::_BuildNormalSQL(const SQLVarParms& varParms, SQLStatement& rSQLFormats, SQLStatement& rSqlStatement){	BOOST_LOG_FUNCTION();	if (!rSQLFormats.strCommonSQL.empty())	{		_BuildSQL(varParms, rSQLFormats.strCommonSQL, rSqlStatement.strCommonSQL);	}	else	{		if (rSQLFormats.strOracleSQL.empty() 			|| rSQLFormats.strMySQLSQL.empty() 			|| rSQLFormats.strSQLiteSQL.empty())		{			throw DataAccessException(ER_DB_ERR_SQLCode, "The MySQL or Oracle SQL or SQLite Format is empty");		}				// build Oracle SQL Statement		_BuildSQL(varParms, rSQLFormats.strOracleSQL, rSqlStatement.strOracleSQL, enumOracleDb);		// build MySQL SQL statement		_BuildSQL(varParms, rSQLFormats.strMySQLSQL, rSqlStatement.strMySQLSQL, enumMysqlDb);		// build SqliteDb SQL Statement		_BuildSQL(varParms, rSQLFormats.strSQLiteSQL, rSqlStatement.strSQLiteSQL, enumSqliteDb);	}	}

CInstrumentTickInfo& CInstrumentTickInfo::operator=(const CInstrumentTickInfo& instrumentTickInfo ){	BOOST_LOG_FUNCTION();	m_TickInfo = instrumentTickInfo.m_TickInfo;	return *this;}

//"%04d-%02d-%02d %02d:%02d:%02d"std::string CCFDServerUtilityFun::dataTimeToStr(time_t nTimeValue){	BOOST_LOG_FUNCTION();	std::string	strTimeString;	char* pszCurTime = NULL;	int nBufferSize = 256;	struct tm* pTM = NULL;	time_t time_Value = (time_t)nTimeValue;	pszCurTime =new char[nBufferSize];	memset(pszCurTime, 0, nBufferSize);	pTM = localtime(&(time_Value));	//TIMESTR--%Y%m%d%H%M%S	//format to string	if ( NULL != pTM )	{		sprintf(pszCurTime, "%04d-%02d-%02d %02d:%02d:%02d",			pTM->tm_year + 1900, pTM->tm_mon + 1, pTM->tm_mday,			pTM->tm_hour, pTM->tm_min, pTM->tm_sec); 		strTimeString = pszCurTime;     	}	delete pszCurTime;	pszCurTime = NULL;	pTM = NULL;	return strTimeString;}

void CMarketDataFileManager::setInstrumentBarInfoRequest( const CInstrumentBarInfoRequest& instrumentBarInfoRequest ){	BOOST_LOG_FUNCTION();	m_InstrumentBarInfoRequest = instrumentBarInfoRequest;	setAnalieType(AnalierType_Dispatch_MarkketData);}

int CServerManager::_InitServer(){	BOOST_LOG_FUNCTION();	int nFunRes = 0;	if (g_string_strServerAddress.empty())	{		LOG_ERROR<<"error! g_string_strServerAddress="<<g_string_strServerAddress;		nFunRes = -1;		return nFunRes;	}	{		boost::mutex::scoped_lock lock(m_mutexBrokerServer);		m_brokerServer.onConnected = boost::bind(&TA_Base_App::CServerManager::handleConnected, this, _1);//static boost::arg<1> _1;		m_brokerServer.onDisconnected = boost::bind(&TA_Base_App::CServerManager::handleDisconnected, this, _1);//static boost::arg<1> _1;		m_brokerServer.onReceived = boost::bind(&TA_Base_App::CServerManager::handleReceivedMessage, this, _1);//static boost::arg<1> _1;		m_brokerServer.onDeliverFailure = boost::bind(&TA_Base_App::CServerManager::handleDeliverFailure, this, _1);//static boost::arg<1> _1;		LOG_DEBUG<< "begin listen g_string_strServerAddress="<<g_string_strServerAddress;		m_brokerServer.listen(g_string_strServerAddress);	}	return nFunRes;}

void CConfigInfoHelper::_GetConifgFileInfo(){	BOOST_LOG_FUNCTION();	CFileSystemItem::LstLineT  lstLine;	CFileSystemItem::LstLineIterT  iterLst;	m_pConfigFileInfo->getAllLinesInFile(lstLine);	iterLst = lstLine.begin();	while (iterLst != lstLine.end())	{		std::string strLineTmp = *iterLst;		std::string strParamKey;		CParamItem* pParamItem = new CParamItem(strLineTmp);		strParamKey = pParamItem->getParamKey();		m_MapParamKeyParamItem.insert(MapParamKeyParamItemValueTypeT(strParamKey, pParamItem));		pParamItem = NULL;		iterLst++;	}//while	lstLine.clear();	return;}

void CConfigInfo::logInfo(){	BOOST_LOG_FUNCTION();	LOG_INFO<<"CConfigInfo::logInfo"		<<" "<<"m_strValue_ConfigFileName="<<m_strValue_ConfigFileName		<<" "<<"m_strValue_HistoryDataDirectory="<<m_strValue_HistoryDataDirectory		<<" "<<"m_strValue_SaveDataDirectoryBAR="<<m_strValue_SaveDataDirectoryBAR		<<" "<<"m_strValue_SaveDataDirectoryTIK="<<m_strValue_SaveDataDirectoryTIK		<<" "<<"m_strValue_DbType="<<m_strValue_DbType		<<" "<<"m_strValue_StartTime_InDB="<<m_strValue_StartTime_InDB		<<" "<<"m_strValue_StartTime_InFile="<<m_strValue_StartTime_InFile		<<" "<<"m_strValue_LoadMaxFilesSize="<<m_strValue_LoadMaxFilesSize		<<" "<<"m_strValue_AutoRun="<<m_strValue_AutoRun		<<" "<<"m_strValue_AutoRunTime="<<m_strValue_AutoRunTime;	LOG_INFO<<"CConfigInfo::logInfo"		<<" "<<"m_nValue_DbType="<<m_nValue_DbType		<<" "<<"m_nValue_StartTime="<<m_nValue_StartTime		<<" "<<"m_nValue_LoadMaxFilesSize="<<m_nValue_LoadMaxFilesSize		<<" "<<"m_nValue_AutoRun="<<m_nValue_AutoRun;	m_pSQLiteConfigFileOperParam->logInfo();	return;}

int CSqliteDbOper::_CreateDBTableTick(){	BOOST_LOG_FUNCTION();	int nFunRes = 0;	bool bExecRes = true;	std::string strSQL;	QSqlQuery* pSqlQuery = NULL;	pSqlQuery = new QSqlQuery(*m_pQSqlDataBaseTIK);	strSQL = _BuildSQLForCreateDBTableTick();	LOG_DEBUG<<"exec strSQL="<<strSQL;	bExecRes = pSqlQuery->exec(strSQL.c_str());	if (!bExecRes)	{		nFunRes = -1;		LOG_ERROR<<"Fail to exec sql:"<<strSQL<<" error:"<<pSqlQuery->lastError().text().toStdString();	}	if (NULL != pSqlQuery)	{		delete pSqlQuery;		pSqlQuery = NULL;	}	return nFunRes;}

int CFileSystemManager::removeOldFile(time_t nStarTime, MapTimeFileSystemItemT& mapTimeFileSystemItem ){	BOOST_LOG_FUNCTION();	int nFunRes = 0;	MapTimeFileSystemItemIterT iterMap;	time_t nFileTime;	CFileSystemItem* pFileSystemItem = NULL;	iterMap = mapTimeFileSystemItem.begin();		while (iterMap != mapTimeFileSystemItem.end())	{		nFileTime = iterMap->first;		pFileSystemItem = iterMap->second;		if (nFileTime <= nStarTime)		{			delete pFileSystemItem;			pFileSystemItem = NULL;			mapTimeFileSystemItem.erase(iterMap);			iterMap = mapTimeFileSystemItem.begin();		}		else		{			iterMap++;		}	}	return nFunRes;}

CMarketDataFileAnalier::CMarketDataFileAnalier(void){	BOOST_LOG_FUNCTION();	m_pUtilityFun = new CCFDServerUtilityFun();	m_pMarketDataDispatcher = new CMarketDataDispatcher();}

int CSyncMarketDataForCFD::_SyncLstCFDBarInfo(LstBarInfoT& lstBarInfoFirst, LstBarInfoT& lstBarInfoSecond, LstCFDBarInfoT& lstCFDBarInfo){	BOOST_LOG_FUNCTION();	int nFunRes = 0;	LstBarInfoIterT iterLstFirst;	LstBarInfoIterT iterLstSecond;	MarketData* pBarFirst = NULL;	MarketData* pBarSecond = NULL;	CCFDInstrumentBarInfo* pCFDInstrumentBarInfoTmp = NULL;	if (lstBarInfoFirst.size() != lstBarInfoSecond.size())	{		LOG_ERROR<<"_SyncLstCFDBarInfo size error!"			<<" "<<"lstBarInfoFirst.size()="<<lstBarInfoFirst.size()			<<" "<<"lstBarInfoSecond.size()="<<lstBarInfoSecond.size();		nFunRes = -1;		return nFunRes;	}	iterLstFirst = lstBarInfoFirst.begin();	iterLstSecond = lstBarInfoSecond.begin();	while (		(iterLstFirst != lstBarInfoFirst.end())		&& (iterLstSecond != lstBarInfoSecond.end())		)	{		pBarFirst = NULL;		pBarSecond = NULL;		pBarFirst = (*iterLstFirst);		pBarSecond = (*iterLstSecond);		pCFDInstrumentBarInfoTmp =new CCFDInstrumentBarInfo(m_CFDRequest);		pCFDInstrumentBarInfoTmp->setCFDRequest(m_CFDRequest);		pCFDInstrumentBarInfoTmp->setBarInfoFirst(*pBarFirst);		pCFDInstrumentBarInfoTmp->setBarInfoSecond(*pBarSecond);		nFunRes = pCFDInstrumentBarInfoTmp->buidCFDBarInfo();		if (0 != nFunRes)		{			LOG_ERROR<<"buildCFDMarketData DataFirst.Time != DataSecond.Time"				<<" ["<<"DataFirst.Time="<<m_pUtilityFun->dataTimeToStr(pBarFirst->getTime())<<"]"				<<" ["<<"DataSecond.Time="<<m_pUtilityFun->dataTimeToStr(pBarSecond->getTime())<<"]"; 		}		else		{			pCFDInstrumentBarInfoTmp->logInfo();		}		lstCFDBarInfo.push_back(pCFDInstrumentBarInfoTmp);		pCFDInstrumentBarInfoTmp = NULL;		iterLstFirst++;		iterLstSecond++;	}//while	return nFunRes;}

int main( int argc, char* argv[] ){	TA_Base_Test::CBoostLogger BoostLogger;	BOOST_LOG_FUNCTION();	TA_Base_Test::CTestCase* pTestCase = new TA_Base_Test::CTestCase();	if (1 == g_runAsServer)	{		pTestCase->runTestCase_ForServer();	}	else	{		pTestCase->runTestCase_ForClient();	}	//	//sleep	{			boost::mutex::scoped_lock lock(g_mutexMainRun);		g_conditionMainRun.wait(lock);	}	delete pTestCase;	pTestCase = NULL;	return 0;}

CInstrumentBarInfo& CInstrumentBarInfo::operator=(const CInstrumentBarInfo& instrumentBarInfo ){	BOOST_LOG_FUNCTION();	m_nInterval = instrumentBarInfo.m_nInterval;	m_BarInfo = instrumentBarInfo.m_BarInfo;	return *this;}

CZmqREQServerThread::CZmqREQServerThread(void){		BOOST_LOG_FUNCTION();		m_toTerminate = false;	m_nThreadJobState = JobState_Begin;}

CInstrumentBarInfoRequest& CInstrumentBarInfoRequest::operator=(const CInstrumentBarInfoRequest& instrumentBarInfoRequest ){	BOOST_LOG_FUNCTION();	m_strCurrentAnalierFileName = instrumentBarInfoRequest.m_strCurrentAnalierFileName;	m_strHistoryMarketDataTotal = instrumentBarInfoRequest.m_strHistoryMarketDataTotal;	m_strInstrumetBarInfoTotal = instrumentBarInfoRequest.m_strInstrumetBarInfoTotal;	_AddBarTimeNormal();	return *this;}

CConfigInfo::CConfigInfo(void){	BOOST_LOG_FUNCTION();	m_strConfigFileName.clear();	m_strConfigFileName = DEF_VALUE_strConfigFileName;	loadDefaultConfigInfo();}

CTOSReqEndTestFrame::CTOSReqEndTestFrame(void){	BOOST_LOG_FUNCTION();	m_nFrameType_SampleValue = C_TO_S_REQ_END_TEST;	m_strReqInfo_SampleValue = "client want to end Test!";	setSampleValue();}

STOCAckBeginTestFrame::STOCAckBeginTestFrame(void){	BOOST_LOG_FUNCTION();	m_nFrameType_SampleValue = S_TO_C_ACK_BEGIN_TEST;	m_strACKInfo_SampleValue = "Server is ready, you can begin to do Test Now!";	setSampleValue();}