worker.hpp File Reference

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. More...

#include <string>
#include <glog/logging.h>
#include <zmq.hpp>
#include "comms/settings.hpp"
#include "comms/messages.hpp"
#include "comms/datatypes.hpp"
#include "comms/transport.hpp"
#include "comms/router.hpp"
#include "comms/clientheartbeat.hpp"

Include dependency graph for worker.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	stateline::comms::Worker
	Worker object that takes jobs, forwards them to a minion then receives results from the minion and send them back to the delegator. More...

Namespaces
	stateline
	stateline::comms

Functions
void	stateline::comms::forwardToNetwork (const Message &m, SocketRouter &router)
	Forward a message to the delegator. More...
void	stateline::comms::forwardToMinion (const Message &m, SocketRouter &router)
	Forward a message to a minion. More...
void	stateline::comms::disconnectFromServer (const Message &m)
	Disconnect from the server with a message. More...

Variables
const std::string	WORKER_SOCKET_ADDR = "inproc://worker"
	Address that the minions connect their sockets to.

Detailed Description

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.

Author

Lachlan McCalman

Date

2014

License:

Affero General Public License version 3 or later

Copyright

(c) 2014, NICTA