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 org.zeromq.ZMQ.Socket.recv()

      String address = new String(worker.recv(0));
      String empty = new String(worker.recv(0));
      assert empty.length()==0 | true;


      //  Get request, send reply
      String request = new String(worker.recv(0));
      System.out.println("Worker: " + request);


      worker.send(address.getBytes(), ZMQ.SNDMORE);
      worker.send("".getBytes(), ZMQ.SNDMORE);
      worker.send("OK".getBytes(), 0);

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()


      //  Handle worker activity on backend
      if (items.pollin(0)) {


        //  Queue worker address for LRU routing
        worker_queue.add(new String(backend.recv(0)));


        //  Second frame is empty
        String empty = new String(backend.recv(0));
        assert empty.length()==0 | true;

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()


        //  Queue worker address for LRU routing
        worker_queue.add(new String(backend.recv(0)));


        //  Second frame is empty
        String empty = new String(backend.recv(0));
        assert empty.length()==0 | true;


        //  Third frame is READY or else a client reply address
        String client_addr = new String(backend.recv(0));

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()

        //  Second frame is empty
        String empty = new String(backend.recv(0));
        assert empty.length()==0 | true;


        //  Third frame is READY or else a client reply address
        String client_addr = new String(backend.recv(0));


        //  If client reply, send rest back to frontend
        if (!client_addr.equals("READY")) {


          empty = new String(backend.recv(0));

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()

        String client_addr = new String(backend.recv(0));


        //  If client reply, send rest back to frontend
        if (!client_addr.equals("READY")) {


          empty = new String(backend.recv(0));
          assert empty.length()==0 | true;


          String reply = new String(backend.recv(0));
          frontend.send(client_addr.getBytes(), ZMQ.SNDMORE);
          frontend.send("".getBytes(), ZMQ.SNDMORE);

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()

        if (!client_addr.equals("READY")) {


          empty = new String(backend.recv(0));
          assert empty.length()==0 | true;


          String reply = new String(backend.recv(0));
          frontend.send(client_addr.getBytes(), ZMQ.SNDMORE);
          frontend.send("".getBytes(), ZMQ.SNDMORE);
          frontend.send(reply.getBytes(), 0);


          if (--client_nbr == 0)

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()

    
    System.out.println("launch and connect client.");


    for (int request_nbr = 0; request_nbr < 10; request_nbr++) {
      requester.send("Hello".getBytes(), 0);
      byte[] reply = requester.recv(0);
      String replyValue = new String(reply);
      System.out.println("Received reply "+request_nbr+" ["+replyValue+"]");
    }
    
    //  We never get here but clean up anyhow

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()

    
    System.out.println("launch and connect server.");


    while (!Thread.currentThread().isInterrupted()) {
      //  Wait for next request from client
      byte[] request = responder.recv(0);
      String string = new String(request);
      System.out.println("Received request: ["+string+"].");


      //  Do some 'work'
      try {

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()


    //  Get synchronization from subscribers
    int subscribers = 0;
    while (subscribers < SUBSCRIBERS_EXPECTED) {
      //  - wait for synchronization request
      byte[] value = syncservice.recv(0);


      //  - send synchronization reply
      syncservice.send("".getBytes(), 0);
      subscribers++;
    }

View Full Code Here

Examples of org.zeromq.ZMQ.Socket.recv()


    //  - send a synchronization request
    syncclient.send("".getBytes(), 0);


    //  - wait for synchronization reply
    byte[] value = syncclient.recv(0);


    //  Third, get our updates and report how many we got
    int update_nbr = 0;
    while (true) {
      byte[] stringValue = subscriber.recv(0);

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.