summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/UdpTransceiver.java
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2014-06-13 10:06:29 -0700
committerMark Spruiell <mes@zeroc.com>2014-06-13 10:06:29 -0700
commit69c46db2fb9f03a4b730f8da1bd6e03d4ba68895 (patch)
treea755e1e123ac50a31729e51ebb375a92e86f1303 /java/src/IceInternal/UdpTransceiver.java
parentSSL Cipher test fix for OpenSSL (diff)
downloadice-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.java10
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);