Examples of com.barchart.udt.SocketUDT.send()

com.barchart.udt.SocketUDT.send()
send from byte[] array upto size=array.length bytes @param array array to send @return -1 : no buffer space (non-blocking only)
=0 : timeout expired (blocking only)
>0 : normal send, actual sent byte count
@see #send0(int,int,int,boolean,byte[])

      try {
        if (isBlocking) {
          begin(); // JDK contract for NIO blocking calls
        }
        if (buffer.isDirect()) {
          sizeSent = socket.send(buffer);
        } else {
          assert buffer.hasArray();
          byte[] array = buffer.array();
          int position = buffer.position();
          int limit = buffer.limit();

View Full Code Here

        } else {
          assert buffer.hasArray();
          byte[] array = buffer.array();
          int position = buffer.position();
          int limit = buffer.limit();
          sizeSent = socket.send(array, position, limit);
          if (0 < sizeSent && sizeSent <= remaining) {
            buffer.position(position + sizeSent);
          }
        }
      } finally {

View Full Code Here

      try {
        if (isBlocking) {
          begin(); // JDK contract for NIO blocking calls
        }
        if (buffer.isDirect()) {
          sizeSent = socket.send(buffer);
        } else {
          assert buffer.hasArray();
          byte[] array = buffer.array();
          int position = buffer.position();
          int limit = buffer.limit();

View Full Code Here

        } else {
          assert buffer.hasArray();
          byte[] array = buffer.array();
          int position = buffer.position();
          int limit = buffer.limit();
          sizeSent = socket.send(array, position, limit);
          if (0 < sizeSent && sizeSent <= remaining) {
            buffer.position(position + sizeSent);
          }
        }
      } finally {

View Full Code Here

      try {
        if (isBlocking) {
          begin(); // JDK contract for NIO blocking calls
        }
        if (buffer.isDirect()) {
          sizeSent = socket.send(buffer);
        } else {
          assert buffer.hasArray();
          byte[] array = buffer.array();
          int position = buffer.position();
          int limit = buffer.limit();

View Full Code Here

        } else {
          assert buffer.hasArray();
          byte[] array = buffer.array();
          int position = buffer.position();
          int limit = buffer.limit();
          sizeSent = socket.send(array, position, limit);
          if (0 < sizeSent && sizeSent <= remaining) {
            buffer.position(position + sizeSent);
          }
        }
      } finally {

View Full Code Here

      }


      if (buffer.isDirect()) {


        do {
          ret = socket.send(buffer);


          if (ret > 0)
            sizeSent += ret;


        } while (buffer.hasRemaining() && isBlocking);

View Full Code Here

        final byte[] array = buffer.array();
        int position = buffer.position();
        final int limit = buffer.limit();


        do {
          ret = socket.send(array, position, limit);


          if (0 < ret && ret <= remaining) {
            sizeSent += ret;
            position += ret;
            buffer.position(position);

View Full Code Here


          final byte[] array = new byte[SIZE];


          putSequenceNumber(array);


          final int result = sender.send(array);


          assert result == SIZE : "wrong size";


        }

View Full Code Here

          begin(); // JDK contract for NIO blocking calls
        }


        if (buffer.isDirect()) {


          sizeSent = socket.send(buffer);


        } else {


          final byte[] array = buffer.array();
          final int position = buffer.position();

View Full Code Here

0 1

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.