X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=include%2Ffreenet%2Ffreenetmasterthread.h;h=f7f176c3cd58ba0c59a4a56e0f768319a5516195;hb=59a5414ec47a2932a7802fcd1d98c4d80166564f;hp=f84acc11ca907b2af6a79c8425dedecf09bb1e40;hpb=d8f51eac91f86a1e00a05a5058a8fa9eb8732464;p=fms.git diff --git a/include/freenet/freenetmasterthread.h b/include/freenet/freenetmasterthread.h index f84acc1..f7f176c 100644 --- a/include/freenet/freenetmasterthread.h +++ b/include/freenet/freenetmasterthread.h @@ -2,27 +2,28 @@ #define _freenetmasterthread_ #include "../ilogger.h" +#include "../ithreaddatabase.h" #include "ifreenetregistrable.h" #include "ifcpmessagehandler.h" #include "ifcpconnected.h" #include "iperiodicprocessor.h" -#include +#include "../threadwrapper/cancelablerunnable.h" // forward declaration class IFreenetRegistrable; -class FreenetMasterThread:public ZThread::Runnable,public ILogger, public IFCPMessageHandler +class FreenetMasterThread:public CancelableRunnable,public ILogger, public IFCPMessageHandler, public IThreadDatabase { public: FreenetMasterThread(); ~FreenetMasterThread(); - const bool HandleMessage(FCPMessage &message); + const bool HandleMessage(FCPv2::Message &message); void run(); - // registration methods for children objects + // registration methods for child objects void RegisterPeriodicProcessor(IPeriodicProcessor *obj); void RegisterFCPConnected(IFCPConnected *obj); void RegisterFCPMessageHandler(IFCPMessageHandler *obj); @@ -33,8 +34,8 @@ private: void Shutdown(); std::string m_fcphost; - long m_fcpport; - FCPv2 m_fcp; + int m_fcpport; + FCPv2::Connection m_fcp; std::vector m_registrables; std::vector m_processors; std::vector m_fcpconnected;