salsa  0.3.0
 All Classes Functions Variables Enumerations Pages
Salsa::PollerZmq Class Reference

salsa node class More...

#include <PollerZmq.hh>

Inheritance diagram for Salsa::PollerZmq:
Salsa::Poller Salsa::Object

Public Member Functions

 PollerZmq ()
 
virtual ~PollerZmq ()
 
virtual void add (SocketZyre *pSocket)
 
virtual void add (zsock_t *pSocket)
 
virtual void add (zactor_t *pSocket)
 
virtual void * wait (int timeout=-1)
 Waiting for socket. More...
 
zpoller_t * poller () const
 Returns Poller.
 

Static Public Member Functions

static std::shared_ptr
< spdlog::logger > 
getConsoleOutput ()
 Get console output.
 
static void setConsoleLevel (spdlog::level::level_enum level)
 Sets console log level.
 

Private Attributes

zpoller_t * mpPoller
 ZeroMQ poller.
 

Detailed Description

Constructor & Destructor Documentation

Salsa::PollerZmq::PollerZmq ( )

Constructor

Definition at line 5 of file PollerZmq.cc.

Salsa::PollerZmq::~PollerZmq ( )
virtual

Destructor

Definition at line 12 of file PollerZmq.cc.

References mpPoller.

Member Function Documentation

void Salsa::PollerZmq::add ( SocketZyre pSocket)
virtual

Add Salsa socket to poller

Parameters
pSocketSalsa socket

Definition at line 45 of file PollerZmq.cc.

References mpPoller, and Salsa::SocketZyre::socket().

Referenced by Salsa::NodeManagerZyre::addTaskSlot(), Salsa::NodeZyre::init(), and Salsa::ActorZmq::pipe().

void Salsa::PollerZmq::add ( zsock_t *  pSocket)
virtual

Add Salsa socket to poller

Parameters
pSocketZeromq socket

Definition at line 23 of file PollerZmq.cc.

References mpPoller.

void Salsa::PollerZmq::add ( zactor_t *  pSocket)
virtual

Add Salsa socket to poller

Parameters
pSocketZeromq socket

Definition at line 34 of file PollerZmq.cc.

References mpPoller.

void * Salsa::PollerZmq::wait ( int  timeout = -1)
virtual

Waiting for socket.

Wait for socket

Parameters
timeoutTimeout of poller

Implements Salsa::Poller.

Definition at line 56 of file PollerZmq.cc.

References mpPoller.

Referenced by Salsa::ActorZmq::wait().


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