version 0.3.33

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

diff --git a/src/freenet/identityinserter.cpp b/src/freenet/identityinserter.cpp
index a18aa0e..988aa25 100644 (file)
--- a/src/freenet/identityinserter.cpp
+++ b/src/freenet/identityinserter.cpp
@@ -64,6 +64,7 @@ const bool IdentityInserter::HandleMessage(FCPv2::Message &message)
                std::vector<std::string> idparts;\r
 \r
                StringFunctions::Split(message["Identifier"],"|",idparts);\r
+               m_lastreceivedmessage=now;\r
 \r
                // no action for URIGenerated\r
                if(message.GetName()=="URIGenerated")\r
@@ -137,6 +138,7 @@ const bool IdentityInserter::HandleMessage(FCPv2::Message &message)
 void IdentityInserter::Initialize()\r
 {\r
        m_lastchecked=Poco::Timestamp();\r
+       m_lastreceivedmessage=Poco::Timestamp();\r
 }\r
 \r
 void IdentityInserter::Process()\r
@@ -149,6 +151,17 @@ void IdentityInserter::Process()
                m_lastchecked=now;\r
        }\r
 \r
+       if(m_lastreceivedmessage<(now-Poco::Timespan(0,0,10,0,0)))\r
+       {\r
+               SQLite3DB::Statement st=m_db->Prepare("SELECT IdentityID FROM tblIdentity WHERE InsertingIdentity='true';");\r
+               st.Step();\r
+               if(st.RowReturned())\r
+               {\r
+                       m_log->debug("IdentityInserter::Process 10 minutes have passed without an insert response from the node.  Restarting inserts.");\r
+                       m_db->Execute("UPDATE tblLocalIdentity SET InsertingIdentity='false';");\r
+               }\r
+       }\r
+\r
 }\r
 \r
 void IdentityInserter::RegisterWithThread(FreenetMasterThread *thread)\r