+++ /dev/null
-#include "../../include/freenet/periodicdbmaintenance.h"\r
-#include "../../include/stringfunctions.h"\r
-#include "../../include/option.h"\r
-\r
-#ifdef XMEM\r
- #include <xmem.h>\r
-#endif\r
-\r
-PeriodicDBMaintenance::PeriodicDBMaintenance()\r
-{\r
- std::string tempval;\r
-\r
- m_check10mins.SetToGMTime();\r
- m_check30mins.SetToGMTime();\r
- m_check1hour.SetToGMTime();\r
- m_check6hours.SetToGMTime();\r
- m_check1day.SetToGMTime();\r
-\r
- // set back times so they will do their first maintenance soon ( within the next hour ) - stagger so not all run at once\r
- m_check30mins.Add(0,-5);\r
- m_check1hour.Add(0,-42);\r
- m_check6hours.Add(0,-1,-5);\r
- m_check1day.Add(0,0,-23);\r
-\r
- tempval="180";\r
- Option::Instance()->Get("DeleteMessagesOlderThan",tempval);\r
- StringFunctions::Convert(tempval,m_deletemessagesolderthan);\r
-\r
-}\r
-\r
-void PeriodicDBMaintenance::Do10MinuteMaintenance()\r
-{\r
-\r
- m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do10MinuteMaintenance");\r
-}\r
-\r
-void PeriodicDBMaintenance::Do30MinuteMaintenance()\r
-{\r
-\r
- m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do30MinuteMaintenance");\r
-}\r
-\r
-void PeriodicDBMaintenance::Do1HourMaintenance()\r
-{\r
- // recalculate all trust levels - this is CPU instensive\r
- // do 1 identity at a time as doing it with 1 UPDATE statement locks that database for the duration\r
- SQLite3DB::Statement st=m_db->Prepare("SELECT TargetIdentityID,PeerMessageTrust,PeerTrustListTrust FROM vwCalculatedPeerTrust;");\r
- SQLite3DB::Statement upd=m_db->Prepare("UPDATE tblIdentity SET PeerMessageTrust=?, PeerTrustListTrust=? WHERE IdentityID=?");\r
- st.Step();\r
- while(st.RowReturned())\r
- {\r
- int identityid=0;\r
- int trust=0;\r
- \r
- st.ResultInt(0,identityid);\r
-\r
- upd.Bind(0,identityid);\r
- if(st.ResultNull(1)==false)\r
- {\r
- trust=0;\r
- st.ResultInt(1,trust);\r
- upd.Bind(0,trust);\r
- }\r
- else\r
- {\r
- upd.Bind(0);\r
- }\r
- if(st.ResultNull(2)==false)\r
- {\r
- trust=0;\r
- st.ResultInt(2,trust);\r
- upd.Bind(1,trust);\r
- }\r
- else\r
- {\r
- upd.Bind(1);\r
- }\r
- upd.Bind(2,identityid);\r
- upd.Step();\r
- upd.Reset();\r
-\r
- st.Step();\r
- }\r
-\r
- // set null peer trust for identities without a calculated trust\r
- st=m_db->Prepare("SELECT IdentityID FROM tblIdentity WHERE IdentityID NOT IN (SELECT TargetIdentityID FROM vwCalculatedPeerTrust);");\r
- upd=m_db->Prepare("UPDATE tblIdentity SET PeerMessageTrust=NULL, PeerTrustListTrust=NULL WHERE IdentityID=?;");\r
- st.Step();\r
- while(st.RowReturned())\r
- {\r
- int identityid=0;\r
- st.ResultInt(0,identityid);\r
- upd.Bind(0,identityid);\r
- upd.Step();\r
- upd.Reset();\r
- st.Step();\r
- }\r
-\r
- m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do1HourMaintenance");\r
-}\r
-\r
-void PeriodicDBMaintenance::Do6HourMaintenance()\r
-{\r
-\r
- // if we remove a board and the reply boardid is still set to it, we need to replace it with a boardid that does exist\r
- SQLite3DB::Statement st=m_db->Prepare("SELECT MessageID FROM tblMessage WHERE ReplyBoardID NOT IN (SELECT BoardID FROM tblBoard);");\r
- SQLite3DB::Statement st2=m_db->Prepare("SELECT BoardID FROM tblMessageBoard WHERE MessageID=?;");\r
- SQLite3DB::Statement upd=m_db->Prepare("UPDATE tblMessage SET ReplyBoardID=? WHERE MessageID=?;");\r
- st.Step();\r
- while(st.RowReturned())\r
- {\r
- // find a valid boardid for the message\r
- int messageid=0;\r
- int boardid=0;\r
-\r
- st.ResultInt(0,messageid);\r
-\r
- st2.Bind(0,messageid);\r
- st2.Step();\r
- if(st2.RowReturned())\r
- {\r
- st2.ResultInt(0,boardid);\r
- upd.Bind(0,boardid);\r
- upd.Bind(1,messageid);\r
- upd.Step();\r
- upd.Reset();\r
- }\r
- st2.Reset();\r
- \r
- st.Step();\r
- }\r
-\r
- m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do6HourMaintenance");\r
-}\r
-\r
-void PeriodicDBMaintenance::Do1DayMaintenance()\r
-{\r
- DateTime date;\r
-\r
- // delete all puzzles 2 or more days old\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-2);\r
- m_db->Execute("DELETE FROM tblIntroductionPuzzleInserts WHERE Day<='"+date.Format("%Y-%m-%d")+"';");\r
- m_db->Execute("DELETE FROM tblIntroductionPuzzleRequests WHERE Day<='"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete all identities we've never seen and were added more than 20 days ago\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-20);\r
- m_db->Execute("DELETE FROM tblIdentity WHERE LastSeen IS NULL AND DateAdded<'"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete old identity requests - we don't need them anymore\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-2);\r
- m_db->Execute("DELETE FROM tblIdentityRequests WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete old board list inserts/requests - we don't need them anymore\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-2);\r
- m_db->Execute("DELETE FROM tblBoardListInserts WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
- m_db->Execute("DELETE FROM tblBoardListRequests WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete old local identity inserts - we don't need them anymore\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-2);\r
- m_db->Execute("DELETE FROM tblLocalIdentityInserts WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete old message list inserts/requests - we don't need them anymore\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-2);\r
- m_db->Execute("DELETE FROM tblMessageListInserts WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
- m_db->Execute("DELETE FROM tblMessageListRequests WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete old trust list inserts/requests - we don't need them anymore\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-2);\r
- m_db->Execute("DELETE FROM tblTrustListInserts WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
- m_db->Execute("DELETE FROM tblTrustListRequests WHERE Day<'"+date.Format("%Y-%m-%d")+"';");\r
-\r
- // delete trust lists from identities we aren't trusting anymore\r
- m_db->Execute("DELETE FROM tblPeerTrust WHERE IdentityID NOT IN (SELECT IdentityID FROM tblIdentity WHERE (LocalTrustListTrust>=(SELECT OptionValue FROM tblOption WHERE Option='MinLocalTrustListTrust')) AND (PeerTrustListTrust IS NULL OR PeerTrustListTrust>=(SELECT OptionValue FROM tblOption WHERE Option='MinPeerTrustListTrust')));");\r
-\r
- // remove identityid from messages where the identity has been deleted\r
- m_db->Execute("UPDATE tblMessage SET IdentityID=NULL WHERE IdentityID NOT IN (SELECT IdentityID FROM tblIdentity);");\r
-\r
- // try to re-attach messages from identities that were previously deleted, but have been since re-added\r
- // first get the names from messages that have a NULL IdentityID\r
- SQLite3DB::Statement st=m_db->Prepare("SELECT FromName FROM tblMessage WHERE IdentityID IS NULL GROUP BY FromName;");\r
- st.Step();\r
- while(st.RowReturned())\r
- {\r
- std::string name="";\r
- std::string namepart="";\r
- std::string publickey="";\r
- int identityid=0;\r
- st.ResultText(0,name);\r
-\r
- std::vector<std::string> parts;\r
- StringFunctions::Split(name,"@",parts);\r
-\r
- // name can have a @ in it - so reattach all parts except the last which is the key\r
- for(long i=0; i<parts.size()-1; i++)\r
- {\r
- if(i!=0)\r
- {\r
- namepart+="@";\r
- }\r
- namepart+=parts[i];\r
- }\r
-\r
- // find identities with this name\r
- SQLite3DB::Statement st2=m_db->Prepare("SELECT IdentityID,PublicKey FROM tblIdentity WHERE Name=?;");\r
- st2.Bind(0,namepart);\r
- st2.Step();\r
- while(st2.RowReturned())\r
- {\r
- publickey="";\r
- identityid=0;\r
- st2.ResultText(1,publickey);\r
- // check if public key matches 2nd part\r
- if(parts.size()>1 && publickey.find(parts[1])==4)\r
- {\r
- // we have the identity - so update the messages table with the identityid\r
- st2.ResultInt(0,identityid);\r
-\r
- SQLite3DB::Statement st3=m_db->Prepare("UPDATE tblMessage SET IdentityID=? WHERE FromName=? AND IdentityID IS NULL;");\r
- st3.Bind(0,identityid);\r
- st3.Bind(1,name);\r
- st3.Step();\r
- }\r
- st2.Step();\r
- }\r
-\r
- st.Step();\r
- }\r
-\r
- // delete single use identities that are older than 7 days\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-7);\r
- st=m_db->Prepare("DELETE FROM tblIdentity WHERE SingleUse='true' AND DateAdded<?;");\r
- st.Bind(0,date.Format("%Y-%m-%d %H:%M:%S"));\r
- st.Step();\r
-\r
- // delete local single use identities that are older than 7 days\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-7);\r
- st=m_db->Prepare("DELETE FROM tblLocalIdentity WHERE SingleUse='true' AND DateCreated<?;");\r
- st.Bind(0,date.Format("%Y-%m-%d %H:%M:%S"));\r
- st.Step();\r
-\r
- // delete old messages\r
- date.SetToGMTime();\r
- date.Add(0,0,0,-m_deletemessagesolderthan);\r
- st=m_db->Prepare("DELETE FROM tblMessage WHERE MessageDate<?;");\r
- st.Bind(0,date.Format("%Y-%m-%d"));\r
- st.Step();\r
-\r
- // delete tblIdentityTrust for local identities and identities that have been deleted\r
- m_db->Execute("DELETE FROM tblIdentityTrust WHERE LocalIdentityID NOT IN (SELECT LocalIdentityID FROM tblLocalIdentity);");\r
- m_db->Execute("DELETE FROM tblIdentityTrust WHERE IdentityID NOT IN (SELECT IdentityID FROM tblIdentity);");\r
-\r
- m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do1DayMaintenance");\r
-\r
-}\r
-\r
-void PeriodicDBMaintenance::Process()\r
-{\r
- DateTime now;\r
- now.SetToGMTime();\r
- \r
- if(m_check10mins<=(now-((1.0/1440.0)*10.0)))\r
- {\r
- Do10MinuteMaintenance();\r
- m_check10mins=now;\r
- }\r
- if(m_check30mins<=(now-((1.0/1440.0)*30.0)))\r
- {\r
- Do30MinuteMaintenance();\r
- m_check30mins=now;\r
- }\r
- if(m_check1hour<=(now-(1.0/24.0)))\r
- {\r
- Do1HourMaintenance();\r
- m_check1hour=now;\r
- }\r
- if(m_check6hours<=(now-(1.0/4.0)))\r
- {\r
- Do6HourMaintenance();\r
- m_check6hours=now;\r
- }\r
- if(m_check1day<=(now-(1.0)))\r
- {\r
- Do1DayMaintenance();\r
- m_check1day=now;\r
- }\r
-\r
-}\r
-\r
-void PeriodicDBMaintenance::RegisterWithThread(FreenetMasterThread *thread)\r
-{\r
- thread->RegisterPeriodicProcessor(this);\r
-}\r
projects / fms.git / blobdiff