CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Member Functions | Public Attributes
esMonitoring.LineHistoryEnd Class Reference
Inheritance diagram for esMonitoring.LineHistoryEnd:
esMonitoring.LineHistoryStart

Public Member Functions

def __init__
 
def pop
 
def push
 
def to_json
 
def write
 

Public Attributes

 buf
 
 max_bytes
 
 max_lines
 
 size
 

Detailed Description

Definition at line 159 of file esMonitoring.py.

Constructor & Destructor Documentation

def esMonitoring.LineHistoryEnd.__init__ (   self,
  max_bytes = 16*1024,
  max_lines = 256 
)

Definition at line 160 of file esMonitoring.py.

160 
161  def __init__(self, max_bytes=16*1024, max_lines=256):
162  self.max_bytes = max_bytes
163  self.max_lines = max_lines
164 
165  self.buf = collections.deque()
166  self.size = 0

Member Function Documentation

def esMonitoring.LineHistoryEnd.pop (   self)

Definition at line 167 of file esMonitoring.py.

References cond::persistency::GLOBAL_TAG::NAME.size, cond::persistency::TAG::NAME.size, cond::persistency::RUN_INFO::RUN_NUMBER.size, cond::persistency::GLOBAL_TAG::VALIDITY.size, cond::persistency::RUN_INFO::START_TIME.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::RUN_INFO::END_TIME.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::GLOBAL_TAG::RELEASE.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 SequenceTypes.Schedule._replaceIfHeldDirectly(), and esMonitoring.LineHistoryEnd.write().

167 
168  def pop(self):
169  elm = self.buf.popleft()
170  self.size -= len(elm)
def esMonitoring.LineHistoryEnd.push (   self,
  rbuf 
)

Definition at line 171 of file esMonitoring.py.

References cond::persistency::GLOBAL_TAG::NAME.size, cond::persistency::TAG::NAME.size, cond::persistency::RUN_INFO::RUN_NUMBER.size, cond::persistency::GLOBAL_TAG::VALIDITY.size, cond::persistency::RUN_INFO::START_TIME.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::RUN_INFO::END_TIME.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::GLOBAL_TAG::RELEASE.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 esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

171 
172  def push(self, rbuf):
173  self.buf.append(rbuf)
174  self.size += len(rbuf)
def esMonitoring.LineHistoryEnd.to_json (   self)

Definition at line 186 of file esMonitoring.py.

References fbuf.buf, cfstream.buf, base64_decode_context.buf, and esMonitoring.LineHistoryEnd.buf.

186 
187  def to_json(self):
188  return list(self.buf)
def esMonitoring.LineHistoryEnd.write (   self,
  line 
)

Definition at line 175 of file esMonitoring.py.

References fbuf.buf, cfstream.buf, base64_decode_context.buf, esMonitoring.LineHistoryEnd.buf, esMonitoring.LineHistoryEnd.max_bytes, esMonitoring.LineHistoryEnd.max_lines, frozendict.frozendict.pop, DictTypes.SortedAndFixedKeysDict.pop, dqmservices::DQMFileIterator.pop(), DictTypes.FixedKeysDict.pop, esMonitoring.LineHistoryEnd.pop(), Config.FilteredStream.pop, 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::GLOBAL_TAG::VALIDITY.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::RUN_INFO::START_TIME.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::RUN_INFO::END_TIME.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::GLOBAL_TAG::RELEASE.size, cond::persistency::TAG::END_OF_VALIDITY.size, cond::persistency::GLOBAL_TAG::SNAPSHOT_TIME.size, cond::persistency::TAG::DESCRIPTION.size, cond::persistency::GLOBAL_TAG::INSERTION_TIME.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, SiPixelROCsStatusAndMapping.size, cond::persistency::TAG::MODIFICATION_TIME.size, cond::persistency::O2O_RUN::STATUS_CODE.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().

175 
176  def write(self, line):
177  line_size = len(line)
178 
179  while len(self.buf) and ((self.size + line_size) > self.max_bytes):
180  self.pop()
181 
182  while (len(self.buf) + 1) > self.max_lines:
183  self.pop()
184 
185  self.push(line)

Member Data Documentation

esMonitoring.LineHistoryEnd.buf

Definition at line 164 of file esMonitoring.py.

Referenced by esMonitoring.LineHistoryEnd.to_json(), esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

esMonitoring.LineHistoryEnd.max_bytes

Definition at line 161 of file esMonitoring.py.

Referenced by esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

esMonitoring.LineHistoryEnd.max_lines

Definition at line 162 of file esMonitoring.py.

Referenced by esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

esMonitoring.LineHistoryEnd.size

Definition at line 165 of file esMonitoring.py.

Referenced by ntupleDataFormat._Collection.__iter__(), ntupleDataFormat._Collection.__len__(), esMonitoring.LineHistoryEnd.pop(), esMonitoring.LineHistoryEnd.push(), cuy.FindIssue.startElement(), esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

Generated for CMSSW Reference Manual by doxygen 1.8.5