7 #include <PollerZmq.hh> 29 virtual void *
wait();
31 zpoller_t *
poller()
const;
PollerZmq * mpPoller
Internal poller.
virtual int init()
First function.
virtual void pipe(void *pipe)
Setter for pipe.
zpoller_t * poller() const
virtual int finish()
Last function.
bool mTerminated
Flag if actor should be terminated.
static void actorProcwaitSupport_(zsock_t *pipe, void *argv)
Support actor method (used for PID waiting)
ZeroMQ implementation of salsa actor class
zsock_t * mpPipe
Zmq pipe socket.
static void SalsaActorFn(zsock_t *pPipe, void *pArgv)
virtual int exec()
Main function.
static void SalsaActorForkFn(zsock_t *pPipe, void *pArgv)
Actor function with fork capability.
int mTimeout
Poller timeout.
PollerZmq * pollerZmq() const