List of recv() Examples

Examples of recv()

backtype.storm.messaging.IConnection.recv()
receive a batch message iterator (consists taskId and payload) @param flags 0: block, 1: non-block @return
io.s4.util.ByteArrayIOChannel.recv()
no.uib.cipr.matrix.distributed.Communicator.recv()
Receives data[offset:offset+length] from peer
org.apache.qpid.proton.engine.Receiver.recv()
Receive message data for the current delivery. @param bytes the destination array where the message data is written @param offset index in the array to start writing data at @param size the maximum number of bytes to write @return number of bytes written. -1 if there are no more bytes for the current delivery.
org.apache.qpid.proton.messenger.Messenger.recv()
Receives an arbitrary number of messages into the incoming queue of the Messenger. This method will block until at least one message is available or the operation times out.
org.apache.qpid.proton.messenger.impl.MessengerImpl.recv()
org.apache.s4.client.Driver.recv()
Receive a message from the adapter. This function blocks till a message becomes available to read. The set of messages sent to this client from S4 depends on the read mode of the client. @see ReadMode @return message received from S4 cluster. @throws IOException if the underlying TCP/IP socket throws an exception.
org.apache.s4.client.util.ByteArrayIOChannel.recv()
org.apache.s4.util.ByteArrayIOChannel.recv()
org.zeromq.ZMQ.Socket.recv()
tachyon.worker.nio.DataServerMessage.recv()
Use this message to receive from the specified socket channel. Make sure this is a recv message and the message type is matched. @param socketChannel The socket channel to receive from @return The number of bytes read, possibly zero, or -1 if the channel has reached end-of-stream @throws IOException
zmq.SocketBase.recv()

Examples of tachyon.worker.nio.DataServerMessage.recv()

        sendMsg.send(socketChannel);
      }
      DataServerMessage recvMsg =
          DataServerMessage.createBlockResponseMessage(false, block.blockId, offset, length);
      while (!recvMsg.isMessageReady()) {
        int numRead = recvMsg.recv(socketChannel);
        if (numRead == -1) {
          break;
        }
      }
      return recvMsg;

View Full Code Here

Examples of zmq.SocketBase.recv()

                }
            }
            //  Process a reply.
            if (success && items[1].isReadable()) {
                while (true) {
                    msg = backend_.recv(0);
                    if (msg == null) {
                        System.out.println("recv failed");


                        success = false;
                        break;

View Full Code Here

Examples of zmq.SocketBase.recv()

                }
            }
            //  Process a reply.
            if (success && items[1].isReadable()) {
                while (true) {
                    msg = backend_.recv(0);
                    if (msg == null) {
                        success = false;
                        break;
                    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.