esMonitoring.LineHistoryEnd Class Reference

Inheritance diagram for esMonitoring.LineHistoryEnd:

Public Member Functions
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
	buf
	max_bytes
	max_lines
	size

Detailed Description

Definition at line 159 of file esMonitoring.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 160 of file esMonitoring.py.

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

        self.buf = collections.deque()
        self.size = 0

Member Function Documentation

pop()

def esMonitoring.LineHistoryEnd.pop

(

self

)

Definition at line 167 of file esMonitoring.py.

References fbuf.buf, cfstream.buf, base64_decode_context.buf, esMonitoring.LineHistoryEnd.buf, 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 SequenceTypes.Schedule._replaceIfHeldDirectly(), and esMonitoring.LineHistoryEnd.write().

    def pop(self):
        elm = self.buf.popleft()
        self.size -= len(elm)

push()

def esMonitoring.LineHistoryEnd.push	(		self,
			rbuf
	)

Definition at line 171 of file esMonitoring.py.

References mps_setup.append, fbuf.buf, cfstream.buf, base64_decode_context.buf, esMonitoring.LineHistoryEnd.buf, 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::TAG::OBJECT_TYPE.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.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::O2O_RUN::JOB_NAME.size, cond::persistency::GLOBAL_TAG::INSERTION_TIME.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 esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

    def push(self, rbuf):
        self.buf.append(rbuf)
        self.size += len(rbuf)

to_json()

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.

    def to_json(self):
        return list(self.buf)

write()

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().

    def write(self, line):
        line_size = len(line)

        while len(self.buf) and ((self.size + line_size) > self.max_bytes):
            self.pop()

        while (len(self.buf) + 1) > self.max_lines:
            self.pop()

        self.push(line)

Member Data Documentation

buf

esMonitoring.LineHistoryEnd.buf

Definition at line 164 of file esMonitoring.py.

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

max_bytes

esMonitoring.LineHistoryEnd.max_bytes

Definition at line 161 of file esMonitoring.py.

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

max_lines

esMonitoring.LineHistoryEnd.max_lines

Definition at line 162 of file esMonitoring.py.

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

size

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().