slacm.component module

Created on Sep 19, 2020

@author: esdev

class slacm.component.Component

Bases: object

Base class for all components.

ERR = -1

FINALIZE = 2

OK = 0

SETUP = 1

START = 3

STOP = 4

activate()

Method executed before the message handlers are activated. Runs in the component thread.

deactivate()

Method executed when the component is stopped. Runs in the component thread.

class slacm.component.ComponentThread(parent)

Bases: Thread

Component executor thread.

activate()

Activate all ports.

deactivate()

Deactivate all ports.

executeHandlerFor(socket)

Execute the handler for the port corresponding to the socket. The handler is always allowed to run to completion, the operation is never preempted.

finalize()

Execute the ‘finalize’ phase of component initialization. Finalize all ports, and connect the ‘client’ ports with the discovery service.

get_netInfo()

Return the network interface information.

locateHandler(portName)

Locate the handler belonging to the the name port.

recvControl()

Receive a control message from the parent via the control socket.

run()

Main loop of component thread.

runCommand(msg)

Run a control command sent to the component thread by its parent actor.

scheduler(sockets)

Priority scheduler for the component message processing.

The priority order is determined by the order of component ports. The dictionary of active sockets is scanned, and the they are inserted into a priority queue (according to their priority value). The queue is processed (in order of priority). After each invocation, the inputs are polled (in a no-wait operation) and the priority queue is updated.

sendControl(msg)

Send a message via the control socket (to the parent)

setup()

Execute the ‘setup’ phase of component initialization. Construct all ports, and register the ‘server’ ports with the discovery service.

setupControl()

Set up the inner ‘control’ socket (for receiving commands)

setupDisco()

Setup the component as a client of the discovery service.

setupPoller()

Setup the poller for the component thread, initially for the control socket only.

terminate()

Terminate all ports.

updatePoller()

Update the poller with all the input ports.