MdcHvDropSvc Class Reference

#include <MdcHvDropSvc.h>

Inheritance diagram for MdcHvDropSvc:

Public Member Functions
	MdcHvDropSvc (const std::string &name, ISvcLocator *svcloc)
	~MdcHvDropSvc ()
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvUnknown)
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
void	handle (const Incident &)
virtual double	queryRelativeHvDrop ()
virtual void	setRelativeHvDropThreshold (double threshold)
virtual bool	queryIsHvDrop ()

Additional Inherited Members
Static Public Member Functions inherited from IMdcHvDropSvc
static const InterfaceID &	interfaceID ()

Detailed Description

Definition at line 32 of file MdcHvDropSvc.h.

Constructor & Destructor Documentation

MdcHvDropSvc()

MdcHvDropSvc::MdcHvDropSvc	(	const std::string &	name,
		ISvcLocator *	svcloc )

Definition at line 49 of file MdcHvDropSvc.cxx.

                                                                  : Service(name, svcloc) {
    // declare properties
    declareProperty("Host", m_host = std::string("202.122.33.123"));
    declareProperty("DbName", m_dbName = std::string("tof40t_linux"));
    declareProperty("TableName", m_table = std::string("MDCLayerVmon"));
    declareProperty("UserName", m_userName = std::string("guest"));
    declareProperty("Password", m_password = std::string("guestpass"));
    declareProperty("Port", m_port=6175);
    declareProperty("IgnoreLayer_21_24",m_ignoreLayer_21_24=true);
    declareProperty("RelativeHvDropThreshold",m_relativeHvDropThreshold=0.007);
    declareProperty("FetchHvDataLengthInSeconds",m_fetchLength=5*3600);
    declareProperty("UseEtsT1",m_useEtsT1=0); // whether to use EtsT1, if not, use time().
    declareProperty("EtsT1OffSet",m_etsT1Offset=0);// if is 0, and UseEtsT1,  will be treated as using database time from database..
                                                // else, acts as calculating time_override=etsT1+etsT1Offset;
 
    declareProperty("Host2", m_host2 = std::string("bes3db2.ihep.ac.cn"));
    declareProperty("DbName2", m_dbName2 = std::string("run"));
    declareProperty("TableName2", m_table2 = std::string("RunParams"));
    declareProperty("UserName2", m_userName2 = std::string("guest"));
    declareProperty("Password2", m_password2 = std::string("guestpass"));
    declareProperty("Port2", m_port2=3306);//3306 is default port for mysql
}

Referenced by MdcHvDropSvc().

~MdcHvDropSvc()

MdcHvDropSvc::~MdcHvDropSvc

(

)

Definition at line 72 of file MdcHvDropSvc.cxx.

                            {
}

Member Function Documentation

finalize()

StatusCode MdcHvDropSvc::finalize ( )

virtual

Definition at line 119 of file MdcHvDropSvc.cxx.

                                  {
    MsgStream log(messageService(), name());
    log << MSG::INFO << "MdcHvDropSvc::finalize()" << endreq;
    //  if(m_connect_offline) delete m_connect_offline;
    return StatusCode::SUCCESS;
}

handle()

void MdcHvDropSvc::handle

(

const Incident &

inc

)

Definition at line 126 of file MdcHvDropSvc.cxx.

                                             {
    MsgStream log(messageService(), name());
    log << MSG::DEBUG << "handle: " << inc.type() << endreq;
    // so currently we do nothing.
    //if (inc.type() == "NewRun") {
    //    log << MSG::DEBUG << "NewRun" << endreq;
    //
    //    SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc, "/Event/EventHeader");
    //    int run = eventHeader->runNumber();
    //    //cout<<"&&&&&&&&&&&&&&:&&&&&&&&&&&&&&&&&&&& MdcHvDropSvc handle,run="<<run<<endl;
    //    if (run < 0) run = -run;
    //    log << MSG::DEBUG << "handle: "
    //        << "Run in handle is: " << run << endreq;
    //    cout << "-------------in MdcHvDropSvc in the following-----------" << endl;
    //    cout << "handle: "
    //         << "Run in handle is: " << run << endl;
 
        //if (run >= m_RunFrom && run <= m_RunTo && m_ReadPar == true) {
        //    cout << "do not read the database repeatly in EmcShEnCalibConst" << endl;
        //    cout << "run,RunFrom,runTo=" << run << "," << m_RunFrom << "," << m_RunTo << endl;
        //} else {
        //
        //    //cout<<"read the database in EmcShEnCalibConst"<<endl;
        //    if (!getMdcHvDropSvcInfo()) {
        //        log << MSG::ERROR << "can not initilize Shower energy Calib Constants" << endreq;
        //    } else {
        //        m_ReadPar = true;
        //        std::cout << "in handle of MdcHvDropSvc  getPi0CalibFile()= " << getPi0CalibFile() << std::endl;
        //        std::cout << "getSingleGammaCalibFile()= " << getSingleGammaCalibFile() << std::endl;
        //    }
        //}
    //}
}

initialize()

StatusCode MdcHvDropSvc::initialize ( )

virtual

Definition at line 84 of file MdcHvDropSvc.cxx.

                                    {
    MsgStream log(messageService(), name());
    log << MSG::INFO << "MdcHvDropSvc::initialize()" << endreq;
 
    StatusCode sc = Service::initialize();
    if (sc.isFailure()) return sc;
 
    IIncidentSvc *incsvc;
    sc           = service("IncidentSvc", incsvc);
    int priority = 100;
    if (sc.isSuccess()) {
        incsvc->addListener(this, "NewRun", priority);
    }
 
    //sc = serviceLocator()->service("DatabaseSvc", m_dbsvc, true);
    //if (sc.isFailure()) {
    //    log << MSG::ERROR << "Unable to find DatabaseSvc " << endreq;
    //    return sc;
    //}
//
    sc = serviceLocator()->service("EventDataSvc", m_eventSvc, true);
    if (sc.isFailure()) {
        log << MSG::ERROR << "Unable to find EventDataSvc " << endreq;
        return sc;
    }
 
    sc = initMySql();
    if (sc.isFailure()){
        log << MSG::ERROR << "Unable to initialize mysql " << endreq;
        return sc;
    }
 
    return StatusCode::SUCCESS;
}

queryInterface()

StatusCode MdcHvDropSvc::queryInterface ( const InterfaceID & riid, void ** ppvUnknown )

virtual

Definition at line 75 of file MdcHvDropSvc.cxx.

                                                                                    {
    if (IID_IMdcHvDropSvc.versionMatch(riid)) {
        *ppvInterface = static_cast<IMdcHvDropSvc *>(this);
    } else {
        return Service::queryInterface(riid, ppvInterface);
    }
    return StatusCode::SUCCESS;
}

queryIsHvDrop()

virtual bool MdcHvDropSvc::queryIsHvDrop ( )

inlinevirtual

Implements IMdcHvDropSvc.

Definition at line 53 of file MdcHvDropSvc.h.

                                {
        return queryRelativeHvDrop() >= m_relativeHvDropThreshold;
    }

queryRelativeHvDrop()

double MdcHvDropSvc::queryRelativeHvDrop ( )

virtual

Implements IMdcHvDropSvc.

Definition at line 413 of file MdcHvDropSvc.cxx.

                                         {
    MsgStream log(messageService(), name());
    //log << MSG::DEBUG << "MdcHvDropSvc::sqlRow2Item()" << endreq;
    SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc, "/Event/EventHeader");
    Time_t time           = eventHeader->time();
    Time_t fetchBeginTime = time;
    int run               = eventHeader->runNumber();
    unsigned long time_etsT1=eventHeader->etsT1();
    long time_etsT1_timelike32=((time_etsT1/2000000)&0x00000000ffffffffLU);
 
    // handle etsT1 logic
    //    declareProperty("UseEtsT1",m_useEtsT1=0); // whether to use EtsT1, if not, use time().
    //declareProperty("EtsT1OffSet",m_etsT1Offset=0);// if is 0, and UseEtsT1,  will be treated as using database time from database..
    //else, acts as calculating time_override=etsT1+etsT1Offset;
 
    if(m_useEtsT1){
        
        if(m_etsT1Offset==0){
            
            time=time_etsT1_timelike32+getRunBeginTime(run);
        }
        else{
            time=time_etsT1_timelike32+m_etsT1Offset;
        }
    }
 
 
 
    if (run < 0) return 0; // a MC event.
 
    log << MSG::INFO << "query time " << time << endreq;
    log << MSG::INFO << "current boundary " << m_vData.getLowerBoundaryEventTime() << " : " << m_vData.getUpperBoundaryEventTime() << endreq;
 
    if (m_vData.getUpperBoundaryEventTime() < time || time < m_vData.getLowerBoundaryEventTime()) { // not in cache
        // 1st time.
        if (m_vData.size() == 0) {
            char time1str[100];
            Time_t2str(time, time1str, 100);
            log << MSG::INFO << "INFO: MdcHvDropSvc time " << time << " aka " << time1str << " is not in cache yet.\n"
                << "\tfetching HV info for 1h ago" << time - 3600 << " til fetch Length" << time + m_fetchLength - 3600 << endreq;
            fetchBeginTime = time - 3600;
        }
        // 2nd time
        else {
            Time_t upTimeCachedDBTime = m_vData.getUpperBoundaryEventTime() + m_vData.getOffsetEvt2Db();
            char time1str[100];
            Time_t2str(time, time1str, 100);
            // time in another fetch interval, thus we choose to fetch new data and append to cache
            if (m_vData.getLowerBoundaryEventTime() < time && time < m_vData.getUpperBoundaryEventTime() + m_fetchLength) {
 
                log << MSG::INFO << "INFO:MdcHvDropSvc time " << time << " aka " << time1str << " is not in cache yet.\n"
                    << "\tcurrent upperBoundary is " << m_vData.getUpperBoundaryEventTime() << "\n"
                    << "\tfetching HV info for dbTime " << upTimeCachedDBTime << " to fetch Length later" << upTimeCachedDBTime + m_fetchLength << endreq;
                fetchBeginTime = upTimeCachedDBTime;
            }
            //time not in another fetch interval, and we cannot find a interval to append to cache.
            else {
                log << MSG::INFO << "INFO:MdcHvDropSvc time " << time << " aka " << time1str << " is not in cache or canbe fetched in a interval.\n"
                    << "\tcurrent cache boundary is " << m_vData.getLowerBoundaryEventTime() << ":" << m_vData.getUpperBoundaryEventTime() << ".\n"
                    << "\tcurrent fetch interval is " << m_vData.getUpperBoundaryEventTime() << ":" << m_vData.getUpperBoundaryEventTime() + m_fetchLength << endreq;
                log << MSG::INFO << "aborted cache and fetching new data.\n"
                    << "\tfetching HV info for 1h ago" << time - 3600 << " til fetch Length" << time + m_fetchLength - 3600 << endreq;
                m_vData.clear();
                fetchBeginTime = time - 3600;
            }
        }
 
        fetchBeginTime += m_vData.getOffsetEvt2Db(); // now db time
        Time_t time2 = fetchBeginTime + m_fetchLength;
        if (!FetchHvInfo(fetchBeginTime - 600, time2) == StatusCode::SUCCESS) {
            cout << "ERROR: MdcHvDropSvc failed to fetch HV info\n";
            return -10000;
        }
    }
    if (!m_vData.isValid(time))
        return -9999;
    if (m_ignoreLayer_21_24)
        return m_vData.getAvgDropButVeryDrop(time);
    else
        return m_vData.getAvgDrop(time);
}

Referenced by queryIsHvDrop().

setRelativeHvDropThreshold()

virtual void MdcHvDropSvc::setRelativeHvDropThreshold ( double threshold )

inlinevirtual

Implements IMdcHvDropSvc.

Definition at line 52 of file MdcHvDropSvc.h.

{ m_relativeHvDropThreshold=threshold;};

---

The documentation for this class was generated from the following files:

• MdcHvDropSvc.h
• MdcHvDropSvc.cxx