|
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 |
|
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