version 0.1.3

[fms.git] / src / freenet / freenetmasterthread.cpp

diff --git a/src/freenet/freenetmasterthread.cpp b/src/freenet/freenetmasterthread.cpp
index 689641f..398d8fa 100644 (file)
--- a/src/freenet/freenetmasterthread.cpp
+++ b/src/freenet/freenetmasterthread.cpp
@@ -17,7 +17,8 @@
 #include "../../include/freenet/messageinserter.h"\r
 #include "../../include/freenet/messagelistinserter.h"\r
 \r
-#include <zthread/Thread.h>\r
+//#include <zthread/Thread.h>\r
+#include "../../include/pthreadwrapper/thread.h"\r
 \r
 #ifdef XMEM\r
        #include <xmem.h>\r
@@ -27,22 +28,22 @@ FreenetMasterThread::FreenetMasterThread()
 {\r
        std::string fcpport;\r
 \r
-       if(Option::instance()->Get("FCPHost",m_fcphost)==false)\r
+       if(Option::Instance()->Get("FCPHost",m_fcphost)==false)\r
        {\r
                m_fcphost="localhost";\r
-               Option::instance()->Set("FCPHost",m_fcphost);\r
+               Option::Instance()->Set("FCPHost",m_fcphost);\r
        }\r
-       if(Option::instance()->Get("FCPPort",fcpport)==false)\r
+       if(Option::Instance()->Get("FCPPort",fcpport)==false)\r
        {\r
                fcpport="9481";\r
-               Option::instance()->Set("FCPPort",fcpport);\r
+               Option::Instance()->Set("FCPPort",fcpport);\r
        }\r
 \r
        // convert fcp port to long, and make sure it's within the valid port range\r
        if(StringFunctions::Convert(fcpport,m_fcpport)==false)\r
        {\r
                m_fcpport=9481;\r
-               Option::instance()->Set("FCPPort","9481");\r
+               Option::Instance()->Set("FCPPort","9481");\r
        }\r
 \r
        m_receivednodehello=false;\r
@@ -163,12 +164,14 @@ void FreenetMasterThread::RegisterPeriodicProcessor(IPeriodicProcessor *obj)
        m_processors.push_back(obj);\r
 }\r
 \r
-void FreenetMasterThread::run()\r
+void FreenetMasterThread::Run()\r
 {\r
 \r
        FCPMessage message;\r
        bool done=false;\r
 \r
+       m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"FreenetMasterThread::run thread started.");\r
+\r
        Setup();\r
 \r
        do\r
@@ -181,6 +184,7 @@ void FreenetMasterThread::run()
                                m_log->WriteLog(LogFile::LOGLEVEL_ERROR,"FreenetMasterThread::run could not connect to node.  Waiting 60 seconds.");\r
 \r
                                // wait 60 seconds - will then try to connect again\r
+                               /*\r
                                try\r
                                {\r
                                        ZThread::Thread::sleep(60000);\r
@@ -189,6 +193,11 @@ void FreenetMasterThread::run()
                                {\r
                                        done=true;\r
                                }\r
+                               */\r
+                               for(int i=0; i<60,!IsCancelled(); i++)\r
+                               {\r
+                                       Sleep(1000);\r
+                               }\r
                        }\r
                }\r
                // fcp is connected\r
@@ -215,7 +224,8 @@ void FreenetMasterThread::run()
                        }\r
 \r
                }\r
-       }while(!ZThread::Thread::interrupted() && done==false);\r
+//     }while(!ZThread::Thread::interrupted() && done==false);\r
+       }while(!IsCancelled() && done==false);\r
 \r
        m_fcp.Disconnect();\r
 \r