1 files changed, 126 insertions, 0 deletions
diff --git a/java-compat/src/Ice/src/main/java/IceInternal/TcpTransceiver.java b/java-compat/src/Ice/src/main/java/IceInternal/TcpTransceiver.java
new file mode 100644
index 00000000000..069e79a3408
--- /dev/null
+++ b/java-compat/src/Ice/src/main/java/IceInternal/TcpTransceiver.java
@@ -0,0 +1,126 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2016 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+package IceInternal;
+
+final class TcpTransceiver implements Transceiver
+{
+    @Override
+    public java.nio.channels.SelectableChannel fd()
+    {
+        assert(_stream != null);
+        return _stream.fd();
+    }
+
+    @Override
+    public void setReadyCallback(ReadyCallback callback)
+    {
+        // No need of the callback
+    }
+
+    @Override
+    public int initialize(Buffer readBuffer, Buffer writeBuffer)
+    {
+        return _stream.connect(readBuffer, writeBuffer);
+    }
+
+    @Override
+    public int closing(boolean initiator, Ice.LocalException ex)
+    {
+        // If we are initiating the connection closure, wait for the peer
+        // to close the TCP/IP connection. Otherwise, close immediately.
+        return initiator ? SocketOperation.Read : SocketOperation.None;
+    }
+
+    @Override
+    public void close()
+    {
+        _stream.close();
+    }
+
+    @Override
+    public EndpointI bind()
+    {
+        assert(false);
+        return null;
+    }
+
+    @Override
+    public int write(Buffer buf)
+    {
+        return _stream.write(buf);
+    }
+
+    @Override
+    public int read(Buffer buf)
+    {
+        return _stream.read(buf);
+    }
+
+    @Override
+    public String protocol()
+    {
+        return _instance.protocol();
+    }
+
+    @Override
+    public String toString()
+    {
+        return _stream.toString();
+    }
+
+    @Override
+    public String toDetailedString()
+    {
+        return toString();
+    }
+
+    @Override
+    public Ice.ConnectionInfo getInfo()
+    {
+        Ice.TCPConnectionInfo info = new Ice.TCPConnectionInfo();
+        if(_stream.fd() != null)
+        {
+            java.net.Socket socket = _stream.fd().socket();
+            info.localAddress = socket.getLocalAddress().getHostAddress();
+            info.localPort = socket.getLocalPort();
+            if(socket.getInetAddress() != null)
+            {
+                info.remoteAddress = socket.getInetAddress().getHostAddress();
+                info.remotePort = socket.getPort();
+            }
+            if(!socket.isClosed())
+            {
+                info.rcvSize = Network.getRecvBufferSize(_stream.fd());
+                info.sndSize = Network.getSendBufferSize(_stream.fd());
+            }
+        }
+        return info;
+    }
+
+    @Override
+    public void checkSendSize(Buffer buf)
+    {
+    }
+
+    @Override
+    public void setBufferSize(int rcvSize, int sndSize)
+    {
+        _stream.setBufferSize(rcvSize, sndSize);
+    }
+
+    TcpTransceiver(ProtocolInstance instance, StreamSocket stream)
+    {
+        _instance = instance;
+        _stream = stream;
+    }
+
+    final private ProtocolInstance _instance;
+    final private StreamSocket _stream;
+}