1 #include "PollerZmq.hh"
18 SPD_TRACE(
"### Destroy PollerZmq ###");
31 SPD_TRACE(
"Adding socket (zsock_t*) {} to poller {}",
static_cast<void *
>(pSocket),
static_cast<void *
>(
this));
42 SPD_TRACE(
"Adding socket (zactor_t*) {} to poller {}",
static_cast<void *
>(pSocket),
static_cast<void *
>(
this));
53 SPD_TRACE(
"Adding socket (Salsa::Socket*){} to poller {}",
static_cast<void *
>(pSocket),
static_cast<void *
>(
this));
69 void * pSocket = zpoller_wait(
mpPoller, timeout);
70 SPD_TRACE(
"wait(timeout [{}]) => socket [{}]", timeout,
static_cast<void *
>(pSocket));
virtual void add(SocketZyre *pSocket)
zpoller_t * mpPoller
ZeroMQ poller.
virtual void * wait(int timeout=-1)
Waiting for socket.
virtual zsock_t * socket() const
Returns zyre socket pointer.