server_states

TcpCommunicationException

class blitz.communications.tcp.TcpCommunicationException

TcpBase

class blitz.communications.tcp.TcpBase(host='localhost', port=None)

TcpStateAction

class blitz.communications.tcp.TcpStateAction(command_type, command)

Manages a TCP action which is queued with the state machine.

The TcpSTateMachine provides convenience methods for creating and queueing instances

is_send()

Returns true if this is a send command

TcpStateMachine

class blitz.communications.tcp.TcpStateMachine(tcp, stop_event, initial_state)

Manages TCP state and ensures the messages are processed in a thread safe manner, one at a time

queue_receive(command)

Queues a receive message

queue_send(command)

Queues a send message