CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Public Attributes
esMonitoring.History Class Reference
Inheritance diagram for esMonitoring.History:

Public Member Functions

def __init__
 
def flush
 
def pop
 
def push
 
def read
 
def write
 

Public Attributes

 buf
 
 max_size
 
 size
 

Detailed Description

Definition at line 155 of file esMonitoring.py.

Constructor & Destructor Documentation

def esMonitoring.History.__init__ (   self,
  history_size = 64*1024 
)

Definition at line 156 of file esMonitoring.py.

157  def __init__(self, history_size=64*1024):
158  self.max_size = history_size
159  self.buf = collections.deque()
160  self.size = 0

Member Function Documentation

def esMonitoring.History.flush (   self)

Definition at line 184 of file esMonitoring.py.

185  def flush(self):
186  pass
def esMonitoring.History.pop (   self)

Definition at line 161 of file esMonitoring.py.

References base64_decode_context.buf, esMonitoring.History.buf, cond::persistency::GLOBAL_TAG::NAME.size, cond::persistency::TAG::NAME.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::GLOBAL_TAG::VALIDITY.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::COND_LOG_TABLE::EXECTIME.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::GLOBAL_TAG::RELEASE.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::COND_LOG_TABLE::IOVTAG.size, cond::persistency::GLOBAL_TAG::SNAPSHOT_TIME.size, cond::persistency::TAG::END_OF_VALIDITY.size, cond::persistency::COND_LOG_TABLE::USERTEXT.size, cond::persistency::GLOBAL_TAG::INSERTION_TIME.size, cond::persistency::TAG::DESCRIPTION.size, cond::persistency::TAG::LAST_VALIDATED_TIME.size, cond::persistency::TAG::INSERTION_TIME.size, cond::persistency::TAG::MODIFICATION_TIME.size, cond::persistency::GLOBAL_TAG_MAP::GLOBAL_TAG_NAME.size, cond::persistency::GLOBAL_TAG_MAP::RECORD.size, reco::Vertex.size, cond::persistency::GLOBAL_TAG_MAP::LABEL.size, SiPixelClusterShapeCache::Field.size, cond::persistency::GLOBAL_TAG_MAP::TAG_NAME.size, cond::persistency::PAYLOAD::HASH.size, reco::Candidate.size, cond::persistency::PAYLOAD::OBJECT_TYPE.size, edmNew::dstvdetails::DetSetVectorTrans::Item.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::MAX_SINCE.size, cond::persistency::IOV::SINCE_GROUP.size, cond::persistency::IOV::SEQUENCE_SIZE.size, cond::persistency::TAG_MIGRATION::SOURCE_ACCOUNT.size, cond::persistency::TAG_MIGRATION::SOURCE_TAG.size, cond::persistency::TAG_MIGRATION::TAG_NAME.size, cond::persistency::TAG_MIGRATION::STATUS_CODE.size, cond::persistency::TAG_MIGRATION::INSERTION_TIME.size, esMonitoring.History.size, cond::persistency::PAYLOAD_MIGRATION::SOURCE_ACCOUNT.size, cond::persistency::PAYLOAD_MIGRATION::SOURCE_TOKEN.size, cond::persistency::PAYLOAD_MIGRATION::PAYLOAD_HASH.size, and cond::persistency::PAYLOAD_MIGRATION::INSERTION_TIME.size.

Referenced by esMonitoring.History.write().

162  def pop(self):
163  if not len(self.buf):
164  return None
165 
166  elm = self.buf.popleft()
167  self.size -= len(elm)
168 
169  return elm
def esMonitoring.History.push (   self,
  rbuf 
)

Definition at line 170 of file esMonitoring.py.

References cond::persistency::GLOBAL_TAG::NAME.size, cond::persistency::TAG::NAME.size, cond::persistency::GLOBAL_TAG::VALIDITY.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::COND_LOG_TABLE::EXECTIME.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::COND_LOG_TABLE::IOVTAG.size, cond::persistency::GLOBAL_TAG::RELEASE.size, cond::persistency::TAG::END_OF_VALIDITY.size, cond::persistency::COND_LOG_TABLE::USERTEXT.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::TAG::INSERTION_TIME.size, cond::persistency::TAG::MODIFICATION_TIME.size, cond::persistency::GLOBAL_TAG_MAP::GLOBAL_TAG_NAME.size, cond::persistency::GLOBAL_TAG_MAP::RECORD.size, reco::Vertex.size, cond::persistency::GLOBAL_TAG_MAP::LABEL.size, SiPixelClusterShapeCache::Field.size, cond::persistency::GLOBAL_TAG_MAP::TAG_NAME.size, cond::persistency::PAYLOAD::HASH.size, reco::Candidate.size, cond::persistency::PAYLOAD::OBJECT_TYPE.size, SiStripLAProfileBooker.size, edmNew::dstvdetails::DetSetVectorTrans::Item.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::MAX_SINCE.size, cond::persistency::IOV::SINCE_GROUP.size, cond::persistency::IOV::SEQUENCE_SIZE.size, cond::persistency::TAG_MIGRATION::SOURCE_ACCOUNT.size, cond::persistency::TAG_MIGRATION::SOURCE_TAG.size, cond::persistency::TAG_MIGRATION::TAG_NAME.size, cond::persistency::TAG_MIGRATION::STATUS_CODE.size, cond::persistency::TAG_MIGRATION::INSERTION_TIME.size, esMonitoring.History.size, cond::persistency::PAYLOAD_MIGRATION::SOURCE_ACCOUNT.size, cond::persistency::PAYLOAD_MIGRATION::SOURCE_TOKEN.size, cond::persistency::PAYLOAD_MIGRATION::PAYLOAD_HASH.size, and cond::persistency::PAYLOAD_MIGRATION::INSERTION_TIME.size.

Referenced by esMonitoring.History.write().

171  def push(self, rbuf):
172  self.buf.append(rbuf)
173  self.size += len(rbuf)
def esMonitoring.History.read (   self)

Definition at line 181 of file esMonitoring.py.

References base64_decode_context.buf, esMonitoring.History.buf, and join().

Referenced by Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor.goto(), and Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor.setFilterBranches().

182  def read(self):
183  return "".join(self.buf)
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
def esMonitoring.History.write (   self,
  rbuf 
)

Definition at line 174 of file esMonitoring.py.

References esMonitoring.History.max_size, frozendict.frozendict.pop, DictTypes.SortedAndFixedKeysDict.pop, dqmservices::DQMFileIterator.pop(), DictTypes.FixedKeysDict.pop, python.seqvaluedict.seqdict.pop(), esMonitoring.History.pop(), Config.FilteredStream.pop, ora::MultiIndexDataTrie.push(), reco::parser::ExpressionVarSetter.push(), reco::parser::MethodSetter.push(), python.seqvaluedict.seqdict.push(), esMonitoring.History.push(), cond::persistency::GLOBAL_TAG::NAME.size, cond::persistency::TAG::NAME.size, cond::persistency::GLOBAL_TAG::VALIDITY.size, cond::persistency::TAG::TIME_TYPE.size, cond::persistency::GLOBAL_TAG::DESCRIPTION.size, cond::persistency::COND_LOG_TABLE::EXECTIME.size, cond::persistency::TAG::OBJECT_TYPE.size, cond::persistency::TAG::SYNCHRONIZATION.size, cond::persistency::COND_LOG_TABLE::IOVTAG.size, cond::persistency::GLOBAL_TAG::RELEASE.size, cond::persistency::TAG::END_OF_VALIDITY.size, cond::persistency::COND_LOG_TABLE::USERTEXT.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::TAG::INSERTION_TIME.size, cond::persistency::TAG::MODIFICATION_TIME.size, cond::persistency::GLOBAL_TAG_MAP::GLOBAL_TAG_NAME.size, cond::persistency::GLOBAL_TAG_MAP::RECORD.size, reco::Vertex.size, cond::persistency::GLOBAL_TAG_MAP::LABEL.size, SiPixelClusterShapeCache::Field.size, cond::persistency::GLOBAL_TAG_MAP::TAG_NAME.size, cond::persistency::PAYLOAD::HASH.size, reco::Candidate.size, cond::persistency::PAYLOAD::OBJECT_TYPE.size, SiStripLAProfileBooker.size, edmNew::dstvdetails::DetSetVectorTrans::Item.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::MAX_SINCE.size, cond::persistency::IOV::SINCE_GROUP.size, cond::persistency::IOV::SEQUENCE_SIZE.size, cond::persistency::TAG_MIGRATION::SOURCE_ACCOUNT.size, cond::persistency::TAG_MIGRATION::SOURCE_TAG.size, cond::persistency::TAG_MIGRATION::TAG_NAME.size, cond::persistency::TAG_MIGRATION::STATUS_CODE.size, cond::persistency::TAG_MIGRATION::INSERTION_TIME.size, esMonitoring.History.size, cond::persistency::PAYLOAD_MIGRATION::SOURCE_ACCOUNT.size, cond::persistency::PAYLOAD_MIGRATION::SOURCE_TOKEN.size, cond::persistency::PAYLOAD_MIGRATION::PAYLOAD_HASH.size, and cond::persistency::PAYLOAD_MIGRATION::INSERTION_TIME.size.

Referenced by pkg.AbstractPkg.generate().

175  def write(self, rbuf):
176  l = len(rbuf)
177  while (self.size + l) >= self.max_size:
178  self.pop()
179 
180  self.push(rbuf)

Member Data Documentation

esMonitoring.History.buf

Definition at line 158 of file esMonitoring.py.

Referenced by esMonitoring.History.pop(), esMonitoring.History.read(), and esMonitoring.JsonInput.write().

esMonitoring.History.max_size

Definition at line 157 of file esMonitoring.py.

Referenced by esMonitoring.History.write().

esMonitoring.History.size

Definition at line 159 of file esMonitoring.py.

Referenced by cuy.FindIssue.__init__(), esMonitoring.History.pop(), esMonitoring.History.push(), and esMonitoring.History.write().