Changeset 407 in Sophya for trunk/Poubelle/archTOI.old/toisvr.cc

Timestamp:

Sep 18, 1999, 2:08:23 PM (26 years ago)

Author:

ansari

Message:

apres grenoble

File:

• trunk/Poubelle/archTOI.old/toisvr.cc (modified) (3 diffs)

trunk/Poubelle/archTOI.old/toisvr.cc

@@ -2 +2 @@
 // Eric Aubourg         CEA/DAPNIA/SPP   juillet 1999
 
-
+#include <iostream.h>
 #include "toisvr.h"
+#include "archparam.h"
+#include "asigps.h"
 
 TOISvr::TOISvr()
 {}
 
-void TOISvr::SetDirectory(string d) {
+// To avoid special copy constructor handling, we will not
+// register ourself to us... Special dealing in readReq.
+
+void TOISvr::setDirectory(string d) {
   iter.directory = d;
 }
 
-void TOISvr::AddFile(string f) {
+void TOISvr::addFile(string f) {
   iter.files.insert(f);
 }
 
-void TOISvr::UseAuxGPS(AuxGPS* gps) {
+void TOISvr::useAuxGPS(AuxGPS* gps) {
   if (iter.auxGPS) delete iter.auxGPS;
   iter.auxGPS = gps;
@@ -22 +27 @@
 
 
-void TOISvr::OnBoardRecorderFiles(bool x) {
+void TOISvr::onBoardRecorderFiles(bool x) {
   iter.isOnBoardRecorder = x;
 }
 
   
-void TOISvr::SetTimeInterval(double tStart, double tEnd) {
+void TOISvr::setTimeInterval(double tStart, double tEnd) {
   if (tStart>0) iter.tStart = tStart;
   if (tEnd>0)   iter.tEnd = tEnd;
 }
   
-void TOISvr::AddInfo(TOIKind kind, int index, bool triggering, bool interp) {
+void TOISvr::addInfo(TOIKind kind, int index, bool triggering, bool interp) {
   TOIIter::info i;
   i.kind = kind; 
@@ -41 +46 @@
 }
 
-void TOISvr::AddInfo(TOIKind kind, bool triggering, bool interp) {
-  AddInfo(kind,0,triggering,interp);
+void TOISvr::addInfo(TOIKind kind, bool triggering, bool interp) {
+  addInfo(kind,0,triggering,interp);
 }
   
-TOIIter TOISvr::DoQuery() {
+TOIIter TOISvr::doQuery() {
   //iter.Init();
   return iter;
 }
+
+void TOISvr::registerReqHandler(RequestHandler* h) {
+  handlers.push_back(h);
+}
+
+
+void TOISvr::readReq(istream& str) {
+   string line;
+   while (str) {
+     getline(str,line);
+     if (!str) break;
+     if (line.substr(0,4)=="#END") break;
+     if (line[0] != '@' && line[0] != '#') continue;
+     bool handled=processRequest(line); 
+     if (!handled) {
+        cerr << "*Warning, unrecognized directive " << line << endl;
+     }
+   }
+}
+
+#define tsttoi(toi)   if (keyw == "@"#toi) kind = toi;
+
+bool TOISvr::processRequest(string line) {
+  int x = line.find(' ');
+  string keyw = line.substr(0, x);
+  string args = (x>0) ? line.substr(x) : string("");
+  if (keyw[0] == '#') {
+     bool handled = processOption(keyw,args);
+     for (list<RequestHandler*>::iterator i = handlers.begin(); 
+          i != handlers.end(); i++) {
+       handled |= (*i)->processOption(keyw,args);
+     }
+     return handled;
+  }
+  if (keyw[0] == '@') {
+        // find TOI kind, index and options
+    TOIKind kind= (TOIKind)-1;
+    int index=-1;
+    bool interp=false;
+    bool repet =false;
+    bool flag  =false;
+    bool notrig=false;
+    tsttoi(sampleNum)
+    else tsttoi(internalTime)
+    else tsttoi(mjd)
+    else tsttoi(boloTens)
+    else tsttoi(boloTens2)
+    else tsttoi(boloRaw)
+    else tsttoi(boloRes)
+    else tsttoi(boloTemp)
+    else tsttoi(boloGainAmpli)
+    else tsttoi(boloTens2T)
+    else tsttoi(boloRawCN)
+    else tsttoi(sstDiode)
+    else tsttoi(sstChannel)
+    else tsttoi(sstDiodeCN)
+    else tsttoi(sstChannelCN)
+    else tsttoi(sstStarCnt)
+    else tsttoi(sstStarZ)
+    else tsttoi(sstStarF)
+    else tsttoi(sstStarT)
+    else tsttoi(gyroRaw)
+    else tsttoi(gyroTens)
+    else tsttoi(gyroSpeed)
+    else tsttoi(gpsTime)
+    else tsttoi(longitude)
+    else tsttoi(latitude)
+    else tsttoi(altitude)
+    else tsttoi(tsid)
+    else tsttoi(azimut)
+    else tsttoi(alphaAxis)
+    else tsttoi(deltaAxis)
+    else tsttoi(alphaSst)
+    else tsttoi(deltaSst)
+    else tsttoi(alphaBolo)
+    else tsttoi(deltaBolo)
+    else {
+      // cerr << "*Warning, unrecognized TOI " << line << endl;
+      return false;
+    }
+    if (kind  == sampleNum || kind == mjd) notrig = true;
+    string toiname = keyw.substr(1); 
+    while (args != "") {
+      if (args[0] == ' ') {
+        args = args.substr(args.find_first_not_of(' '));
+        if (args == "") break;
+      }
+      x = args.find(' ');
+      string opt = args.substr(0, x);
+      args = (x>0) ? args.substr(x) : string("");
+      if (opt[0]>='0' && opt[0]<='9') {
+        index = atoi(opt.c_str());
+      } else if (opt == "notrig") {
+        notrig = true;
+      } else if (opt == "repet") {
+        repet = true; interp = false;
+      } else if (opt == "interp") {
+        interp = true; repet = false;
+      } else if (opt == "flag") {
+        flag = true;
+      }
+    }
+    bool handled = processTOIReq(line, toiname, kind, index, interp, repet, flag, notrig);
+    for (list<RequestHandler*>::iterator i = handlers.begin(); 
+         i != handlers.end(); i++) {
+      handled |= (*i)->processTOIReq(line, toiname, kind, index, interp, repet, flag, notrig);
+    }
+    return handled;
+  }
+  return false;
+}
+
+
+bool TOISvr::processTOIReq(string /*line*/, string /*toiname*/, TOIKind kind, int index, 
+                           bool interp, bool /*repet*/, bool /*flag*/, bool notrig)
+{
+  if (index<0) index=0;
+  addInfo(kind, index, !notrig, interp);
+  return true;
+} 
+
+bool TOISvr::processOption(string key, string arg)
+{
+  if (arg.length()>0 && arg[0] == ' ') {
+    arg = arg.substr(arg.find_first_not_of(' '));
+  }
+  if (key == "#TRANGE") {
+    double tmin, tmax;
+    sscanf(arg.c_str(), "%lg %lg", &tmin, &tmax);
+    setTimeInterval(tmin, tmax);
+  } else if (key == "#PATH") {
+    setDirectory(arg);
+  } else if (key == "#FILE") {
+    addFile(arg);
+  } else if (key == "#RECORDER") {
+    onBoardRecorderFiles(true);
+  } else if (key == "#MJD0") {
+    double t0;
+    sscanf(arg.c_str(), "%lg", &t0);
+    archParam.acq.tBlock0 = t0;
+  } else if (key == "#PERECH") {
+    double t0;
+    sscanf(arg.c_str(), "%lg", &t0);
+    archParam.acq.perEch = t0;
+  } else if (key == "#ASIGPS") {
+    ASIGPS* gps = new ASIGPS(arg);
+    gps->FitsDump("GPSDump.fits");
+    useAuxGPS(gps);
+  } else {
+    // cerr << "*Warning, unrecognized option " << line << endl;
+    return false;
+  }
+  return true;
+}