src/freenet/periodicdbmaintenance.cpp

   1 #include "../../include/freenet/periodicdbmaintenance.h"\r
   2 \r
   3 #ifdef XMEM\r
   4         #include <xmem.h>\r
   5 #endif\r
   6 \r
   7 PeriodicDBMaintenance::PeriodicDBMaintenance()\r
   8 {\r
   9         m_check10mins.SetToGMTime();\r
  10         m_check30mins.SetToGMTime();\r
  11         m_check1hour.SetToGMTime();\r
  12         m_check6hours.SetToGMTime();\r
  13         m_check1day.SetToGMTime();\r
  14 \r
  15         // set back times so they will do their first maintenance soon ( within the next hour ) - stagger so not all run at once\r
  16         m_check1hour.Add(0,-45);\r
  17         m_check6hours.Add(0,0,-5);\r
  18         m_check1day.Add(0,0,-23);\r
  19 \r
  20 }\r
  21 \r
  22 void PeriodicDBMaintenance::Do10MinuteMaintenance()\r
  23 {\r
  24 \r
  25         m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do10MinuteMaintenance");\r
  26 }\r
  27 \r
  28 void PeriodicDBMaintenance::Do30MinuteMaintenance()\r
  29 {\r
  30 \r
  31         m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do30MinuteMaintenance");\r
  32 }\r
  33 \r
  34 void PeriodicDBMaintenance::Do1HourMaintenance()\r
  35 {\r
  36         // recalculate all trust levels - this is CPU instensive\r
  37         // TODO - will probably have to change this to do 1 identity at a time as this locks that database for the duration\r
  38         m_db->Execute("UPDATE tblIdentity SET PeerMessageTrust=(SELECT PeerMessageTrust FROM vwCalculatedPeerTrust WHERE TargetIdentityID=IdentityID), PeerTrustListTrust=(SELECT PeerTrustListTrust FROM vwCalculatedPeerTrust WHERE TargetIdentityID=IdentityID);");\r
  39 \r
  40         m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do1HourMaintenance");\r
  41 }\r
  42 \r
  43 void PeriodicDBMaintenance::Do6HourMaintenance()\r
  44 {\r
  45 \r
  46         m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do6HourMaintenance");\r
  47 }\r
  48 \r
  49 void PeriodicDBMaintenance::Do1DayMaintenance()\r
  50 {\r
  51         DateTime date;\r
  52 \r
  53         // delete all puzzles 2 or more days old\r
  54         date.SetToGMTime();\r
  55         date.Add(0,0,0,-2);\r
  56         m_db->Execute("DELETE FROM tblIntroductionPuzzleInserts WHERE Day<='"+date.Format("%Y-%m-%d")+"';");\r
  57         m_db->Execute("DELETE FROM tblIntroductionPuzzleRequests WHERE Day<='"+date.Format("%Y-%m-%d")+"';");\r
  58 \r
  59         m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do1DayMaintenance");\r
  60 \r
  61 }\r
  62 \r
  63 void PeriodicDBMaintenance::Process()\r
  64 {\r
  65         DateTime now;\r
  66         now.SetToGMTime();\r
  67         \r
  68         if(m_check10mins<=(now-((1.0/1440.0)*10.0)))\r
  69         {\r
  70                 Do10MinuteMaintenance();\r
  71                 m_check10mins=now;\r
  72         }\r
  73         if(m_check30mins<=(now-((1.0/1440.0)*30.0)))\r
  74         {\r
  75                 Do30MinuteMaintenance();\r
  76                 m_check30mins=now;\r
  77         }\r
  78         if(m_check1hour<=(now-(1.0/24.0)))\r
  79         {\r
  80                 Do1HourMaintenance();\r
  81                 m_check1hour=now;\r
  82         }\r
  83         if(m_check6hours<=(now-(1.0/4.0)))\r
  84         {\r
  85                 Do6HourMaintenance();\r
  86                 m_check6hours=now;\r
  87         }\r
  88         if(m_check1day<=(now-(1.0)))\r
  89         {\r
  90                 Do1DayMaintenance();\r
  91                 m_check1day=now;\r
  92         }\r
  93 \r
  94 }\r
  95 \r
  96 void PeriodicDBMaintenance::RegisterWithThread(FreenetMasterThread *thread)\r
  97 {\r
  98         thread->RegisterPeriodicProcessor(this);\r
  99 }\r