singa::SocketInterface Class Reference

Inheritance diagram for singa::SocketInterface:

Public Member Functions
virtual int	Send (Msg **msg)=0
	Send a message to connected socket(s), non-blocking. More...
virtual Msg *	Receive ()=0
	Receive a message from any connected socket. More...
virtual void *	InternalID () const =0

Member Function Documentation

virtual void* singa::SocketInterface::InternalID ( ) const

pure virtual

Returns

Identifier of the implementation dependent socket. E.g., zsock_t* for ZeroMQ implementation and rank for MPI implementation.

Implemented in singa::Router, and singa::Dealer.

virtual Msg* singa::SocketInterface::Receive ( )

pure virtual

Receive a message from any connected socket.

Returns

a message pointer if success; nullptr if failure

Implemented in singa::Router, and singa::Dealer.

virtual int singa::SocketInterface::Send ( Msg **  msg )

pure virtual

Send a message to connected socket(s), non-blocking.

The message will be deallocated after sending, thus should not be used after calling Send();

Parameters

msg	The message to be sent

Returns

1 for success queuing the message for sending, 0 for failure

Implemented in singa::Router, and singa::Dealer.

---

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