ipc — Inter Process Communication.

Inter Process Communication.

this module provides classes to ease the inter process communication (IPC) between the Feedback Controller and the Feedbacks

class lib.ipc.FeedbackControllerIPCChannel(conn, fc)

IPC Channel for Feedback Contoller’s end.

handle_message(message)

Handle message from Feedback.

class lib.ipc.FeedbackIPCChannel(conn, feedback)

IPC Channel for Feedback’s end.

handle_message(message)

Handle message from Feedback Controller.

class lib.ipc.IPCChannel(conn)

IPC Channel.

Base for the channels, the Feedback Controller and the Feedbacks need.

This Class transparently takes care of de-/serialization of the data which goes through the IPC. Derived classes should implement

handle_message(self, message)

to do something useful and use

send_message(self, message)

for sending messages via IPC.

collect_incoming_data(data)

Append incoming data to input buffer.

found_terminator()

Process message from peer.

handle_close()

Handle closing of connection.

handle_message(message)

Do something with the received message.

This method should be overwritten by derived classes.

send_message(message)

Send message to peer.

class lib.ipc.IPCConnectionHandler(fc)

Waits for incoming connection requests and dispatches a FeedbackControllerIPCChannel.

close_channel()

Close the channel to the Feedback.

handle_accept()

Handle incoming connection from Feedback.

handle_close()

Handle closing of connection.

handle_error()

Handle error.

send_message(message)

Send the message via the currently open connection.

lib.ipc.get_feedbackcontroller_connection()

Return a connection to the Feedback Controller.

lib.ipc.ipcloop()

Start the IPC loop.

Module author: Bastian Venthur <venthur@cs.tu-berlin.de>