X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=include%2Ffreenet%2Fiindexrequester.h;h=37dcdda7ce1d81643b200031bfcd9a5c5730997c;hb=4e96d123460d6363cf7274e36bd9357768eb86ad;hp=678e43e118cb89f422d5c0b35fdcecaa28190c03;hpb=278ee758050cb7772cd95946688c5b40104f4d8b;p=fms.git diff --git a/include/freenet/iindexrequester.h b/include/freenet/iindexrequester.h index 678e43e..37dcdda 100644 --- a/include/freenet/iindexrequester.h +++ b/include/freenet/iindexrequester.h @@ -14,6 +14,8 @@ #include #include +#include + #ifdef XMEM #include #endif @@ -23,12 +25,12 @@ class IIndexRequester:public IFreenetRegistrable,public IFCPConnected,public IFC { public: IIndexRequester(); - IIndexRequester(FCPv2 *fcp); + IIndexRequester(FCPv2::Connection *fcp); virtual ~IIndexRequester() {} virtual void FCPConnected(); virtual void FCPDisconnected(); - virtual const bool HandleMessage(FCPMessage &message); + virtual const bool HandleMessage(FCPv2::Message &message); virtual void Process(); @@ -39,8 +41,8 @@ protected: virtual void Initialize()=0; // initialize m_maxrequests and m_fcpuniquename virtual void PopulateIDList()=0; virtual void StartRequest(const IDTYPE &id)=0; - virtual const bool HandleAllData(FCPMessage &message)=0; - virtual const bool HandleGetFailed(FCPMessage &message)=0; + virtual const bool HandleAllData(FCPv2::Message &message)=0; + virtual const bool HandleGetFailed(FCPv2::Message &message)=0; virtual void RemoveFromRequestList(const IDTYPE id); Poco::DateTime m_tempdate; @@ -63,7 +65,7 @@ IIndexRequester::IIndexRequester() } template -IIndexRequester::IIndexRequester(FCPv2 *fcp):IFCPConnected(fcp) +IIndexRequester::IIndexRequester(FCPv2::Connection *fcp):IFCPConnected(fcp) { InitializeIIndexRequester(); } @@ -82,7 +84,7 @@ void IIndexRequester::FCPConnected() } if(m_fcpuniquename.find("|")!=std::string::npos) { - m_log->fatal("IIndexRequester::FCPConnected fcpuniquename contains | character! This is not a valid character!"); + m_log->fatal("IIndexRequester::FCPConnected fcpuniquename "+m_fcpuniquename+" contains | character! This is not a valid character!"); } m_lastreceived=Poco::Timestamp(); @@ -98,7 +100,7 @@ void IIndexRequester::FCPDisconnected() } template -const bool IIndexRequester::HandleMessage(FCPMessage &message) +const bool IIndexRequester::HandleMessage(FCPv2::Message &message) { if(message["Identifier"].find(m_fcpuniquename)==0) @@ -208,11 +210,8 @@ void IIndexRequester::RegisterWithThread(FreenetMasterThread *thread) template void IIndexRequester::RemoveFromRequestList(const IDTYPE id) { - typename std::vector::iterator i=m_requesting.begin(); - while(i!=m_requesting.end() && (*i)!=id) - { - i++; - } + typename std::vector::iterator i=std::find(m_requesting.begin(),m_requesting.end(),id); + if(i!=m_requesting.end()) { m_requesting.erase(i);