Reference Manual

CMS 3D

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

◆ init()

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< key_type >.keys(), edm::RefVectorBase< KEY >.keys(), RefVectorBase< KEY >.keys(), generateEDF.LumiInfoCont.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< BasicClusterCollection, float, unsigned short > >.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::OneToManyWithQuality< edm::View< reco::Vertex >, TrackingVertexCollection, double > >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), vector< SimTrack >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< TrackingVertexCollection, edm::View< reco::Vertex >, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), vector< SimTrack > unsigned int.keys(), edm::AssociationMap< Tag >.keys(), vector< CaloParticle >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.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

◆ smallestQueue()

def psClasses.queueList.smallestQueue ( self )

Definition at line 214 of file psClasses.py.

References Enumerate.Enumerate.keys(), DictTypes.SortedKeysDict.keys(), MagFieldConfig.keys, edm::RefVectorBase< key_type >.keys(), edm::RefVectorBase< KEY >.keys(), RefVectorBase< KEY >.keys(), generateEDF.LumiInfoCont.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< BasicClusterCollection, float, unsigned short > >.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::OneToManyWithQuality< edm::View< reco::Vertex >, TrackingVertexCollection, double > >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), vector< SimTrack >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< TrackingVertexCollection, edm::View< reco::Vertex >, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), vector< SimTrack > unsigned int.keys(), edm::AssociationMap< Tag >.keys(), vector< CaloParticle >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.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
       

◆ thinerQueue()

def psClasses.queueList.thinerQueue ( self )

Definition at line 224 of file psClasses.py.

References Enumerate.Enumerate.keys(), DictTypes.SortedKeysDict.keys(), MagFieldConfig.keys, edm::RefVectorBase< key_type >.keys(), edm::RefVectorBase< KEY >.keys(), RefVectorBase< KEY >.keys(), generateEDF.LumiInfoCont.keys(), edm::AssociationMap< edm::OneToMany< std::vector< SimTrack >, std::vector< OmniClusterRef >, unsigned int > >.keys(), edm::AssociationMap< edm::OneToValue< BasicClusterCollection, float, unsigned short > >.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::OneToManyWithQuality< edm::View< reco::Vertex >, TrackingVertexCollection, double > >.keys(), edm::AssociationMap< edm::OneToMany< JetC, reco::TrackCollection > >.keys(), vector< SimTrack >.keys(), edm::AssociationMap< edm::OneToOne< reco::TrackCollection, std::vector< TrackParamConstraint > > >.keys(), edm::AssociationMap< edm::OneToManyWithQuality< TrackingVertexCollection, edm::View< reco::Vertex >, double > >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< MomentumConstraint > > >.keys(), vector< SimTrack > unsigned int.keys(), edm::AssociationMap< Tag >.keys(), vector< CaloParticle >.keys(), edm::AssociationMap< edm::OneToOne< reco::GsfTrackCollection, std::vector< VertexConstraint > > >.keys(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.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

◆ Cores

psClasses.queueList.Cores

Definition at line 208 of file psClasses.py.

◆ EdmRefreshLock

psClasses.queueList.EdmRefreshLock

Definition at line 211 of file psClasses.py.

◆ Jay

psClasses.queueList.Jay

Definition at line 209 of file psClasses.py.

◆ QueueLock

psClasses.queueList.QueueLock

Definition at line 210 of file psClasses.py.