JTurbot.cc

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <iomanip>
#include <limits>
#include <map>
#include <vector>

#include "TROOT.h"
#include "TFile.h"
#include "TH1D.h"
#include "TF1.h"
#include "TMath.h"

#include "JDAQ/JDAQ.hh"
#include "JDAQ/JDAQEvent.hh"
#include "JDAQ/JDAQTimeslice.hh"
#include "JDAQ/JDAQEvaluator.hh"
#include "JDetector/JDetector.hh"
#include "JDetector/JDetectorToolkit.hh"
#include "JDetector/JDAQHitRouter.hh"
#include "JDetector/JPMTParametersMap.hh"
#include "JTrigger/JBuildL0.hh"
#include "JTrigger/JBuildL1.hh"
#include "JLang/JSinglePointer.hh"
#include "JGizmo/JManager.hh"
#include "JTools/JWeight.hh"
#include "JROOT/JROOTClassSelector.hh"
#include "JSupport/JSingleFileScanner.hh"
#include "JSupport/JTreeScannerInterface.hh"
#include "JSupport/JTreeScanner.hh"
#include "JSupport/JAutoTreeScanner.hh"
#include "JSupport/JSupport.hh"
#include "JSupport/JMeta.hh"

#include "Jeep/JPrint.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"


/**
 * \file
 *
 * Example program to search for correlations between triggered events and timeslice data.
 * \author mdejong
 */
int main(int argc, char **argv)
{
  using namespace std;
  using namespace JPP;
  using namespace KM3NETDAQ;

  JSingleFileScanner<> inputFile;
  JLimit_t&          numberOfEvents = inputFile.getLimit();
  string             outputFile;
  string             detectorFile;
  double             TMaxLocal_ns;
  string             pmtFile;
  int                numberOfTimeslices;
  double             binWidth_ns;
  double             Pmin;
  JROOTClassSelector selector;
  int                debug;

  try { 

    JParser<> zap("Example program to search for correlations between triggered events and timeslice data.");
    
    zap['f'] = make_field(inputFile);
    zap['o'] = make_field(outputFile)          = "";
    zap['a'] = make_field(detectorFile);
    zap['n'] = make_field(numberOfEvents)      = JLimit::max();
    zap['T'] = make_field(TMaxLocal_ns)        = 20.0;
    zap['P'] = make_field(pmtFile)             = "";
    zap['N'] = make_field(numberOfTimeslices)  = 100;
    zap['W'] = make_field(binWidth_ns)         = 10e3;
    zap['p'] = make_field(Pmin)                = 1.0e-6;
    zap['C'] = make_field(selector)            = "", getROOTClassSelection<JDAQTimesliceTypes_t>();
    zap['d'] = make_field(debug)               =  2;

    zap(argc, argv);
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }


  cout.tie(&cerr);

  JDetector detector;

  try {
    load(detectorFile, detector);
  }
  catch(const JException& error) {
    FATAL(error);
  }
  
  const JDAQHitRouter router(detector);

  const double TMax_ns = max(binWidth_ns, getMaximalTime(detector));

  typedef  double    hit_type;
  
  JBuildL0<hit_type> buildL0;
  JBuildL1<hit_type> buildL1(TMaxLocal_ns, true);
  vector  <hit_type> data;  
  
  typedef JManager<int, TH1D>  JManager_t;

  const Double_t xmin = -(numberOfTimeslices + 1) * getFrameTime() - 0.5*binWidth_ns;
  const Double_t xmax = +(numberOfTimeslices + 1) * getFrameTime() + 0.5*binWidth_ns;
  const Int_t    nx   = (Int_t) ((xmax - xmin) / binWidth_ns);
  
  JManager_t manager(new TH1D("M_%", NULL, nx, xmin, xmax));

  JTreeScanner<>::debug = debug;
  
  JSinglePointer< JTreeScannerInterface<JDAQTimeslice> > ps;

  JAutoTreeScanner<JDAQTimeslice> zmap = JType<JDAQTimesliceTypes_t>();
  
  if (selector == "") {

    if ((ps = new JTreeScanner< JAssertConversion<JDAQTimesliceSN, JDAQTimeslice> >(inputFile))->getEntries() != 0 ||
        (ps = new JTreeScanner< JAssertConversion<JDAQTimesliceL2, JDAQTimeslice> >(inputFile))->getEntries() != 0 ||
        (ps = new JTreeScanner< JAssertConversion<JDAQTimesliceL1, JDAQTimeslice> >(inputFile))->getEntries() != 0 ||
        (ps = new JTreeScanner< JAssertConversion<JDAQTimeslice,   JDAQTimeslice> >(inputFile))->getEntries() != 0 ||
        (ps = new JTreeScanner< JAssertConversion<JDAQTimesliceL0, JDAQTimeslice> >(inputFile))->getEntries() != 0) {
    } else {
      FATAL("No timeslice data." << endl);
    }

    NOTICE("Selected class " << ps->getClassName() << endl);

  } else {

    ps = zmap[selector];
    
    ps->configure(inputFile);
  }


  typedef map<int, vector<double> > map_type;    // frame index -> event times

  map_type buffer;
    
  for (JTreeScanner<JDAQEvent> in(inputFile.getFilename(), inputFile.getLimit()); in.hasNext(); ) {

    STATUS("event: " << setw(10) << in.getCounter() << '\r'); DEBUG(endl);

    JDAQEvent* event = in.next();

    // Average time of triggered hits
    
    double t0 = 0.0;
    
    for (JDAQEvent::const_iterator<JDAQTriggeredHit> hit = event->begin<JDAQTriggeredHit>(); hit != event->end<JDAQTriggeredHit>(); ++hit) {
      t0 += getTime(*hit, router.getPMT(*hit));
    }
    
    t0 /= event->size<JDAQTriggeredHit>();
    t0 += event->getFrameIndex() * getFrameTime();
    
    buffer[event->getFrameIndex()].push_back(t0);
  }    
  STATUS(endl);
    

  while (ps->hasNext()) {
    
    STATUS("event: " << setw(10) << ps->getCounter() << '\r'); DEBUG(endl);

    JDAQTimeslice* timeslice = ps->next();

    map_type::const_iterator p = buffer.lower_bound(timeslice->getFrameIndex() - numberOfTimeslices);
    map_type::const_iterator q = buffer.upper_bound(timeslice->getFrameIndex() + numberOfTimeslices);

    int number_of_events = 0;

    for (map_type::const_iterator i = p; i != q; ++i) {
      number_of_events += i->second.size();
    }

    if (number_of_events == 0) {
      continue;
    }
    
    for (JDAQTimeslice::const_iterator frame = timeslice->begin(); frame != timeslice->end(); ++frame) {

      data.clear();

      buildL1(*frame, router.getModule(frame->getModuleID()), back_inserter(data));
        
      TH1D* h1 = manager[frame->getModuleID()];
        
      for (vector<hit_type>::const_iterator hit = data.begin(); hit != data.end(); ++hit) {
          
        const double t1 = *hit + frame->getFrameIndex() * getFrameTime();
          
        for (map_type::const_iterator i = p; i != q; ++i) {
          for (map_type::mapped_type::const_iterator j = i->second.begin(); j != i->second.end(); ++j) {
            
            const double t0 = *j;
            
            h1->Fill(t1 - t0);
          }
        }
      }
    }
  }
  STATUS(endl);

  if (pmtFile != "") {

    JPMTParametersMap parameters;
    
    try {
      parameters.load(pmtFile.c_str());
    }
    catch(const JException& error) {}
    
    TF1 f1("f1", "[0]*exp(-0.5*(x-[1])*(x-[1])/([2]*[2])) + [3]");
    
    string option = "L";

    if (debug < debug_t) {
      option += "Q";
    }
    
    for (JDetector::const_iterator module = detector.begin(); module != detector.end(); ++module) {

      bool status = false;
    
      JManager_t::iterator p = manager.find(module->getID());

      if (p != manager.end()) {

        TH1D* h1       = p->second;

        if (h1->GetEntries() != 0) {

          // start values
          
          Double_t ymax  =   0.0;
          Double_t x0    =   0.0;    // [ns]
          Double_t sigma = 250.0;    // [ns]
          Double_t ymin  =   0.0;
          
          for (int i = 1; i != h1->GetNbinsX(); ++i) {
      
            const Double_t x = h1->GetBinCenter (i);
            const Double_t y = h1->GetBinContent(i);
          
            if (y > ymax) {
              ymax = y;
              x0   = x;
            }

            ymin += y;
          }

          ymin /= h1->GetNbinsX();
        
          f1.SetParameter(0, ymax);
          f1.SetParameter(1, x0);
          if (binWidth_ns < sigma) 
            f1.SetParameter(2, sigma);
          else
            f1.FixParameter(2, binWidth_ns/sqrt(12.0));
          f1.SetParameter(3, ymin);
          
          // fit
    
          h1->Fit(&f1, option.c_str(), "same", x0 - 5 * sigma, x0 + 5 * sigma);

          status = (fabs(f1.GetParameter(1)) <= 0.5*getFrameTime() &&
                    f1.GetParameter(0)       >= f1.GetParameter(3));
        }

        if (h1->GetEntries() != 0) {

          // look for peaks at offsets equal to a multiple of frame time
          
          JWeight           bg;    // background
          map<int, JWeight> sn;    // signal(s)

          for (Int_t i = 1, ns = -(numberOfTimeslices + 1); i <= h1->GetNbinsX(); ++i) {

            const Double_t x = h1->GetBinCenter (i);
            const Double_t y = h1->GetBinContent(i);

            while (x > (ns + 1) * getFrameTime() - TMax_ns) { ++ns; }
            
            if (fabs(x - ns * getFrameTime()) < TMax_ns)
              sn[ns].put(y);
            else
              bg    .put(y);
          }


          for (map<int, JWeight>::iterator i = sn.begin(); i != sn.end(); ) {

            const Double_t y = bg.getTotal() * i->second.getCount() / bg.getCount();
            const Double_t P = TMath::PoissonI(i->second.getTotal(), y);
            
            if (i->second.getTotal() > y && P < Pmin)
              ++i;               // keep
            else
              sn.erase(i++);     // remove
          }

          if (sn.size() != 1) {

            ERROR("Module " << setw(8) << module->getID() << " number of peaks " << sn.size() << " != 1" << endl);

            for (map<int, JWeight>::const_iterator i = sn.begin(); i != sn.end(); ++i) {
              WARNING("Peak at " << setw(4) << i->first << " [frame time] S/N = " 
                      << FIXED(7,1) << i->second.getTotal()                                 << " / "
                      << FIXED(7,1) << bg.getTotal() * i->second.getCount() / bg.getCount() << endl);
            }
          }

          status &= (sn.size()         == 1 && 
                     sn.begin()->first == 0);
        }
      }
      
      if (!status) {

        NOTICE("Module " << module->getID() << " set QEs of all PMTs to zero." << endl);
        
        for (int pmt = 0; pmt != NUMBER_OF_PMTS; ++pmt) {
          parameters[JPMTIdentifier(module->getID(), pmt)].QE = 0.0;
        }
      }
    }

    ofstream out(pmtFile.c_str());

    parameters.comment.add(JMeta(argc, argv));
    
    out << parameters << endl;

    out.close();
  }

  if (outputFile != "") {
    manager.Write(outputFile.c_str());
  }
}