Changeset 274 for drsdaq/DAQReadout.cc

Timestamp:

07/30/10 12:35:09 (14 years ago)

Author:

ogrimm

Message:

drsdaq publishes some more run-related services

File:

• drsdaq/DAQReadout.cc (modified) (9 diffs)

drsdaq/DAQReadout.cc

@@ -78 +78 @@
   LastBoard                     = -1;
   MinDelay                      = 1;
+  RunNumber                     = -1;
 
   // Get configuration data (static needed for c_str() pointers to remain valid after constructor finished)
@@ -142 +143 @@
   // Create DIM event data service
   EventService = new DimService (SERVER_NAME"/EventData", (char *) "C", DIMEventData, 0);
+  RunNumService = new DimService (SERVER_NAME"/RunNumber", RunNumber);
                                                    
   // Install DIM command (after all initialized)
@@ -155 +157 @@
   delete Command;
 
+  delete RunNumService;
   delete EventService;  delete[] DIMEventData;
   delete RHeader;               delete EHeader;
@@ -299 +302 @@
   }
   else RunNumber = -1;
+  RunNumService->updateService();
 
   // Create DAQ thread
@@ -1197 +1201 @@
   off_t FileSize;
   int DIMSize;
+  float RunSizeMB=0, FileSizeMB=0;
 
   // Initialize run
@@ -1202 +1207 @@
   FileNumber = 0;
   DimClient::sendCommandNB("Feedback/Command", "clear");
+
+  DimService RunSizeService(SERVER_NAME"/RunSizeMB", RunSizeMB);
+  DimService FileSizeService(SERVER_NAME"/FileSizeMB", FileSizeMB);
+  DimService EventNumService(SERVER_NAME"/EventNumber", NumEvents);
+  DimService FilenameService(SERVER_NAME"/FileName", FileName);
     
   gettimeofday(&StartTime, NULL);
@@ -1218 +1228 @@
     EventsInFile = 0;
     FileSize = 0;
+        FilenameService.updateService();
 
     WriteError |= !WriteRunHeader();
@@ -1277 +1288 @@
           }
 
-      // Call routine to update DIM service (update rate is limited)
+      // Update DIM services (update rate is limited)
           if (time(NULL) - LastDIMUpdate < MinDelay) continue;
           LastDIMUpdate = time(NULL);
+          
+          RunSizeMB = (RunSize+FileSize)/1024.0/1024.0;
+          RunSizeService.updateService();
+          FileSizeMB = FileSize/1024.0/1024.0;
+          FileSizeService.updateService();
+          EventNumService.updateService();
           
           // Copy new event header
@@ -1338 +1355 @@
   }
   
+  RunNumber = -1;
+  RunNumService->updateService();
+
   daq_state = stopped;
 }