comms Directory Reference

Implementation of stateline comms system.

More...

Directory dependency graph for comms:

Files
file	blob.cpp
file	clientheartbeat.cpp
	Implementation of heartbeat routers that deal with client heartbeating sending and receiving.
file	clientheartbeat.hpp
	Heartbeat routers that deal with client heartbeating sending and receiving.
file	datatypes.hpp
file	delegator.cpp
file	delegator.hpp
	The delegator is the intermediary between requesters and workers. It acts as the server to which workers connect, and requesters submit jobs.
file	messages.cpp
file	messages.hpp
	Contains the functions to seralise and unserialise GDF datatypes.
file	minion.cpp
file	minion.hpp
	Object which actually performs the work requested then distributed by the worker. There can be many minions in the same machine, but only one per thread sending to a shared worker object.
file	requester.cpp
file	requester.hpp
	Object which actually requests work and returns a result. Many of these can live in the same executable, but only 1 per thread. They forward requests to a shared (threadsafe) delegator object using zeromq inproc messaging.
file	router.cpp
file	router.hpp
	A router that implements polling on multiple zeromq sockets, and a signal-based callback system depending on the socket and the subject of the message. Implementing GDFP-SW (GDF Server-apper Protocol)
file	serverheartbeat.cpp
	Implementation of heartbeat routers that deal with server heartbeating sending and receiving.
file	serverheartbeat.hpp
	Heartbeat routers that deal with server heartbeating sending and receiving.
file	settings.hpp
	Settings constructs for program configuration.
file	transport.cpp
	Contains the functions to communicate GDF datatypes across zmq in accordance with the GDFP-SW (GDF Server-Worker protocol)
file	transport.hpp
	Contains the functions to communicate GDF datatypes across zmq in accordance with the GDFP-SW (GDF Server-Worker protocol)
file	worker.cpp
	Contains the implementation of the worker.
file	worker.hpp
	The worker object connects with a delegator, then forwards job requests to a set of minions that actually perform the work. These minions then return the worker results, which are forwarded back to the delegator.

Detailed Description

Implementation of stateline comms system.

Author

Lachlan McCalman

Date

2014

License:

General Public License version 3 or later

Copyright

(c) 2014, NICTA