X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;ds=sidebyside;f=include%2Ffreenet%2Fidentityrequester.h;h=601bdc96722c7a80472606c3aa7ec28b6f1f9452;hb=ed0732b2550c23c05fc9faf925620e87ee6dee12;hp=2ded93ad8a9a4c699bd30ccbad0174534153bce1;hpb=6b896a9e1dc143bba86795be1e9336549db9b85f;p=fms.git diff --git a/include/freenet/identityrequester.h b/include/freenet/identityrequester.h index 2ded93a..601bdc9 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(SQLite3DB::DB *db); + IdentityRequester(SQLite3DB::DB *db, 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; - long m_maxrequests; - std::string m_messagebase; - 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); };