psClasses.queueList Class Reference

Inheritance diagram for psClasses.queueList:

Public Member Functions
def	__init__ (self, servers=[], cores=4, jay=2)
def	smallestQueue (self)
def	thinerQueue (self)

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 cms::Filter.keys, Enumerate.Enumerate.keys(), MagFieldConfig.keys, DictTypes.SortedKeysDict.keys(), RefVectorBase< KEY >.keys(), edm::RefVectorBase< KEY >.keys(), edm::RefVectorBase< key_type >.keys(), cmsPerfPublish.Table.keys, generateEDF.LumiInfoCont.keys(), vector< SimTrack > unsigned int.keys(), vector< SimTrack >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< MomentumConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< TrackCandidate >, std::vector< Trajectory >, unsigned int > >.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::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::OneToManyWithQualityGeneric< edm::View< reco::Track >, TrackingParticleCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< VertexConstraint > > >.keys(), vector< TrackCandidate >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), vector< TrackCandidate > unsigned int.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(), OneToOne< reco::TrackCollection, EcalRecHitCollection >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), vector< reco::Track > unsigned int.keys(), vector< reco::Track >.keys(), edm::AssociationMap< Tag >.keys(), vector< Trajectory >.keys(), vector< Trajectory > unsigned int.keys(), and svgfig.SVG.keys().

  def __init__(self,servers = [],cores = 4,jay = 2):
    dict.__init__(self,dict.fromkeys(servers))
    for srv in self.keys():
      self[srv]=queueNode(cores,jay)
    self.Cores = cores
    self.Jay = jay
    self.QueueLock = RLock() 
    self.EdmRefreshLock = RLock()
  

Member Function Documentation

def psClasses.queueList.smallestQueue

(

self

)

Definition at line 214 of file psClasses.py.

References cms::Filter.keys, Enumerate.Enumerate.keys(), MagFieldConfig.keys, DictTypes.SortedKeysDict.keys(), RefVectorBase< KEY >.keys(), edm::RefVectorBase< KEY >.keys(), edm::RefVectorBase< key_type >.keys(), cmsPerfPublish.Table.keys, generateEDF.LumiInfoCont.keys(), vector< SimTrack > unsigned int.keys(), vector< SimTrack >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< MomentumConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< TrackCandidate >, std::vector< Trajectory >, unsigned int > >.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::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::OneToManyWithQualityGeneric< edm::View< reco::Track >, TrackingParticleCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< VertexConstraint > > >.keys(), vector< TrackCandidate >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), vector< TrackCandidate > unsigned int.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(), OneToOne< reco::TrackCollection, EcalRecHitCollection >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), vector< reco::Track > unsigned int.keys(), vector< reco::Track >.keys(), edm::AssociationMap< Tag >.keys(), vector< Trajectory >.keys(), vector< Trajectory > unsigned int.keys(), and svgfig.SVG.keys().

  def smallestQueue(self):
    smallest=self.keys()[0]
    sizeSmallest=self[smallest].pendingThreads()
    for srv in self.keys()[1:]:
      size=self[srv].pendingThreads()
      if size < sizeSmallest:
        smallest = srv
        sizeSmallest = size
    return smallest
      

def psClasses.queueList.thinerQueue

(

self

)

Definition at line 224 of file psClasses.py.

References cms::Filter.keys, Enumerate.Enumerate.keys(), MagFieldConfig.keys, DictTypes.SortedKeysDict.keys(), RefVectorBase< KEY >.keys(), edm::RefVectorBase< KEY >.keys(), edm::RefVectorBase< key_type >.keys(), cmsPerfPublish.Table.keys, generateEDF.LumiInfoCont.keys(), vector< SimTrack > unsigned int.keys(), vector< SimTrack >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< MomentumConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< TrackCandidate >, std::vector< Trajectory >, unsigned int > >.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::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::OneToManyWithQualityGeneric< edm::View< reco::Track >, TrackingParticleCollection, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< VertexConstraint > > >.keys(), vector< TrackCandidate >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), vector< TrackCandidate > unsigned int.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(), OneToOne< reco::TrackCollection, EcalRecHitCollection >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), vector< reco::Track > unsigned int.keys(), vector< reco::Track >.keys(), edm::AssociationMap< Tag >.keys(), vector< Trajectory >.keys(), vector< Trajectory > unsigned int.keys(), and svgfig.SVG.keys().

  def thinerQueue(self):
    thinnest=self.keys()[0]
    weightThinnest=self[thinnest].queueWeight()
    for srv in self.keys()[1:]:
      weight=self[srv].queueWeight()
      if weight < weightThinnest:
        thinnest = srv
        weightThinnest = weight
    return thinnest
  
    
    
    
   

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.

---

Generated for CMSSW Reference Manual by  1.8.11