bool EventBuilderWrapper::runOpen ( const EVT_CTRL2 &  evt )

inline

Definition at line 556 of file EventBuilderWrapper.h.

References DataWriteFits, MessageImp::Error(), DataCalib::GetCalibration(), MessageImp::Info(), kCalib, kCfitsio, kDebug, kFits, kNone, kRaw, kZFits, runClose(), EVT_CTRL2::runCtrl, EVT_CTRL2::runNum, str, time, and EVT_CTRL2::triggerCounter.

Referenced by runOpen().

    {
        const uint32_t night = evt.runCtrl->night;
        const uint32_t runid = evt.runNum>0 ? evt.runNum : time(NULL);

        // If there is still an open file: close it
        if (fFile)
            runClose(evt);

        // Keep a copy of the currently valid drs calibration
        // and associate it to the run control structure
        evt.runCtrl->calib = make_shared<DrsCalibration>(DataCalib::GetCalibration());

        // Crate the file
        DataProcessorImp *file = 0;
        switch (fFileFormat)
        {
        case FAD::kNone:    file = new DataDump(fPath, night, runid,  fMsg); break;
        case FAD::kDebug:   file = new DataDebug(fPath, night, runid, fMsg); break;
        case FAD::kCfitsio: file = new DataWriteFits(fPath, night, runid,  fMsg); break;
        case FAD::kFits:    file = new DataWriteFits2(fPath, night, runid, fMsg); break;
        case FAD::kZFits:   file = new DataWriteFits2(fPath, night, runid, *evt.runCtrl->calib, fMsg); break;
        case FAD::kRaw:     file = new DataWriteRaw(fPath, night, runid, fMsg); break;
        case FAD::kCalib:   file = new DataCalib(fPath, night, runid, *evt.runCtrl->calib, fDimDrsCalibration, fDimDrsRuns, fMsg); break;
        }

        try
        {
            // Try to open the file
            FAD::RunDescription desc;
            desc.maxevt  = evt.runCtrl->maxEvt;
            desc.maxtime = evt.runCtrl->closeTime - evt.runCtrl->openTime;
            desc.name    = evt.runCtrl->runType;

            if (!file->Open(evt, desc))
                return false;
        }
        catch (const exception &e)
        {
            fMsg.Error("Exception trying to open file: "+string(e.what()));
            return false;
        }

        fLastOpened = runid;

        // Signal that a file is open
        fFile = shared_ptr<DataProcessorImp>(file);

        // Now do all the calls which potentially block (dim)

        // Time for update runs before time for update events
        UpdateRuns(file->GetFileName());
        fNumEvts[kEventId]   = 0;
        fNumEvts[kTriggerId] = 0;
        fNumEvts[kCurrent]   = 0;

        const Time time;

        fQueueEvents.emplace(time, fNumEvts);
        fQueueTrigger.emplace(time, 'o', evt.triggerCounter);

        ostringstream str;
        str << "Opened: " << file->GetFileName() << " (" << file->GetRunId() << ")";
        fMsg.Info(str);

        return true;
    }

Here is the call graph for this function:

Here is the caller graph for this function: