esMonitoring.LineHistoryStart Class Reference

Inheritance diagram for esMonitoring.LineHistoryStart:

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

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

Definition at line 190 of file esMonitoring.py.

    def __init__(self, *kargs, **kwargs):
        LineHistoryEnd.__init__(self, *kargs, **kwargs)
        self.done = False

Member Function Documentation

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::RUN_INFO::RUN_NUMBER.size, cond::persistency::TAG::NAME.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::TAG::LAST_VALIDATED_TIME.size, cond::persistency::RUN_INFO::MAX_RUN_NUMBER.size, cond::persistency::TAG::INSERTION_TIME.size, cond::persistency::TAG::MODIFICATION_TIME.size, cond::persistency::RUN_INFO::MIN_RUN_NUMBER.size, cond::persistency::RUN_INFO::MIN_START_TIME.size, cond::persistency::GLOBAL_TAG_MAP::GLOBAL_TAG_NAME.size, cond::persistency::GLOBAL_TAG_MAP::RECORD.size, cond::persistency::GLOBAL_TAG_MAP::LABEL.size, reco::Candidate.size, Phase2ITPixelClusterShapeCache::Field.size, SiPixelClusterShapeCache::Field.size, cond::persistency::GLOBAL_TAG_MAP::TAG_NAME.size, reco::Vertex.size, cond::persistency::PAYLOAD::HASH.size, cond::persistency::PAYLOAD::OBJECT_TYPE.size, cond::persistency::PAYLOAD::DATA.size, SiStripLAProfileBooker.size, cond::persistency::PAYLOAD::STREAMER_INFO.size, cond::persistency::PAYLOAD::VERSION.size, cond::persistency::PAYLOAD::INSERTION_TIME.size, cond::TagInfo_t.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, cond::persistency::IOV::SEQUENCE_SIZE.size, cond::persistency::IOV::MIN_SINCE.size, cond::persistency::IOV::MAX_SINCE.size, edmNew::dstvdetails::DetSetVectorTrans::Item.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, cond::persistency::TAG_LOG::USER_TEXT.size, and esMonitoring.LineHistoryEnd.size.

Referenced by pkg.AbstractPkg.generate().

    def write(self, line):
        if self.done:
            return

        if ((self.size + len(line)) > self.max_bytes):
            self.done = True
            return

        if (len(self.buf) > self.max_lines):
            self.done = True
            return

        self.push(line)

Member Data Documentation

esMonitoring.LineHistoryStart.done

Definition at line 192 of file esMonitoring.py.

Referenced by esMonitoring.LineHistoryStart.write().