The delegator is the intermediary between requesters and workers. It acts as the server to which workers connect, and requesters submit jobs. More...
#include <set>
#include <string>
#include <deque>
#include <glog/logging.h>
#include <zmq.hpp>
#include "comms/settings.hpp"
#include "comms/messages.hpp"
#include "comms/transport.hpp"
#include "comms/router.hpp"
#include "comms/serverheartbeat.hpp"
Classes | |
class | stateline::comms::Delegator |
Requester object that takes jobs and returns results. Communicates with a delegator living in a (possibly) different thread. More... | |
Namespaces | |
stateline | |
stateline::comms | |
Variables | |
const std::string | DELEGATOR_SOCKET_ADDR = "inproc://delegator" |
Address that the requesters connect their sockets to. | |
The delegator is the intermediary between requesters and workers. It acts as the server to which workers connect, and requesters submit jobs.