From: hadaq <hadaq>
Date: Tue, 30 Jan 2007 19:24:11 +0000 (+0000)
Subject: two functions added to write simple run start/stop info to ascii file to be inserted... 
X-Git-Url: https://jspc29.x-matter.uni-frankfurt.de/git/?a=commitdiff_plain;h=b6b8c3f3de510420ecc8f05a5da757c48f70f189;p=daqdata.git

two functions added to write simple run start/stop info to ascii file to be inserted to Oracle
---

diff --git a/hadaq/evtbuild.c b/hadaq/evtbuild.c
index f811fdc..6fdec46 100644
--- a/hadaq/evtbuild.c
+++ b/hadaq/evtbuild.c
@@ -1,5 +1,5 @@
 static char *rcsId =
-  "$Header: /misc/hadesprojects/daq/cvsroot/eventbuilder/hadaq/evtbuild.c,v 6.75 2007-01-25 16:08:20 hadaq Exp $";
+  "$Header: /misc/hadesprojects/daq/cvsroot/eventbuilder/hadaq/evtbuild.c,v 6.76 2007-01-30 19:24:11 hadaq Exp $";
 
 
 #define _POSIX_C_SOURCE 199309L
@@ -574,6 +574,51 @@ statsDump (TheArgs * theArgs, TheStats * my, int interval)
 }
 
 
+static void storeRunInfoStart(time_t t, TheArgs *myArgs)
+{
+  /* open ascii file eb_runinfo2ora.txt to store simple information for 
+     the started RUN. The format: start <run_id> <filename> <date> <time>
+     where "start" is a key word which defines START RUN info. -S.Y.
+  */
+ 
+  FILE *fp;
+  char ltime[20];                 /* local time */
+  strftime(ltime, 20, "%Y-%m-%d %H:%M:%S", localtime(&t));
+
+  /* read path from DAQ_SETUP and define full file name */
+  char runinfo2ora[50];
+  sprintf(runinfo2ora,"%s_runinfo2ora.txt",getenv("DAQ_SETUP"));
+  
+  fp = fopen(runinfo2ora,"a+");
+  
+  fprintf(fp, "start %d %s %s\n", myArgs->runNr, myArgs->outPath, ltime);
+  
+  fclose(fp);
+}
+
+static void storeRunInfoStop(time_t t, TheArgs *myArgs, TheStats *myStats)
+{
+  /* open ascii file eb_runinfo2ora.txt to store simple information for 
+     the stoped RUN. The format: stop <run_id> <date> <time> <events> <bytes>
+     where "stop" is a key word which defines STOP RUN info. -S.Y.
+  */
+
+  FILE *fp;
+  char ltime[20];                 /* local time */
+  strftime(ltime, 20, "%Y-%m-%d %H:%M:%S", localtime(&t));
+
+  /* read path from DAQ_SETUP and define full file name */
+  char runinfo2ora[50];
+  sprintf(runinfo2ora,"%s_runinfo2ora.txt",getenv("DAQ_SETUP"));
+  
+  fp = fopen(runinfo2ora,"a+");
+
+  fprintf(fp, "stop %d %s %s ", myArgs->runNr, ltime, unit(*myStats->evtsComplete));
+  fprintf(fp, "%s\n", unit(*myStats->bytesWritten));
+
+  fclose(fp);  
+}
+
 #define NJUNK 128
 static void
 storeInfoStart (const char *n, time_t t, TheArgs * my)
@@ -1391,6 +1436,9 @@ main (int argc, char *argv[])
 	    }
 	  storeInfoStart (argv[0], ourTime, theArgs);
 
+	  /* store simple start run info */
+	  storeRunInfoStart(ourTime, theArgs);	  
+
 	  evt = newEvt (EvtDecoding_64bitAligned, EvtId_runStart);
 	  for (i = 0; i < theArgs->slowCtrlFileCnt; i++)
 	    {
@@ -1563,6 +1611,9 @@ main (int argc, char *argv[])
 	  closeFile ();
 	  storeInfoStop (argv[0], ourTime - 2, worker);
 
+	  /* store simple stop run info */
+	  storeRunInfoStop(ourTime - 2, theArgs, theStats);	  
+
 	  (*theStats->bytesWritten) = 0;
 	  (*theStats->evtsComplete) = 0;
 	  (*theStats->evtsDiscarded) = 0;
@@ -1601,6 +1652,9 @@ main (int argc, char *argv[])
     }
   storeInfoStop (argv[0], ourTime - 2, worker);
 
+  /* store simple stop run info */
+  storeRunInfoStop(ourTime - 2, theArgs, theStats);
+
   statsDump (theArgs, theStats, 1);
 
   for (i = 0; i < theArgs->nrOfMsgs; i++)