CMS 3D CMS Logo

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__ (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

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

Definition at line 160 of file esMonitoring.py.

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

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::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::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::RUN_INFO::END_TIME.size, cond::persistency::TAG::OBJECT_TYPE.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::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, SiStripLAProfileBooker.size, cond::persistency::PAYLOAD::DATA.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 esMonitoring.LineHistoryEnd.write().

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

Definition at line 171 of file esMonitoring.py.

References 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::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::RUN_INFO::END_TIME.size, cond::persistency::TAG::OBJECT_TYPE.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::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, SiStripLAProfileBooker.size, cond::persistency::PAYLOAD::DATA.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 esMonitoring.LineHistoryEnd.write(), and esMonitoring.LineHistoryStart.write().

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

Definition at line 186 of file esMonitoring.py.

References fbuf.buf, cfstream.buf, base64_decode_context.buf, esMonitoring.LineHistoryEnd.buf, and list().

186  def to_json(self):
187  return list(self.buf)
188 
How EventSelector::AcceptEvent() decides whether to accept an event for output otherwise it is excluding the probing of A single or multiple positive and the trigger will pass if any such matching triggers are PASS or EXCEPTION[A criterion thatmatches no triggers at all is detected and causes a throw.] A single negative with an expectation of appropriate bit checking in the decision and the trigger will pass if any such matching triggers are FAIL or EXCEPTION A wildcarded negative criterion that matches more than one trigger in the trigger list("!*","!HLTx*"if it matches 2 triggers or more) will accept the event if all the matching triggers are FAIL.It will reject the event if any of the triggers are PASS or EXCEPTION(this matches the behavior of"!*"before the partial wildcard feature was incorporated).Triggers which are in the READY state are completely ignored.(READY should never be returned since the trigger paths have been run
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, dqmservices::DQMFileIterator.pop(), esMonitoring.LineHistoryEnd.pop(), reco::parser::ExpressionVarSetter.push(), hcaldqm::ContainerXXX< STDTYPE >.push(), reco::parser::MethodSetter.push(), esMonitoring.LineHistoryEnd.push(), cond::persistency::TAG::NAME.size, cond::persistency::RUN_INFO::RUN_NUMBER.size, cond::persistency::GLOBAL_TAG::NAME.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::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, reco::Candidate.size, Phase2ITPixelClusterShapeCache::Field.size, SiPixelClusterShapeCache::Field.size, cond::persistency::GLOBAL_TAG_MAP::LABEL.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().

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

Member Data Documentation

esMonitoring.LineHistoryEnd.buf
esMonitoring.LineHistoryEnd.max_bytes
esMonitoring.LineHistoryEnd.max_lines
esMonitoring.LineHistoryEnd.size