MBSpillAccessor.cxx

Go to the documentation of this file.

#include "MBSpillAccessor.h"

#include <Validity/VldContext.h>

#include <MessageService/MsgService.h>
CVSID("$Id: MBSpillAccessor.cxx,v 1.2 2006/06/29 03:45:03 rhatcher Exp $");

#include <DatabaseInterface/DbiResultPtr.h>
#include <DatabaseInterface/DbiSqlContext.h>

#include <cmath>
using namespace std;

MBSpillAccessor* MBSpillAccessor::fInstance = 0;

MBSpillAccessor& MBSpillAccessor::Get()
{
    if (!fInstance) fInstance = new MBSpillAccessor();
    return *fInstance;
}


MBSpillAccessor::MBSpillAccessor()
    : fPrevPtr(0)
    , fCenterPtr(new DbiResultPtr<MBSpill>)
    , fNextPtr(0)
    , fNeedNext(true)
    , fNeedPrev(true)
{
}
MBSpillAccessor::~MBSpillAccessor()
{
    if (fPrevPtr)   delete fPrevPtr;
    if (fCenterPtr) delete fCenterPtr;
    if (fNextPtr)   delete fNextPtr;
    fPrevPtr = fCenterPtr = fNextPtr = 0;
}

const MBSpill* MBSpillAccessor::LoadSpill(VldTimeStamp vts, int which)
{
    const MBSpill *before=0, *after=0;
    this->SeekClosest(vts,before,after);
    
    if (which < 0) return before;
    if (which > 0) return after;

    if (!before) return after;
    if (!after) return before;

    VldTimeStamp vts_before = before->GetTimeStamp();
    VldTimeStamp vts_after = after->GetTimeStamp();
    
    MSG("MBU",Msg::kDebug)
        << vts_before << " " << vts << " " << vts_after << endl;

    if (vts - vts_before < vts_after - vts)
        return before;
    return after;

}


void MBSpillAccessor::SeekClosest(const VldTimeStamp &vts,
                                  const MBSpill* &before,
                                  const MBSpill* &after)
{
    Detector::Detector_t det = Detector::kNear;
    SimFlag::SimFlag_t simflag = SimFlag::kData;
    VldContext vc(det,simflag,vts);

    fCenterPtr->NewQuery(vc,0,true);

    if (! fResKey.IsEqualTo(fCenterPtr->GetKey())) {
        fNeedPrev = fNeedNext = true;
    }

    const DbiValidityRec* vr = fCenterPtr->GetValidityRec();

    VldTimeStamp beg = vr->GetVldRange().GetTimeStart();
    VldTimeStamp end = vr->GetVldRange().GetTimeEnd();

    before=after=0;
    this->TableSearch(*fCenterPtr,vts,before,after);

    if (before && after) return;

    MSG("MBU",Msg::kDebug)
        << vts << " not in center table, before @ " << (void*)before
        << " after @ " << (void*)after 
        << " seqno = " << vr->GetSeqNo() << endl;

    if (!before) {
        const char* sqltxt = Form("(TIMEEND<='%s') order by TIMEEND desc limit 1",
                                  beg.AsString("s"));
        DbiSqlContext dscx(sqltxt);
        if(fPrevPtr && fNeedPrev)
            fPrevPtr->NewQuery(dscx,Dbi::kAnyTask);
        else 
            fPrevPtr = new DbiResultPtr<MBSpill>("MBSpill",dscx);
        fNeedPrev = false;

        const MBSpill* dummy=0;
        this->TableSearch(*fPrevPtr,vts,before,dummy);
        if(dummy)
            MSG("MBU",Msg::kError)
                << "Found next time in previous table: "
                << dummy->GetTimeStamp() << endl;
    }
    if (!after) {
        const char* sqltxt = Form("(TIMESTART>='%s') order by TIMEEND asc limit 1",
                                  end.AsString("s"));
        DbiSqlContext dscx(sqltxt);
        if(fNextPtr && fNeedNext)
            fNextPtr->NewQuery(dscx,Dbi::kAnyTask);
        else 
            fNextPtr = new DbiResultPtr<MBSpill>("MBSpill",dscx);
        fNeedNext = false;

        const MBSpill* dummy=0;
        this->TableSearch(*fNextPtr,vts,dummy,after);
        if(dummy)
            MSG("MBU",Msg::kError)
                << "Found previous time in next table: "
                << dummy->GetTimeStamp() << endl;

    }

}

void MBSpillAccessor::TableSearch(DbiResultPtr<MBSpill> &table,
                                  const VldTimeStamp& vts, 
                                  const MBSpill* &before,
                                  const MBSpill* &after)
{
    before = after = 0;

    int nrows = table.GetNumRows();
    if (nrows <= 0) return;

    double minneg = 1e10;
    double minpos = 1e10;
    for (int row = 0; row < nrows; ++row) {
        const MBSpill* spill = table.GetRow(row);
        double dt = spill->GetTimeStamp() - vts;
        if (dt <= 0) {
            if (-dt < minneg) {
                minneg = -dt;
                before = spill;
            }
        }
        else {
            if (dt < minpos) {
                minpos = dt;
                after = spill;
            }
        }
    }
}

---