X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ffreenet%2Ffreenetmasterthread.cpp;fp=src%2Ffreenet%2Ffreenetmasterthread.cpp;h=9e0670cc77448b543fe05af5429f9dd72fec91de;hb=dec33c63afafabf83c3039e916725cac6faef9b3;hp=a6445addcadd883401c8b8ae27634145f5b4454c;hpb=9b22dd53fe62e312c1647310b7ec43aa127090af;p=fms.git diff --git a/src/freenet/freenetmasterthread.cpp b/src/freenet/freenetmasterthread.cpp index a6445ad..9e0670c 100644 --- a/src/freenet/freenetmasterthread.cpp +++ b/src/freenet/freenetmasterthread.cpp @@ -1,6 +1,5 @@ #include "../../include/freenet/freenetmasterthread.h" #include "../../include/option.h" -#include "../../include/uuidgenerator.h" #include "../../include/stringfunctions.h" #include "../../include/freenet/unkeyedidcreator.h" #include "../../include/freenet/identityinserter.h" @@ -12,15 +11,19 @@ #include "../../include/freenet/trustlistinserter.h" #include "../../include/freenet/trustlistrequester.h" #include "../../include/freenet/messagelistrequester.h" +#include "../../include/freenet/messagelistinserter.h" #include "../../include/freenet/messagerequester.h" #include "../../include/freenet/messageinserter.h" -#include "../../include/freenet/messagelistinserter.h" -#include "../../include/freenet/periodicdbmaintenance.h" #include "../../include/freenet/boardlistinserter.h" #include "../../include/freenet/boardlistrequester.h" #include "../../include/freenet/siteinserter.h" #include "../../include/freenet/fileinserter.h" -#include "../../include/pthreadwrapper/thread.h" + +#include +#include +#include +#include +#include #include @@ -71,16 +74,27 @@ const bool FreenetMasterThread::FCPConnect() m_receivednodehello=false; } - m_log->WriteLog(LogFile::LOGLEVEL_INFO,"FreenetMasterThread::FCPConnect trying to connect to node "+m_fcphost); + m_log->information("FreenetMasterThread::FCPConnect trying to connect to node "+m_fcphost); if(m_fcp.Connect(m_fcphost.c_str(),m_fcpport)==true) { - UUIDGenerator uuid; - std::string clientname="FMSClient-"+uuid.Generate(); + Poco::UUIDGenerator uuidgen; + Poco::UUID uuid; + + try + { + uuid=uuidgen.createRandom(); + } + catch(...) + { + m_log->fatal("FreenetMasterThread::FCPConnect could not generate UUID"); + } + + std::string clientname="FMSClient-"+uuid.toString(); // send ClientHello message to node m_fcp.SendMessage("ClientHello",2,"Name",clientname.c_str(),"ExpectedVersion","2.0"); - m_log->WriteLog(LogFile::LOGLEVEL_INFO,"FreenetMasterThread::FCPConnect connected to node"); + m_log->information("FreenetMasterThread::FCPConnect connected to node"); return true; } @@ -122,7 +136,7 @@ const bool FreenetMasterThread::HandleMessage(FCPMessage &message) { info+="\t\t\t\t"+(*mi).first+"="+(*mi).second+"\r\n"; } - m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"FreenetMasterThread::HandleMessage received unhandled "+message.GetName()+" message. Message content :\r\n"+info); + m_log->debug("FreenetMasterThread::HandleMessage received unhandled "+message.GetName()+" message. Message content :\r\n"+info); // if unhandled message was alldata - we must retrieve the data if(message.GetName()=="AllData") @@ -147,7 +161,7 @@ const bool FreenetMasterThread::HandleMessage(FCPMessage &message) } else { - m_log->WriteLog(LogFile::LOGLEVEL_ERROR,"FreenetMasterThread::HandleMessage received "+message.GetName()+" message before NodeHello"); + m_log->error("FreenetMasterThread::HandleMessage received "+message.GetName()+" message before NodeHello"); } return false; @@ -168,19 +182,18 @@ void FreenetMasterThread::RegisterPeriodicProcessor(IPeriodicProcessor *obj) m_processors.push_back(obj); } -void FreenetMasterThread::Run() +void FreenetMasterThread::run() { - DateTime lastreceivedmessage; - DateTime lastconnected; - DateTime now; + Poco::DateTime lastreceivedmessage; + Poco::DateTime lastconnected; + Poco::DateTime now; FCPMessage message; bool done=false; - lastconnected.SetToGMTime(); - lastconnected.Add(0,-1); + lastconnected-=Poco::Timespan(0,0,1,0,0); - m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"FreenetMasterThread::run thread started."); + m_log->debug("FreenetMasterThread::run thread started."); Setup(); @@ -189,28 +202,28 @@ void FreenetMasterThread::Run() if(m_fcp.Connected()==false) { // wait at least 1 minute since last successful connect - now.SetToGMTime(); - if(lastconnected<=(now-(1.0/1440.0))) + now=Poco::Timestamp(); + if(lastconnected<=(now-Poco::Timespan(0,0,1,0,0))) { if(FCPConnect()==false) { - m_log->WriteLog(LogFile::LOGLEVEL_ERROR,"FreenetMasterThread::run could not connect to node. Waiting 60 seconds."); + m_log->error("FreenetMasterThread::run could not connect to node. Waiting 60 seconds."); for(int i=0; i<60 && !IsCancelled(); i++) { - Sleep(1000); + Poco::Thread::sleep(1000); } } else { - lastreceivedmessage.SetToGMTime(); - lastconnected.SetToGMTime(); + lastreceivedmessage=Poco::Timestamp(); + lastconnected=Poco::Timestamp(); } } else { - Sleep(1000); + Poco::Thread::sleep(1000); } } // fcp is connected @@ -227,7 +240,7 @@ void FreenetMasterThread::Run() if(message.GetName()!="") { HandleMessage(message); - lastreceivedmessage.SetToGMTime(); + lastreceivedmessage=Poco::Timestamp(); } } @@ -238,16 +251,16 @@ void FreenetMasterThread::Run() } // if we haven't received any messages from the node in 10 minutes, something is wrong - now.SetToGMTime(); - if(lastreceivedmessage<(now-(1.0/144.0))) + now=Poco::Timestamp(); + if(lastreceivedmessage<(now-Poco::Timespan(0,0,10,0,0))) { - m_log->WriteLog(LogFile::LOGLEVEL_ERROR,"FreenetMasterThread::Run The Freenet node has not responded in 10 minutes. Trying to reconnect."); + m_log->error("FreenetMasterThread::Run The Freenet node has not responded in 10 minutes. Trying to reconnect."); m_fcp.Disconnect(); } if(m_fcp.Connected()==false) { - m_log->WriteLog(LogFile::LOGLEVEL_INFO,"FreenetMasterThread::Run Disconnected from Freenet node."); + m_log->information("FreenetMasterThread::Run Disconnected from Freenet node."); } } @@ -257,7 +270,7 @@ void FreenetMasterThread::Run() Shutdown(); - m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"FreenetMasterThread::run thread exiting."); + m_log->debug("FreenetMasterThread::run thread exiting."); } @@ -278,13 +291,12 @@ void FreenetMasterThread::Setup() m_registrables.push_back(new TrustListRequester(&m_fcp)); m_registrables.push_back(new MessageListInserter(&m_fcp)); m_registrables.push_back(new MessageListRequester(&m_fcp)); - m_registrables.push_back(new MessageRequester(&m_fcp)); m_registrables.push_back(new MessageInserter(&m_fcp)); + m_registrables.push_back(new MessageRequester(&m_fcp)); m_registrables.push_back(new BoardListInserter(&m_fcp)); m_registrables.push_back(new BoardListRequester(&m_fcp)); m_registrables.push_back(new SiteInserter(&m_fcp)); m_registrables.push_back(new FileInserter(&m_fcp)); - m_registrables.push_back(new PeriodicDBMaintenance()); for(std::vector::iterator i=m_registrables.begin(); i!=m_registrables.end(); i++) {