version 0.1.9

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

diff --git a/src/freenet/periodicdbmaintenance.cpp b/src/freenet/periodicdbmaintenance.cpp
new file mode 100644 (file)
index 0000000..22a4ccf
--- /dev/null
+++ b/src/freenet/periodicdbmaintenance.cpp
@@ -0,0 +1,99 @@
+#include "../../include/freenet/periodicdbmaintenance.h"\r
+\r
+#ifdef XMEM\r
+       #include <xmem.h>\r
+#endif\r
+\r
+PeriodicDBMaintenance::PeriodicDBMaintenance()\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_check1hour.Add(0,-45);\r
+       m_check6hours.Add(0,0,-5);\r
+       m_check1day.Add(0,0,-23);\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
+       // TODO - will probably have to change this to do 1 identity at a time as this locks that database for the duration\r
+       m_db->Execute("UPDATE tblIdentity SET PeerMessageTrust=(SELECT PeerMessageTrust FROM vwCalculatedPeerTrust WHERE TargetIdentityID=IdentityID), PeerTrustListTrust=(SELECT PeerTrustListTrust FROM vwCalculatedPeerTrust WHERE TargetIdentityID=IdentityID);");\r
+\r
+       m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do1HourMaintenance");\r
+}\r
+\r
+void PeriodicDBMaintenance::Do6HourMaintenance()\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
+       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