singa::Poller Class Reference

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

Member Function Documentation

virtual bool singa::Poller::Terminated ( )

virtual

Returns

true if the poller is terminated due to process interupt

SocketInterface* singa::Poller::Wait

(

int

duration

)

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,

---

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

• /home/wangwei/program/asf/release-0.1/apache-singa-incubating-0.1.0-RC1/include/communication/socket.h