AddChannel(self, channelId, authCallback=None)

This adds a new channel to the Event Service.

GetLocation(self)

GetLocation returns the (host,port) for this service.

HandleEOF(self, connObj)

Handle an EOF on a connection.

If this connection doesn't yet have a channel assignment, we can just delete it from our list of all channels.

If it does have a channel assignment, remove from there then delete from all-channels.

HandleEvent(self, event, connObj)

Handle an incoming event.

This is executed in the message handling thread after an event has been received by the async reader.

Exactly what happens with this event depends on whether the connection object has been connected to a channel or not.

If it has not, the only events that will be processed are Connect and Disconnect.

If it has, the event is passed along to the EventChannel for processing.

HandleEventForDisconnectedChannel(self, event, connObj)

We've received an event for a connection which hasn't yet been connected to a channel.

Pass the event to the channel to allow it to decide whether to allow the connection or not. If it allows it, add the connection to the channel. If not, close the channel.

RecvHandler(self)

Thread main routine for event queue handling.

RegisterChannelCallback(self, channelId, callback)

Register a callback for all events on this channel.

RegisterObject(self, channel, object)

RegisterObject is short hand for registering multiple callbacks on the same object. The object being registered has to define a table named callbacks that has event types as keys, and self.methods as values. Then these are automatically registered.

RemoveChannel(self, channelId)

This removes a channel from the Event Service.

start(self)

Start. Initialize the asynch io on accept.

Stop(self)

Stop the event service.

Close our listener socket and all the active connections; this should clear out any lingering state.