CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
esMonitoring.LineHistoryStart Class Reference
Inheritance diagram for esMonitoring.LineHistoryStart:
esMonitoring.LineHistoryEnd

Public Member Functions

def __init__ (self, kargs, kwargs)
 
def write (self, line)
 
- Public Member Functions inherited from esMonitoring.LineHistoryEnd
def __init__ (self, max_bytes=16 *1024, max_lines=256)
 
def pop (self)
 
def push (self, rbuf)
 
def to_json (self)
 
def write (self, line)
 

Public Attributes

 done
 
- Public Attributes inherited from esMonitoring.LineHistoryEnd
 buf
 
 max_bytes
 
 max_lines
 
 size
 

Detailed Description

Definition at line 189 of file esMonitoring.py.

Constructor & Destructor Documentation

◆ __init__()

def esMonitoring.LineHistoryStart.__init__ (   self,
  kargs,
  kwargs 
)

Definition at line 190 of file esMonitoring.py.

190  def __init__(self, *kargs, **kwargs):
191  LineHistoryEnd.__init__(self, *kargs, **kwargs)
192  self.done = False
193 
def __init__(self, dataset, job_number, job_id, job_name, isDA, isMC, applyBOWS, applyEXTRACOND, extraconditions, runboundary, lumilist, intlumi, maxevents, gt, allFromGT, alignmentDB, alignmentTAG, apeDB, apeTAG, bowDB, bowTAG, vertextype, tracktype, refittertype, ttrhtype, applyruncontrol, ptcut, CMSSW_dir, the_dir)

Member Function Documentation

◆ write()

def esMonitoring.LineHistoryStart.write (   self,
  line 
)

Definition at line 194 of file esMonitoring.py.

References fbuf.buf, cfstream.buf, base64_decode_context.buf, esMonitoring.LineHistoryEnd.buf, esMonitoring.LineHistoryStart.done, esMonitoring.LineHistoryEnd.max_bytes, esMonitoring.LineHistoryEnd.max_lines, reco::parser::ExpressionVarSetter.push(), hcaldqm::ContainerXXX< STDTYPE >.push(), reco::parser::MethodSetter.push(), esMonitoring.LineHistoryEnd.push(), cond::persistency::GLOBAL_TAG::NAME.size, cond::persistency::TAG::NAME.size, cond::persistency::RUN_INFO::RUN_NUMBER.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::GLOBAL_TAG::VALIDITY.size, cond::persistency::RUN_INFO::START_TIME.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::RUN_INFO::END_TIME.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::GLOBAL_TAG::RELEASE.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::GLOBAL_TAG::SNAPSHOT_TIME.size, cond::persistency::TAG::END_OF_VALIDITY.size, cond::persistency::GLOBAL_TAG::INSERTION_TIME.size, cond::persistency::TAG::DESCRIPTION.size, cond::persistency::O2O_RUN::JOB_NAME.size, cond::persistency::TAG::LAST_VALIDATED_TIME.size, cond::persistency::O2O_RUN::START_TIME.size, cond::persistency::RUN_INFO::MAX_RUN_NUMBER.size, cond::persistency::TAG::INSERTION_TIME.size, cond::persistency::O2O_RUN::END_TIME.size, cond::persistency::TAG::MODIFICATION_TIME.size, cond::persistency::O2O_RUN::STATUS_CODE.size, SiPixelROCsStatusAndMapping.size, cond::persistency::TAG::PROTECTION_CODE.size, cond::persistency::O2O_RUN::LOG.size, calo::common::AddSize< tags::Ptr >.size, cond::persistency::RUN_INFO::MIN_RUN_NUMBER.size, calo::common::AddSize< tags::DevPtr >.size, cond::persistency::RUN_INFO::MIN_START_TIME.size, SiPixelROCsStatusAndMappingWrapper.size, reco::Candidate.size, reco::Vertex.size, SiPixelClusterShapeCache::Field.size, cond::persistency::GLOBAL_TAG_MAP::GLOBAL_TAG_NAME.size, cond::persistency::GLOBAL_TAG_MAP::RECORD.size, cond::persistency::GLOBAL_TAG_MAP::LABEL.size, cond::persistency::GLOBAL_TAG_MAP::TAG_NAME.size, SiStripLAProfileBooker.size, cond::TagInfo_t.size, cond::persistency::PAYLOAD::HASH.size, cond::persistency::PAYLOAD::OBJECT_TYPE.size, cond::persistency::PAYLOAD::DATA.size, cond::persistency::PAYLOAD::STREAMER_INFO.size, cond::persistency::PAYLOAD::VERSION.size, cond::persistency::PAYLOAD::INSERTION_TIME.size, cond::persistency::IOV::TAG_NAME.size, cond::persistency::IOV::SINCE.size, cond::persistency::IOV::PAYLOAD_HASH.size, cond::persistency::IOV::INSERTION_TIME.size, cond::persistency::IOV::SINCE_GROUP.size, edmNew::dstvdetails::DetSetVectorTrans::Item.size, cond::persistency::IOV::SEQUENCE_SIZE.size, cond::persistency::IOV::MIN_SINCE.size, cond::persistency::IOV::MAX_SINCE.size, esMonitoring.LineHistoryEnd.size, cond::persistency::TAG_AUTHORIZATION::TAG_NAME.size, cond::persistency::TAG_AUTHORIZATION::ACCESS_TYPE.size, cond::persistency::TAG_AUTHORIZATION::CREDENTIAL.size, cond::persistency::TAG_AUTHORIZATION::CREDENTIAL_TYPE.size, cond::persistency::TAG_LOG::TAG_NAME.size, cond::persistency::TAG_LOG::EVENT_TIME.size, cond::persistency::TAG_LOG::USER_NAME.size, cond::persistency::TAG_LOG::HOST_NAME.size, cond::persistency::TAG_LOG::COMMAND.size, cond::persistency::TAG_LOG::ACTION.size, and cond::persistency::TAG_LOG::USER_TEXT.size.

Referenced by pkg.AbstractPkg.generate().

194  def write(self, line):
195  if self.done:
196  return
197 
198  if ((self.size + len(line)) > self.max_bytes):
199  self.done = True
200  return
201 
202  if (len(self.buf) > self.max_lines):
203  self.done = True
204  return
205 
206  self.push(line)
207 

Member Data Documentation

◆ done

esMonitoring.LineHistoryStart.done

Definition at line 192 of file esMonitoring.py.

Referenced by esMonitoring.LineHistoryStart.write().