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
psClasses.queueList Class Reference
Inheritance diagram for psClasses.queueList:

Public Member Functions

def __init__
 
def smallestQueue
 
def thinerQueue
 

Public Attributes

 Cores
 
 EdmRefreshLock
 
 Jay
 
 QueueLock
 

Detailed Description

Definition at line 203 of file psClasses.py.

Constructor & Destructor Documentation

def psClasses.queueList.__init__ (   self,
  servers = [],
  cores = 4,
  jay = 2 
)

Definition at line 204 of file psClasses.py.

References Enumerate.Enumerate.keys(), DictTypes.SortedKeysDict.keys(), MagFieldConfig.keys, edm::RefVectorBase< T >.keys(), edm::RefVectorBase< key_type >.keys(), RefVectorBase< KEY >.keys(), generateEDF.LumiInfoCont.keys(), edm::AssociationMap< edm::OneToManyWithQualityGeneric< TrackingParticleCollection, edm::View< reco::Track >, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< Trajectory >, std::vector< TrajectorySeed >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< CaloParticle >, BXVector< l1t::HGCalTriggerCell >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< reco::TrackCollection, reco::TauImpactParameterTrackData > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::TrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< edm::View< reco::Vertex >, TrackingVertexCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< TrackCandidate >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< reco::Track >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< BasicClusterCollection, float, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< TrackingVertexCollection, edm::View< reco::Vertex >, double > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< Tag >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQualityGeneric< edm::View< reco::Track >, TrackingParticleCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< MomentumConstraint > > >.keys(), and svgfig.SVG.keys().

205  def __init__(self,servers = [],cores = 4,jay = 2):
206  dict.__init__(self,dict.fromkeys(servers))
207  for srv in self.keys():
208  self[srv]=queueNode(cores,jay)
209  self.Cores = cores
210  self.Jay = jay
211  self.QueueLock = RLock()
212  self.EdmRefreshLock = RLock()
213 

Member Function Documentation

def psClasses.queueList.smallestQueue (   self)

Definition at line 214 of file psClasses.py.

References Enumerate.Enumerate.keys(), DictTypes.SortedKeysDict.keys(), MagFieldConfig.keys, edm::RefVectorBase< T >.keys(), edm::RefVectorBase< key_type >.keys(), RefVectorBase< KEY >.keys(), generateEDF.LumiInfoCont.keys(), edm::AssociationMap< edm::OneToManyWithQualityGeneric< TrackingParticleCollection, edm::View< reco::Track >, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< Trajectory >, std::vector< TrajectorySeed >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< CaloParticle >, BXVector< l1t::HGCalTriggerCell >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< reco::TrackCollection, reco::TauImpactParameterTrackData > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::TrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< edm::View< reco::Vertex >, TrackingVertexCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< TrackCandidate >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< reco::Track >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< BasicClusterCollection, float, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< TrackingVertexCollection, edm::View< reco::Vertex >, double > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< Tag >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQualityGeneric< edm::View< reco::Track >, TrackingParticleCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< MomentumConstraint > > >.keys(), and svgfig.SVG.keys().

215  def smallestQueue(self):
216  smallest=self.keys()[0]
217  sizeSmallest=self[smallest].pendingThreads()
218  for srv in self.keys()[1:]:
219  size=self[srv].pendingThreads()
220  if size < sizeSmallest:
221  smallest = srv
222  sizeSmallest = size
223  return smallest
def psClasses.queueList.thinerQueue (   self)

Definition at line 224 of file psClasses.py.

References Enumerate.Enumerate.keys(), DictTypes.SortedKeysDict.keys(), MagFieldConfig.keys, edm::RefVectorBase< T >.keys(), edm::RefVectorBase< key_type >.keys(), RefVectorBase< KEY >.keys(), generateEDF.LumiInfoCont.keys(), edm::AssociationMap< edm::OneToManyWithQualityGeneric< TrackingParticleCollection, edm::View< reco::Track >, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< Trajectory >, std::vector< TrajectorySeed >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< CaloParticle >, BXVector< l1t::HGCalTriggerCell >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< reco::TrackCollection, reco::TauImpactParameterTrackData > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::TrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< edm::View< reco::Vertex >, TrackingVertexCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< TrackCandidate >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< reco::Track >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, std::vector< Trajectory >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< BasicClusterCollection, float, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< TrackingVertexCollection, edm::View< reco::Vertex >, double > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< Tag >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToManyWithQualityGeneric< edm::View< reco::Track >, TrackingParticleCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< MomentumConstraint > > >.keys(), and svgfig.SVG.keys().

225  def thinerQueue(self):
226  thinnest=self.keys()[0]
227  weightThinnest=self[thinnest].queueWeight()
228  for srv in self.keys()[1:]:
229  weight=self[srv].queueWeight()
230  if weight < weightThinnest:
231  thinnest = srv
232  weightThinnest = weight
233  return thinnest
234 
235 
236 
237 
238 
239 

Member Data Documentation

psClasses.queueList.Cores

Definition at line 208 of file psClasses.py.

psClasses.queueList.EdmRefreshLock

Definition at line 211 of file psClasses.py.

psClasses.queueList.Jay

Definition at line 209 of file psClasses.py.

psClasses.queueList.QueueLock

Definition at line 210 of file psClasses.py.