X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=include%2Ffreenet%2Fidentityrequester.h;h=0b70abdf4e0a85119eb26200a3f4cc50b475fb2f;hb=4e96d123460d6363cf7274e36bd9357768eb86ad;hp=ebea4252474694a403f14f3a648519ae42df9d9e;hpb=d8f51eac91f86a1e00a05a5058a8fa9eb8732464;p=fms.git diff --git a/include/freenet/identityrequester.h b/include/freenet/identityrequester.h index ebea425..0b70abd 100644 --- a/include/freenet/identityrequester.h +++ b/include/freenet/identityrequester.h @@ -1,42 +1,20 @@ #ifndef _identity_requester_ #define _identity_requester_ -#include "../idatabase.h" -#include "../ilogger.h" -#include "../datetime.h" -#include "ifreenetregistrable.h" -#include "ifcpconnected.h" -#include "ifcpmessagehandler.h" -#include "iperiodicprocessor.h" +#include "iindexrequester.h" -class IdentityRequester:public IFreenetRegistrable,public IFCPConnected,public IFCPMessageHandler,public IPeriodicProcessor,public IDatabase,public ILogger +class IdentityRequester:public IIndexRequester { public: IdentityRequester(); - IdentityRequester(FCPv2 *fcp); - - void FCPConnected(); - void FCPDisconnected(); - - const bool HandleMessage(FCPMessage &message); - - void Process(); - - void RegisterWithThread(FreenetMasterThread *thread); + IdentityRequester(FCPv2::Connection *fcp); private: - void Initialize(); - void PopulateIDList(); // clear and re-populate m_ids with identities we want to query - void StartRequest(const long identityid); - const bool HandleAllData(FCPMessage &message); - const bool HandleGetFailed(FCPMessage &message); - void RemoveFromRequestList(const long identityid); - - DateTime m_tempdate; - std::string m_messagebase; - long m_maxrequests; - std::vector m_requesting; // list of ids we are currently requesting from - std::map m_ids; // map of all ids we know and whether we have requested file from them yet + virtual void Initialize(); + virtual void PopulateIDList(); // clear and re-populate m_ids with identities we want to query + void StartRequest(const long &identityid); + const bool HandleAllData(FCPv2::Message &message); + const bool HandleGetFailed(FCPv2::Message &message); };