1 files changed, 143 insertions, 0 deletions
diff --git a/cpp/test/Ice/background/Transceiver.cpp b/cpp/test/Ice/background/Transceiver.cpp
new file mode 100644
index 00000000000..ddee56e5d23
--- /dev/null
+++ b/cpp/test/Ice/background/Transceiver.cpp
@@ -0,0 +1,143 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2007 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.
+//
+// **********************************************************************
+
+#include <Transceiver.h>
+
+using namespace std;
+
+SOCKET
+Transceiver::fd()
+{
+    return _transceiver->fd();
+}
+
+IceInternal::SocketStatus
+Transceiver::initialize(int timeout)
+{
+    if(timeout == 0)
+    {
+        IceInternal::SocketStatus status = _configuration->initializeSocketStatus();
+        if(status == IceInternal::NeedConnect)
+        {
+            return status;
+        }
+        else if(status == IceInternal::NeedWrite)
+        {
+            if(!_initialized)
+            {
+                status = _transceiver->initialize(timeout);
+                if(status != IceInternal::Finished)
+                {
+                    return status;
+                }
+                _initialized = true;
+            }
+            return IceInternal::NeedWrite;
+        }
+        else if(status == IceInternal::NeedRead)
+        {
+            return status;
+        }
+    }
+    _configuration->checkInitializeException();
+    if(!_initialized)
+    {
+        IceInternal::SocketStatus status = _transceiver->initialize(timeout);
+        if(status != IceInternal::Finished)
+        {
+            return status;
+        }
+        _initialized = true;
+    }
+    return IceInternal::Finished;
+}
+
+void
+Transceiver::close()
+{
+    _transceiver->close();
+}
+
+void
+Transceiver::shutdownWrite()
+{
+    _transceiver->shutdownWrite();
+}
+
+void
+Transceiver::shutdownReadWrite()
+{
+    _transceiver->shutdownReadWrite();
+}
+
+bool
+Transceiver::write(IceInternal::Buffer& buf, int timeout)
+{
+    if(!_initialized)
+    {
+        throw Ice::SocketException(__FILE__, __LINE__);
+    }
+
+    if(timeout == 0)
+    {
+        if(!_configuration->writeReady())
+        {
+            return false;
+        }
+    }
+    _configuration->checkWriteException();
+    return _transceiver->write(buf, timeout);
+}
+
+bool
+Transceiver::read(IceInternal::Buffer& buf, int timeout)
+{
+    if(!_initialized)
+    {
+        throw Ice::SocketException(__FILE__, __LINE__);
+    }
+
+    if(timeout == 0)
+    {
+        if(!_configuration->readReady())
+        {
+            return false;
+        }
+    }
+    _configuration->checkReadException();
+    return _transceiver->read(buf, timeout);
+}
+
+string
+Transceiver::type() const
+{
+    return "test-" + _transceiver->type();
+}
+
+string
+Transceiver::toString() const
+{
+    return _transceiver->toString();
+}
+
+void
+Transceiver::checkSendSize(const IceInternal::Buffer& buf, size_t messageSizeMax)
+{
+    _transceiver->checkSendSize(buf, messageSizeMax);
+}
+
+//
+// Only for use by Connector, Acceptor
+//
+Transceiver::Transceiver(const IceInternal::TransceiverPtr& transceiver) :
+    _transceiver(transceiver),
+    _configuration(Configuration::getInstance()),
+    _initialized(false)
+{
+}