MdcHvDropSvc Class Reference

#include <MdcHvDropSvc.h>

Inheritance diagram for MdcHvDropSvc:

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

Friends
class	SvcFactory< MdcHvDropSvc >

Detailed Description

Definition at line 33 of file MdcHvDropSvc.h.

Constructor & Destructor Documentation

MdcHvDropSvc()

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

Definition at line 48 of file MdcHvDropSvc.cxx.

    : base_class( 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 74 of file MdcHvDropSvc.cxx.

{}

Member Function Documentation

finalize()

StatusCode MdcHvDropSvc::finalize ( )

virtual

Definition at line 112 of file MdcHvDropSvc.cxx.

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

handle()

void MdcHvDropSvc::handle

(

const Incident &

inc

)

Definition at line 119 of file MdcHvDropSvc.cxx.

                                               {
  MsgStream log( msgSvc(), name() );
  log << MSG::DEBUG << "handle: " << inc.type() << endmsg;
  // so currently we do nothing.
  // if (inc.type() == "NewRun") {
  //    log << MSG::DEBUG << "NewRun" << endmsg;
  //
  //    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 << endmsg;
  //    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" << endmsg;
  //     } 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 83 of file MdcHvDropSvc.cxx.

                                    {
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "MdcHvDropSvc::initialize()" << endmsg;
 
  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( "EventDataSvc", m_eventSvc, true );
  if ( sc.isFailure() )
  {
    log << MSG::ERROR << "Unable to find EventDataSvc " << endmsg;
    return sc;
  }
 
  sc = initMySql();
  if ( sc.isFailure() )
  {
    log << MSG::ERROR << "Unable to initialize mysql " << endmsg;
    return sc;
  }
 
  return StatusCode::SUCCESS;
}

queryIsHvDrop()

virtual bool MdcHvDropSvc::queryIsHvDrop ( )

inlinevirtual

Definition at line 54 of file MdcHvDropSvc.h.

{ return queryRelativeHvDrop() >= m_relativeHvDropThreshold; }

queryRelativeHvDrop()

double MdcHvDropSvc::queryRelativeHvDrop ( )

virtual

Definition at line 334 of file MdcHvDropSvc.cxx.

                                         {
  MsgStream log( msgSvc(), name() );
  // log << MSG::DEBUG << "MdcHvDropSvc::sqlRow2Item()" << endmsg;
  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 << endmsg;
  log << MSG::INFO << "current boundary " << m_vData.getLowerBoundaryEventTime() << " : "
      << m_vData.getUpperBoundaryEventTime() << endmsg;
 
  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 << endmsg;
      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 << endmsg;
        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 << endmsg;
        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 << endmsg;
        m_vData.clear();
        fetchBeginTime = time - 3600;
      }
    }
 
    fetchBeginTime += m_vData.getOffsetEvt2Db(); // now db time
    Time_t time2 = fetchBeginTime + m_fetchLength;
    if ( !FetchHvInfo( fetchBeginTime - 600, time2 ).isSuccess() )
    {
      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

Definition at line 51 of file MdcHvDropSvc.h.

                                                                {
    m_relativeHvDropThreshold = threshold;
  };

Friends And Related Symbol Documentation

SvcFactory< MdcHvDropSvc >

friend class SvcFactory< MdcHvDropSvc >

friend

Definition at line 1 of file MdcHvDropSvc.h.

---

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

• MdcHvDropSvc.h
• MdcHvDropSvc.cxx