Package ioids :: Module dataengine :: Class DataEngine
[hide private]
[frames] | no frames]

Class DataEngine

source code

Instance Methods [hide private]
 
__init__(self)
Sets up the queues for incoming messages.
source code
 
startup(self)
Start up the data engine in its background thread.
source code
 
runUntilShutdown(self)
In here, all the queues are checked frequently and appropriate actions are undertaken.
source code
 
shutdown(self)
Shutdown the data engine thread.
source code
 
_executeOneReaction(self, event, reaction)
Performs all operations as defined by the reaction part of an ioids rule.
source code
 
_processEventFromLocal(self, event)
Processes one item from the local event list.
source code
 
_processIoidsEventFromLocal(self, event) source code
 
newEventFromLocal(self, event)
Processes the occurence of a new event in the local database.
source code
 
newIoidsEventFromLocal(self, ioidsevent)
Processes the occurence of a new ioids event in the local database.
source code
 
newIoidsEventFromRemote(self, ioidsevent, relations=[]) source code
Method Details [hide private]

newEventFromLocal(self, event)

source code 

Processes the occurence of a new event in the local database.

Should be called from the ioids event trigger.

newIoidsEventFromLocal(self, ioidsevent)

source code 

Processes the occurence of a new ioids event in the local database.

Should be called from the ioids event trigger.