Copernicus  2.0
 All Classes Namespaces Files Functions Variables
cpc.dataflow.active_network.ActiveNetwork Class Reference
Inheritance diagram for cpc.dataflow.active_network.ActiveNetwork:
cpc.dataflow.network.Network

Public Member Functions

def getParentInstance
 
def getNetworkLock
 
def addInstance
 
def getActiveInstance
 
def tryGetActiveInstance
 
def getActiveInstanceList
 
def getConnectionList
 
def getNamedActiveInstance
 
def getContainingNetwork
 
def getTaskQueue
 
def findConnectionSrcDest
 
def addConnection
 
def activateAll
 
def deactivateAll
 
def rerun
 
def getCumulativeCputime
 
def findErrorStates
 
def getNet
 
def writeXML
 
- Public Member Functions inherited from cpc.dataflow.network.Network
def addInstance
 
def getInstance
 
def findConnectionSrcDest
 
def addConnection
 
def removeConnection
 
def getInstances
 
def writeXML
 

Public Attributes

 project
 
 taskQueue
 
 baseDir
 
 inActiveInstance
 
 activeInstances
 
 lock
 
 networkLock
 
- Public Attributes inherited from cpc.dataflow.network.Network
 instances
 
 connections
 

Detailed Description

An active function network is a function network with actual data.

Member Function Documentation

def cpc.dataflow.active_network.ActiveNetwork.activateAll (   self)
Activate all activeinstances in this network, starting them.
def cpc.dataflow.active_network.ActiveNetwork.addConnection (   self,
  conn,
  sourceTag 
)
Add a connection. 
    findConnectionSrcDest MUST have been called on this connection
    before, and all affected output AIs MUST be locked at this point.
    After this, handleConnectedListenerInput() must be called on 
    affected destination ACPs' value.

    conn = the connection object
    sourceTag = the source to tag new inputs with
def cpc.dataflow.active_network.ActiveNetwork.addInstance (   self,
  inst 
)
Add a new instance, and return its activeInstance.
def cpc.dataflow.active_network.ActiveNetwork.deactivateAll (   self)
De-activate all activeinstances in this network, starting them.
def cpc.dataflow.active_network.ActiveNetwork.findConnectionSrcDest (   self,
  conn,
  affectedInputAIs,
  affectedOutputAIs 
)
First step in making a connection: finding out the source and 
   destination (and the affected source/destination active instances).

   conn = the Connection object. Updated by this function
   affectedInputAIs = a set that will be updated with the affected
              destination active instances of the new 
              connection.
   affectedOutputAIs = a set that will be updated with the active 
               instances that have changed outputs because of 
               the new connection. For these active instances,
               handleNewOutputConnections will have to be
               called. 
               This makes it possible to make multiple 
               connections in a single transaction.
def cpc.dataflow.active_network.ActiveNetwork.findErrorStates (   self,
  errlist,
  warnlist 
)
Find any error states associated with this any of the 
   sub-instances. Fill errlist & warnlist with active instances in
   these states.
def cpc.dataflow.active_network.ActiveNetwork.getActiveInstance (   self,
  name 
)
Get the named active instance associated with this network.
   Throw an ActiveError if not found.
def cpc.dataflow.active_network.ActiveNetwork.getActiveInstanceList (   self,
  listIO,
  listSelf 
)
Return a dict of instance names. If listIO is true, each instance's
   IO items are listed as well
def cpc.dataflow.active_network.ActiveNetwork.getConnectionList (   self)
Return a list of instance connections.
def cpc.dataflow.active_network.ActiveNetwork.getContainingNetwork (   self,
  instancePath 
)
Get the network and instanceName that contains the item in a 
   path specifier according to 
   [instance]:[instance]:... 

   returns a tuple (network, instanceName)
def cpc.dataflow.active_network.ActiveNetwork.getCumulativeCputime (   self)
Get the cumulative CPU time used (in seconds) for all active
   instances in this network and all subnets.
def cpc.dataflow.active_network.ActiveNetwork.getNamedActiveInstance (   self,
  instancePath 
)
Get and instance/network in a path specifier according to 
   [instance]:[instance]:... 
def cpc.dataflow.active_network.ActiveNetwork.getNet (   self)
Get the first network, or None if none exists.
def cpc.dataflow.active_network.ActiveNetwork.getNetworkLock (   self)
Get the global network lock assigned to this active network.
def cpc.dataflow.active_network.ActiveNetwork.getParentInstance (   self)
Get the instance this active network belongs to.
def cpc.dataflow.active_network.ActiveNetwork.getTaskQueue (   self)
Get the task queue associated with this network.
def cpc.dataflow.active_network.ActiveNetwork.rerun (   self,
  recursive,
  clearError,
  outf = None 
)
Clear the error in all sub-instances if recursive is true
   Returns the number of errors cleared
def cpc.dataflow.active_network.ActiveNetwork.tryGetActiveInstance (   self,
  name 
)
Get the named active instance and return None if not found.
def cpc.dataflow.active_network.ActiveNetwork.writeXML (   self,
  outFile,
  indent = 0 
)
Write an XML description of the active network.

Member Data Documentation

cpc.dataflow.active_network.ActiveNetwork.activeInstances
cpc.dataflow.active_network.ActiveNetwork.baseDir
cpc.dataflow.active_network.ActiveNetwork.inActiveInstance
cpc.dataflow.active_network.ActiveNetwork.lock
cpc.dataflow.active_network.ActiveNetwork.networkLock
cpc.dataflow.active_network.ActiveNetwork.project
cpc.dataflow.active_network.ActiveNetwork.taskQueue

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