Copernicus  2.0
 All Classes Namespaces Files Functions Variables
cpc.dataflow.active_conn.ActiveConnectionPoint Class Reference
Inheritance diagram for cpc.dataflow.active_conn.ActiveConnectionPoint:
cpc.dataflow.active_value.ValueUpdateListener

Public Member Functions

def getValue
 
def getActiveInstance
 
def getSourceActiveInstance
 
def setSource
 
def stageNewInput
 
def update
 
def connectDestination
 
def propagate
 
def notifyDestinations
 
def searchDestinations
 
def getListeners
 
def findConnectedInputAIs
 
def findConnectedOutputAIs
 
def writeXML
 
- Public Member Functions inherited from cpc.dataflow.active_value.ValueUpdateListener
def update
 

Public Attributes

 value
 
 directDests
 
 activeInstance
 
 sourceValue
 
 sourceAcp
 
 directSource
 
 direction
 
 listeners
 

Detailed Description

An object holding a connection point that can is used in 
   ActiveConnection objects. Can serve as input or output
   point, with active instance or further connection points associated
   with it.

Member Function Documentation

def cpc.dataflow.active_conn.ActiveConnectionPoint.connectDestination (   self,
  destAcp,
  conn,
  sourceTag 
)
Add a downstream connection to another activeConnectionPoint. 
   To be called from ActiveNetwork.addConnection().
   
   NOTE: assumes the active instance's output lock is locked
def cpc.dataflow.active_conn.ActiveConnectionPoint.findConnectedInputAIs (   self,
  affectedInputAIs 
)
Find all input AIs associated with this acp and add them to the set
   affectedInputAIs
def cpc.dataflow.active_conn.ActiveConnectionPoint.findConnectedOutputAIs (   self,
  affectedOutputAIs 
)
Find all source acps and their active instances. Update the set
   affecteOutputAIs with these
def cpc.dataflow.active_conn.ActiveConnectionPoint.getActiveInstance (   self)
def cpc.dataflow.active_conn.ActiveConnectionPoint.getListeners (   self)
Return the pre-computed set listeners on the value of this acp.
def cpc.dataflow.active_conn.ActiveConnectionPoint.getSourceActiveInstance (   self)
def cpc.dataflow.active_conn.ActiveConnectionPoint.getValue (   self)
def cpc.dataflow.active_conn.ActiveConnectionPoint.notifyDestinations (   self,
  sourceTag,
  seqNr 
)
Notify the ActiveInstance associated with this acp through 
   handleNewInput(), and notify all listeners through 
   notifyListeners().
def cpc.dataflow.active_conn.ActiveConnectionPoint.propagate (   self,
  sourceTag,
  seqNr 
)
Accept a new value with a source tag and sequence number, 
   and propagate it to any listeners.
def cpc.dataflow.active_conn.ActiveConnectionPoint.searchDestinations (   self)
Get the set of destination active instances for this source acp.
def cpc.dataflow.active_conn.ActiveConnectionPoint.setSource (   self,
  directSource,
  sourceAcp,
  sourceValue 
)
Set the source active instance.
   
   directSource = the directly connectd source acp
   sourceAcp = the originating source (source of the source..)
   sourceValue = the originating source value
def cpc.dataflow.active_conn.ActiveConnectionPoint.stageNewInput (   self,
  source,
  seqNr 
)
Stage new input into the newValue fields of the value
  
   source = the source output item/project
   seqNr = the new sequence number (or None)
def cpc.dataflow.active_conn.ActiveConnectionPoint.update (   self,
  newValue,
  sourceTag,
  seqNr 
)
Update the value associated with this connection point.
def cpc.dataflow.active_conn.ActiveConnectionPoint.writeXML (   self,
  outf,
  indent = 0 
)
Write value to xml

Member Data Documentation

cpc.dataflow.active_conn.ActiveConnectionPoint.activeInstance
cpc.dataflow.active_conn.ActiveConnectionPoint.directDests
cpc.dataflow.active_conn.ActiveConnectionPoint.direction
cpc.dataflow.active_conn.ActiveConnectionPoint.directSource
cpc.dataflow.active_conn.ActiveConnectionPoint.listeners
cpc.dataflow.active_conn.ActiveConnectionPoint.sourceAcp
cpc.dataflow.active_conn.ActiveConnectionPoint.sourceValue
cpc.dataflow.active_conn.ActiveConnectionPoint.value

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