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 ()
Public Member Functions inherited from IMdcHvDropSvc

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
}

~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