line::ag::AgWorkerPool Class Reference

The connections to every configured worker, plus the agent partition. More...

#include <line/solvers/ag/ag_worker_client.h>

Public Member Functions
	AgWorkerPool (const std::vector< std::string > &endpoints, double timeout_seconds)
	~AgWorkerPool ()
	AgWorkerPool (const AgWorkerPool &)=delete
AgWorkerPool &	operator= (const AgWorkerPool &)=delete
template<class Payload>
void	ensure_assigned (std::size_t num_agents, Payload payload)
	Connect and ship the static half of each owned agent, once.
void	sweep (const std::vector< double > &x, std::vector< std::vector< double > > &pi, std::vector< bool > &pending)
	One sweep.

Detailed Description

The connections to every configured worker, plus the agent partition.

Definition at line 80 of file ag_worker_client.h.

Constructor & Destructor Documentation

AgWorkerPool() [1/2]

line::ag::AgWorkerPool::AgWorkerPool ( const std::vector< std::string > & endpoints, double timeout_seconds )

inline

Definition at line 82 of file ag_worker_client.h.

Referenced by AgWorkerPool(), operator=(), and line::ag::solver_ag().

~AgWorkerPool()

line::ag::AgWorkerPool::~AgWorkerPool ( )

inline

Definition at line 94 of file ag_worker_client.h.

AgWorkerPool() [2/2]

line::ag::AgWorkerPool::AgWorkerPool ( const AgWorkerPool & )

delete

References AgWorkerPool().

Member Function Documentation

ensure_assigned()

template<class Payload>

void line::ag::AgWorkerPool::ensure_assigned ( std::size_t num_agents, Payload payload )

inline

Connect and ship the static half of each owned agent, once.

payload maps an agent index to its wire description.

Definition at line 104 of file ag_worker_client.h.

Referenced by line::ag::ag_sweep_cluster().

operator=()

AgWorkerPool & line::ag::AgWorkerPool::operator= ( const AgWorkerPool & )

delete

References AgWorkerPool().

sweep()

void line::ag::AgWorkerPool::sweep ( const std::vector< double > & x, std::vector< std::vector< double > > & pi, std::vector< bool > & pending )

inline

One sweep.

Fills pi for every agent a live worker answered for and clears its pending flag; the rest are left to the caller.

Definition at line 137 of file ag_worker_client.h.

Referenced by line::ag::ag_sweep_cluster().

---

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

• include/line/solvers/ag/ag_worker_client.h