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
void IdentityInserter::Initialize()\r
{\r
m_lastchecked=Poco::Timestamp();\r
+ m_lastreceivedmessage=Poco::Timestamp();\r
}\r
\r
void IdentityInserter::Process()\r
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