lsst.ctrl.pool.pool.PoolNode Class Reference

Inheritance diagram for lsst.ctrl.pool.pool.PoolNode:

Public Member Functions
def	__init__ (self, comm=None, root=0)
def	log (self, msg, *args)
def	isMaster (self)
def	storeSet (self, context, **kwargs)
def	storeDel (self, context, *nameList)
def	storeClear (self, context)
def	cacheClear (self, context)
def	cacheList (self, context)
def	storeList (self, context)
def	__call__ (cls, *args, **kwargs)

Public Attributes
	comm
	rank
	root
	size
	debugger
	node

Detailed Description

Node in MPI process pool

WARNING: You should not let a pool instance hang around at program
termination, as the garbage collection behaves differently, and may
cause a segmentation fault (signal 11).

Definition at line 486 of file pool.py.

Constructor & Destructor Documentation

__init__()

def lsst.ctrl.pool.pool.PoolNode.__init__	(		self,
			comm = None,
			root = 0
	)

Definition at line 494 of file pool.py.

    def __init__(self, comm=None, root=0):
        if comm is None:
            comm = Comm()
        self.comm = comm
        self.rank = self.comm.rank
        self.root = root
        self.size = self.comm.size
        self._cache = {}
        self._store = {}
        self.debugger = Debugger()
        self.node = NODE
 

Member Function Documentation

__call__()

def lsst.ctrl.pool.pool.SingletonMeta.__call__ (   cls, *  args, **  kwargs  )

inherited

Definition at line 387 of file pool.py.

    def __call__(cls, *args, **kwargs):
        if cls._instance is None:
            cls._instance = super(SingletonMeta, cls).__call__(*args, **kwargs)
        return cls._instance
 
 

cacheClear()

def lsst.ctrl.pool.pool.PoolNode.cacheClear	(		self,
			context
	)

Reset cache for a particular context

Reimplemented in lsst.ctrl.pool.pool.PoolMaster.

Definition at line 607 of file pool.py.

    def cacheClear(self, context):
        """Reset cache for a particular context"""
        self.log("clearing cache", context)
        if context not in self._cache:
            return
        self._cache[context] = {}
 

cacheList()

def lsst.ctrl.pool.pool.PoolNode.cacheList	(		self,
			context
	)

List contents of cache

Reimplemented in lsst.ctrl.pool.pool.PoolMaster.

Definition at line 614 of file pool.py.

    def cacheList(self, context):
        """List contents of cache"""
        cache = self._cache[context] if context in self._cache else {}
        sys.stderr.write("Cache on %s (%s): %s\n" % (self.node, context, cache))
 

isMaster()

def lsst.ctrl.pool.pool.PoolNode.isMaster

(

self

)

Definition at line 526 of file pool.py.

    def isMaster(self):
        return self.rank == self.root
 

log()

def lsst.ctrl.pool.pool.PoolNode.log	(		self,
			msg,
		*	args
	)

Log a debugging message

Reimplemented in lsst.ctrl.pool.pool.PoolSlave, and lsst.ctrl.pool.pool.PoolMaster.

Definition at line 522 of file pool.py.

    def log(self, msg, *args):
        """Log a debugging message"""
        self.debugger.log("Node %d" % self.rank, msg, *args)
 

storeClear()

def lsst.ctrl.pool.pool.PoolNode.storeClear	(		self,
			context
	)

Clear stored data for a particular context

Reimplemented in lsst.ctrl.pool.pool.PoolMaster.

Definition at line 600 of file pool.py.

    def storeClear(self, context):
        """Clear stored data for a particular context"""
        self.log("clearing store", context)
        if context not in self._store:
            raise KeyError("No such context: %s" % context)
        self._store[context] = {}
 

storeDel()

def lsst.ctrl.pool.pool.PoolNode.storeDel	(		self,
			context,
		*	nameList
	)

Delete value in store for a particular context

Reimplemented in lsst.ctrl.pool.pool.PoolMaster.

Definition at line 592 of file pool.py.

    def storeDel(self, context, *nameList):
        """Delete value in store for a particular context"""
        self.log("deleting from store", context, nameList)
        if context not in self._store:
            raise KeyError("No such context: %s" % context)
        for name in nameList:
            del self._store[context][name]
 

storeList()

def lsst.ctrl.pool.pool.PoolNode.storeList	(		self,
			context
	)

List contents of store for a particular context

Reimplemented in lsst.ctrl.pool.pool.PoolMaster.

Definition at line 619 of file pool.py.

    def storeList(self, context):
        """List contents of store for a particular context"""
        if context not in self._store:
            raise KeyError("No such context: %s" % context)
        sys.stderr.write("Store on %s (%s): %s\n" % (self.node, context, self._store[context]))
 
 

storeSet()

def lsst.ctrl.pool.pool.PoolNode.storeSet	(		self,
			context,
		**	kwargs
	)

Set values in store for a particular context

Reimplemented in lsst.ctrl.pool.pool.PoolMaster.

Definition at line 584 of file pool.py.

    def storeSet(self, context, **kwargs):
        """Set values in store for a particular context"""
        self.log("storing", context, kwargs)
        if context not in self._store:
            self._store[context] = {}
        for name, value in kwargs.items():
            self._store[context][name] = value
 

Member Data Documentation

comm

lsst.ctrl.pool.pool.PoolNode.comm

Definition at line 497 of file pool.py.

debugger

lsst.ctrl.pool.pool.PoolNode.debugger

Definition at line 503 of file pool.py.

node

lsst.ctrl.pool.pool.PoolNode.node

Definition at line 504 of file pool.py.

rank

lsst.ctrl.pool.pool.PoolNode.rank

Definition at line 498 of file pool.py.

root

lsst.ctrl.pool.pool.PoolNode.root

Definition at line 499 of file pool.py.

size

lsst.ctrl.pool.pool.PoolNode.size

Definition at line 500 of file pool.py.

---

The documentation for this class was generated from the following file:

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/ctrl_pool/22.0.1-2-g92698f7+9f079a9461/python/lsst/ctrl/pool/pool.py