diff options
Diffstat (limited to 'java/src/Ice/src/main/java/IceSSL/TransceiverI.java')
-rw-r--r-- | java/src/Ice/src/main/java/IceSSL/TransceiverI.java | 11 |
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(); |