summaryrefslogtreecommitdiff
path: root/java/src/Ice/src/main/java/IceSSL/TransceiverI.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/src/Ice/src/main/java/IceSSL/TransceiverI.java')
-rw-r--r--java/src/Ice/src/main/java/IceSSL/TransceiverI.java11
1 files changed, 10 insertions, 1 deletions
diff --git a/java/src/Ice/src/main/java/IceSSL/TransceiverI.java b/java/src/Ice/src/main/java/IceSSL/TransceiverI.java
index f388e58ac60..128f890e690 100644
--- a/java/src/Ice/src/main/java/IceSSL/TransceiverI.java
+++ b/java/src/Ice/src/main/java/IceSSL/TransceiverI.java
@@ -257,6 +257,12 @@ final class TransceiverI implements IceInternal.Transceiver
}
@Override
+ public void setBufferSize(int rcvSize, int sndSize)
+ {
+ _stream.setBufferSize(rcvSize, sndSize);
+ }
+
+ @Override
public void checkSendSize(IceInternal.Buffer buf)
{
}
@@ -306,6 +312,9 @@ final class TransceiverI implements IceInternal.Transceiver
info.remotePort = socket.getPort();
}
+ info.rcvSize = IceInternal.Network.getRecvBufferSize(_stream.fd());
+ info.sndSize = IceInternal.Network.getSendBufferSize(_stream.fd());
+
SSLSession session = _engine.getSession();
info.cipher = session.getCipherSuite();
try
@@ -516,7 +525,7 @@ final class TransceiverI implements IceInternal.Transceiver
{
throw new Ice.ConnectionLostException(ex);
}
-
+
if(_netOutput.hasRemaining())
{
_netOutput.compact();