CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
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

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

204  def __init__(self,servers = [],cores = 4,jay = 2):
205  dict.__init__(self,dict.fromkeys(servers))
206  for srv in self.keys():
207  self[srv]=queueNode(cores,jay)
208  self.Cores = cores
209  self.Jay = jay
210  self.QueueLock = RLock()
211  self.EdmRefreshLock = RLock()
212 
213 
def __init__(self, dataset, job_number, job_id, job_name, isDA, isMC, applyBOWS, applyEXTRACOND, extraconditions, runboundary, lumilist, intlumi, maxevents, gt, allFromGT, alignmentDB, alignmentTAG, apeDB, apeTAG, bowDB, bowTAG, vertextype, tracktype, refittertype, ttrhtype, applyruncontrol, ptcut, CMSSW_dir, the_dir)

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

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

◆ thinerQueue()

def psClasses.queueList.thinerQueue (   self)

Definition at line 224 of file psClasses.py.

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

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

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.