#include <Cpg.h>
Public Member Functions | |
Cpg (Handler &) | |
Open a CPG handle. | |
~Cpg () | |
Destructor calls shutdown. | |
void | shutdown () |
Disconnect from CPG. | |
void | dispatch (cpg_dispatch_t type) |
Dispatch CPG events. | |
void | dispatchOne () |
Dispatch one event in current thread. | |
void | dispatchAll () |
Dispatch all available events, don't block. | |
void | dispatchBlocking () |
Blocking loop to dispatch cluster events. | |
void | join (const Name &group) |
void | leave (const Name &group) |
void | mcast (const Name &group, const iovec *iov, int iovLen) |
cpg_handle_t | getHandle () const |
Static Public Member Functions | |
static std::string | str (const cpg_name &n) |
Manages a single CPG handle, initialized in ctor, finialzed in destructor. On error all functions throw Cpg::Exception
qpid::cluster::Cpg::Cpg | ( | Handler & | ) |
Open a CPG handle.
handler | for CPG events. |
qpid::cluster::Cpg::~Cpg | ( | ) |
Destructor calls shutdown.
void qpid::cluster::Cpg::dispatch | ( | cpg_dispatch_t | type | ) | [inline] |
Dispatch CPG events.
type | one of
|
Referenced by dispatchAll(), dispatchBlocking(), and dispatchOne().
void qpid::cluster::Cpg::dispatchOne | ( | ) | [inline, virtual] |
Dispatch one event in current thread.
Implements qpid::cluster::Dispatchable.
References dispatch().
void qpid::cluster::Cpg::dispatchAll | ( | ) | [inline, virtual] |
Dispatch all available events, don't block.
Implements qpid::cluster::Dispatchable.
References dispatch().