//--------------------------------//		coder 	Cai jianyu,Yuan Zhijian,Meng Qing//		begin 	2002//		v1		2003-01//		v2		2003-08-10 move all multithread code to the same class//--------------------------------#include <TimeOutThread.h>#include <algorithm>#include <DataRecovery_impl.h>#ifdef HAS_DEBUG_LEVEL#include "LogClient.h"extern LogClient * g_pLogWriter;#endifCTimeOutThread::CTimeOutThread(long lTimeOut, long lInterval){	DRList.clear();	m_lTimeOut = lTimeOut;	m_lInterval = lInterval;}CTimeOutThread::~CTimeOutThread(){	DRList.clear();}//如果有客戶端調用，將調用對象加入到超時隊列中void CTimeOutThread::addNode(const char * ipport, DataRecovery_impl* theDR){	MultiSync;	Elem_T e;	e.ipport = ipport;	e.pDR = theDR;	DRList.push_back(e);}//客戶端異常退出時釋放資源void CTimeOutThread::delNodebyIp(const char * ipport){	MultiSync;	list<Elem_T>::iterator pos;	for (pos = DRList.begin(); pos != DRList.end();)	{		if ( compareIPPORT(*pos, ipport) )		{			list<Elem_T>::iterator old = pos++;						//CORBA::String_var str = (*old).pDR->getUserID();						//RESULTDSTROY(str.in(),(*old).ipport.c_str(), "quit without invoke destroy")						//(*old).pDR->destroyInner();			DRList.erase(old);			cout<<"client quit abnormally"<<endl;					}		else ++pos;	}}void CTimeOutThread::delNodebyPointer(DataRecovery_impl* theDR){	MultiSync;	list<Elem_T>::iterator pos;	for (pos = DRList.begin(); pos != DRList.end();)	{		if ( comparepDR(*pos, theDR) )		{			list<Elem_T>::iterator old = pos++;						//CORBA::String_var str = (*old).pDR->getUserID();			//RESULTDSTROY(str.in(),(*old).ipport.c_str(), "quit by invoke destroy")						DRList.erase(old);		}		else ++pos;	}}//	判斷是否有超時的結果集bool CTimeOutThread::bTimeOut(DataRecovery_impl* theDR){	curr_int = time(0);	return theDR->isTimeOut(curr_int);}//超時釋放void CTimeOutThread::DelNodeInner(){	MultiSync;		list<Elem_T>::iterator pos;	for (pos = DRList.begin(); pos != DRList.end();)	{		DataRecovery_impl* theDR = (*pos).pDR;		if (bTimeOut(theDR))		{			list<Elem_T>::iterator old = pos++;						//CORBA::String_var str = (*old).pDR->getUserID();			//RESULTDSTROY(str.in(),(*old).ipport.c_str(), "quit by timeout")						//theDR->destroyInner();			DRList.erase(old);		}		else ++pos;	}}//原來的時間判斷函數有問題，在一個長時間的操作之后會判斷錯誤，bTimeOut(),現已經修改//baixiaobo , 20040910//	循環檢查結果集列表中是否有超時的結果集對象void CTimeOutThread::run(){//	cout << "m_lInterval = " << m_lInterval << endl;	for( ; ; )	{		//thetime = time(0);		//curr_time = localtime(&thetime);		//curr_int = curr_time->tm_hour*3600 + curr_time->tm_min*60 + curr_time->tm_sec ;		try		{			DelNodeInner();		}		catch(CORBA::Exception& e)		{			cout << "error in delete timeout IResult" <<endl;			cout << e <<endl;		}		//cout << "int timeout "<<m_lInterval<<endl;#ifdef __UNIX__		sleep(m_lInterval);#endif#ifdef _WIN32		Sleep(m_lInterval);#endif	}}bool CTimeOutThread::IsNil(){//	cout << "DRList.size() = " << DRList.size() << endl;	return DRList.size() == 0;}void CTimeOutThread::ReleaseAll(){	MultiSync;	//for (int i=0; i<DRList.size(); i++)	//{//		cout << "DRList.size() = " << DRList.size() << endl;	//	DRList[i]->destroyInner();	//}	list<Elem_T>::iterator pos;//	for (pos = DRList.begin(); pos != DRList.end(); ++pos)//	{//		//(*pos).pDR->destroyInner();//	}	DRList.clear();//	cout << "out ReleaseAll" << endl;}