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

#include <worker.hpp>

Public Member Functions
	Worker (const std::vector< uint > &jobIDs, const WorkerSettings &settings)
	Build a new worker. More...

	~Worker ()
	Destructor. Safely stops all polling threads and cleans up.

void	stop ()
	Stop the worker polling sockets.

zmq::context_t &	zmqContext ()
	Return a ref to the context object owned by the worker. This allows a minion to use inproc sockets and connect. More...

const std::string &	globalSpec ()
	Return a reference to the problemspec so that the minions can instantiate their sockets. More...

const std::string &	jobSpec (uint jobID)
	Return the individual job specifications for the minions. More...

const std::set< uint >	jobsEnabled () const
	Return a set of job IDs that are enabled. More...

const std::string &	jobResults (uint jobID)
	Return the result of a particular job. More...

Detailed Description

Worker object that takes jobs, forwards them to a minion then receives results from the minion and send them back to the delegator.

Constructor & Destructor Documentation

stateline::comms::Worker::Worker	(	const std::vector< uint > &	jobIDs,
		const WorkerSettings &	settings
	)

Build a new worker.

Parameters

jobIDs	A list of job IDs that the worker can do.
settings	The configuration object.

const std::string& stateline::comms::Worker::globalSpec ( )

inline

Return a reference to the problemspec so that the minions can instantiate their sockets.

const std::string& stateline::comms::Worker::jobResults ( uint jobID )

inline

Return the result of a particular job.

Parameters

jobID The ID of the job.

const std::set<uint> stateline::comms::Worker::jobsEnabled ( ) const

inline

Return a set of job IDs that are enabled.

const std::string& stateline::comms::Worker::jobSpec ( uint jobID )

inline

Return the individual job specifications for the minions.

zmq::context_t& stateline::comms::Worker::zmqContext ( )

inline

Return a ref to the context object owned by the worker. This allows a minion to use inproc sockets and connect.

The documentation for this class was generated from the following files: