The Assimilation Project  based on Assimilation version 1.1.7.1474836767
cma.assimeventobserver.ForkExecObserver Class Reference
Inheritance diagram for cma.assimeventobserver.ForkExecObserver:
Collaboration diagram for cma.assimeventobserver.ForkExecObserver:

Public Member Functions

def __init__ (self, constraints=None, scriptdir=None)
 
def ioerror (self, event)
 
def __del__ (self)
 
def listenforevents (self)
 
def processJSONevent (self, jsonstr)
 
def listscripts (self)
 
- Public Member Functions inherited from cma.assimeventobserver.FIFOEventObserver
def __init__ (self, FIFOwritefd, constraints=None, maxerrcount=None)
 
def notifynewevent (self, event)
 
def ioerror (self, _unusedevent)
 
- Public Member Functions inherited from cma.assimeventobserver.AssimEventObserver
def __init__ (self, constraints)
 
def notifynewevent (self, event)
 
def is_interesting (self, event)
 

Data Fields

 scriptdir
 
 FIFOreadfd
 
 childpid
 
 FIFOwritefd
 
- Data Fields inherited from cma.assimeventobserver.FIFOEventObserver
 FIFOwritefd
 
 constraints
 
 errcount
 
 maxerrcount
 
 pipebufsize
 
- Data Fields inherited from cma.assimeventobserver.AssimEventObserver
 constraints
 

Additional Inherited Members

- Static Public Member Functions inherited from cma.assimeventobserver.AssimEventObserver
def getvalue (event, attr)
 
- Static Public Attributes inherited from cma.assimeventobserver.FIFOEventObserver
 NULstr = chr(0)
 

Detailed Description

Objects in this class execute scripts when events they are interested in
are observed.  Note that these events come to us through a pipe
that we create, but is written to by our base class FIFOEventObserver...

Definition at line 208 of file assimeventobserver.py.

Constructor & Destructor Documentation

def cma.assimeventobserver.ForkExecObserver.__init__ (   self,
  constraints = None,
  scriptdir = None 
)
Initializer for ForkExecObserver class.

Parameters:
-----------
constraints: dict
    Same as AssimEventObserver's constraints parameter.
scriptdir: str
    The directory where our scripts are found.  We execute them all whenever an
    event of the selected type occurs.

Definition at line 213 of file assimeventobserver.py.

def cma.assimeventobserver.ForkExecObserver.__del__ (   self)

Member Function Documentation

def cma.assimeventobserver.ForkExecObserver.ioerror (   self,
  event 
)
Re-initialize (respawn) our child in response to an I/O error

Definition at line 241 of file assimeventobserver.py.

References cma.assimeventobserver.ForkExecObserver.childpid, and cma.assimeventobserver.FIFOEventObserver.FIFOwritefd.

def cma.assimeventobserver.ForkExecObserver.listenforevents (   self)
def cma.assimeventobserver.ForkExecObserver.listscripts (   self)

Definition at line 352 of file assimeventobserver.py.

References cma.assimeventobserver.ForkExecObserver.scriptdir.

Referenced by cma.assimeventobserver.ForkExecObserver.processJSONevent().

Here is the caller graph for this function:

def cma.assimeventobserver.ForkExecObserver.processJSONevent (   self,
  jsonstr 
)

Definition at line 329 of file assimeventobserver.py.

References cma.assimeventobserver.ForkExecObserver._JSONevent_env(), and cma.assimeventobserver.ForkExecObserver.listscripts().

Referenced by cma.assimeventobserver.ForkExecObserver.listenforevents().

Here is the call graph for this function:

Here is the caller graph for this function:

Field Documentation

cma.assimeventobserver.ForkExecObserver.childpid
cma.assimeventobserver.ForkExecObserver.FIFOreadfd
cma.assimeventobserver.ForkExecObserver.FIFOwritefd

Definition at line 251 of file assimeventobserver.py.

cma.assimeventobserver.ForkExecObserver.scriptdir

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