singa::Poller Class Reference

Inheritance diagram for singa::Poller:

Public Member Functions
virtual void	Add (Socket *socket)
	Add a socket for polling; Multiple sockets can be polled together by adding them into the same poller.
virtual Socket *	Wait (int duration)
	Poll for all sockets added into this poller. More...

Protected Attributes
zpoller_t *	poller_
std::map< zsock_t *, Socket * >	zsock2Socket_

Member Function Documentation

virtual Socket* singa::Poller::Wait ( int  timeout )

virtual

Poll for all sockets added into this poller.

Parameters

timeout

stop after this number of mseconds

Returns

pointer to the socket if it has one message in the receiving queue; nullptr if no message in any sockets,

Implements singa::BasePoller.

---

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

• /home/wangwei/program/asf/incubator-singa/include/communication/socket.h