Changeset 12538 for trunk/FACT++

Timestamp:

11/16/11 15:53:10 (13 years ago)

Author:

lyard

Message:

moved the flush from every row entry to every minute

File:

• trunk/FACT++/src/datalogger.cc (modified) (4 diffs)

trunk/FACT++/src/datalogger.cc

@@ -389 +389 @@
     //Current day variable. Used to close nightly files when night changes
     int fCurrentDay;
+    Time lastFlush;
 public:
     int Write(const Time &time, const std::string &txt, int qos=kMessage);
@@ -759 +760 @@
     const Time nowMinusTwelve = timeNow-boost::posix_time::hours(12);
     fCurrentDay = nowMinusTwelve.M()*31 + nowMinusTwelve.D();//assume 31 days per month. we do not really care, only want unique number per day of the year
+    lastFlush = Time();
 
     //Give a name to this machine's specific states
@@ -1178 +1180 @@
     int newDayNumber = nowMinusTwelve.M()*31 + nowMinusTwelve.D();//assume 31 days per month. we do not really care, only want unique number per day of the year
 
+    //also check if we should flush the nightly files
+    if (lastFlush < timeNow-boost::posix_time::minutes(1))
+    {
+        lastFlush = timeNow;
+        SubscriptionsListType::iterator x;
+        map<string, SubscriptionType>::iterator y;
+        for (x=fServiceSubscriptions.begin(); x != fServiceSubscriptions.end(); x++)
+        {//find current service is subscriptions
+            for (y=x->second.begin(); y!=x->second.end();y++)
+                if (y->second.nightlyFile.IsOpen())
+                {
+                    y->second.nightlyFile.Flush();
+                }
+        }
+        if (fDebugIsOn)
+            Debug("Just flushed nightly fits files to the disk");
+    }
+
 //    if (Time().h() == 12 && !fDailyFileDayChangedAlready)
     if (newDayNumber !=  fCurrentDay)
@@ -1905 +1925 @@
                 return;
             }
-            sub.nightlyFile.Flush();
+ //           sub.nightlyFile.Flush();
          }