diff options
author | Mark Spruiell <mes@zeroc.com> | 2014-06-13 10:06:29 -0700 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2014-06-13 10:06:29 -0700 |
commit | 69c46db2fb9f03a4b730f8da1bd6e03d4ba68895 (patch) | |
tree | a755e1e123ac50a31729e51ebb375a92e86f1303 /java/src/IceInternal/UdpTransceiver.java | |
parent | SSL Cipher test fix for OpenSSL (diff) | |
download | ice-69c46db2fb9f03a4b730f8da1bd6e03d4ba68895.tar.bz2 ice-69c46db2fb9f03a4b730f8da1bd6e03d4ba68895.tar.xz ice-69c46db2fb9f03a4b730f8da1bd6e03d4ba68895.zip |
initial commit of C# transport changes
Diffstat (limited to 'java/src/IceInternal/UdpTransceiver.java')
-rw-r--r-- | java/src/IceInternal/UdpTransceiver.java | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/java/src/IceInternal/UdpTransceiver.java b/java/src/IceInternal/UdpTransceiver.java index 15f1683cf4e..d8344adb130 100644 --- a/java/src/IceInternal/UdpTransceiver.java +++ b/java/src/IceInternal/UdpTransceiver.java @@ -66,6 +66,11 @@ final class UdpTransceiver implements Transceiver return SocketOperation.Write; } + if(!buf.b.hasRemaining()) + { + return SocketOperation.None; + } + assert(buf.b.position() == 0); assert(_fd != null && _state >= StateConnected); @@ -127,6 +132,11 @@ final class UdpTransceiver implements Transceiver @SuppressWarnings("deprecation") public int read(Buffer buf, Ice.BooleanHolder moreData) { + if(!buf.b.hasRemaining()) + { + return SocketOperation.None; + } + assert(buf.b.position() == 0); final int packetSize = java.lang.Math.min(_maxPacketSize, _rcvSize - _udpOverhead); |