summaryrefslogtreecommitdiff
path: root/cppe
diff options
context:
space:
mode:
authorDwayne Boone <dwayne@zeroc.com>2006-02-17 17:36:04 +0000
committerDwayne Boone <dwayne@zeroc.com>2006-02-17 17:36:04 +0000
commit995a30f8dec3ccb841bb772c4add9af73d841deb (patch)
tree035aa3e6c204a63cbdb9ef383a3abf7edc4ac220 /cppe
parent- Changes to use blocking sockets instead of non-blocking sockets. (diff)
downloadice-995a30f8dec3ccb841bb772c4add9af73d841deb.tar.bz2
ice-995a30f8dec3ccb841bb772c4add9af73d841deb.tar.xz
ice-995a30f8dec3ccb841bb772c4add9af73d841deb.zip
Got rid of IceDelegate
Diffstat (limited to 'cppe')
-rw-r--r--cppe/include/IceE/Config.h2
-rw-r--r--cppe/include/IceE/Proxy.h40
-rw-r--r--cppe/include/IceE/ProxyF.h15
-rw-r--r--cppe/src/IceE/Proxy.cpp590
-rw-r--r--cppe/src/TcpTransport/Transceiver.cpp2
5 files changed, 248 insertions, 401 deletions
diff --git a/cppe/include/IceE/Config.h b/cppe/include/IceE/Config.h
index 1fac75707d7..a311b0d78cc 100644
--- a/cppe/include/IceE/Config.h
+++ b/cppe/include/IceE/Config.h
@@ -24,7 +24,7 @@
// Comment this out if you want to build without batch mode on the
// client side.
//
-#define ICEE_HAS_BATCH
+//#define ICEE_HAS_BATCH
//
// Comment this out if you want to build without support for blocking
diff --git a/cppe/include/IceE/Proxy.h b/cppe/include/IceE/Proxy.h
index 0a47d1be6cd..0fe604ef7ad 100644
--- a/cppe/include/IceE/Proxy.h
+++ b/cppe/include/IceE/Proxy.h
@@ -153,47 +153,13 @@ public:
void __rethrowException(const ::Ice::LocalException&);
void __checkTwowayOnly(const char*) const;
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> __getDelegate();
-
protected:
- virtual ::IceInternal::Handle< ::IceDelegate::Ice::Object> __createDelegate();
-
const ::Ice::Context& __defaultContext() const;
+ void __checkConnection();
-private:
-
- void setup(const ::IceInternal::ReferencePtr&);
- friend class ::IceInternal::ProxyFactory;
-
+ ::Ice::ConnectionPtr _connection;
::IceInternal::ReferencePtr _reference;
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> _delegate;
-};
-
-} }
-
-namespace IceDelegate { namespace Ice
-{
-
-class ICE_API Object : public ::IceUtil::Shared
-{
-public:
-
- ~Object();
-
- bool ice_isA(const ::std::string&, const ::Ice::Context&);
- void ice_ping(const ::Ice::Context&);
- ::std::vector< ::std::string> ice_ids(const ::Ice::Context&);
- ::std::string ice_id(const ::Ice::Context&);
-
- ::Ice::ConnectionPtr ice_connection();
-
- void __copyFrom(const ::IceInternal::Handle< ::IceDelegate::Ice::Object>&);
-
-protected:
-
- ::IceInternal::ReferencePtr __reference;
- ::Ice::ConnectionPtr __connection;
private:
@@ -203,7 +169,7 @@ private:
::std::string __ice_id(::IceInternal::Outgoing&);
void setup(const ::IceInternal::ReferencePtr&);
- friend class ::IceProxy::Ice::Object;
+ friend class ::IceInternal::ProxyFactory;
};
} }
diff --git a/cppe/include/IceE/ProxyF.h b/cppe/include/IceE/ProxyF.h
index 942fb51dd52..3318aa30fd2 100644
--- a/cppe/include/IceE/ProxyF.h
+++ b/cppe/include/IceE/ProxyF.h
@@ -25,27 +25,12 @@ class Object;
}
-namespace IceDelegate
-{
-
-namespace Ice
-{
-
-class Object;
-
-}
-
-}
-
namespace IceInternal
{
ICE_API void incRef(::IceProxy::Ice::Object*);
ICE_API void decRef(::IceProxy::Ice::Object*);
-ICE_API void incRef(::IceDelegate::Ice::Object*);
-ICE_API void decRef(::IceDelegate::Ice::Object*);
-
}
#include <IceE/ProxyHandle.h>
diff --git a/cppe/src/IceE/Proxy.cpp b/cppe/src/IceE/Proxy.cpp
index f6544047d27..6412de2d777 100644
--- a/cppe/src/IceE/Proxy.cpp
+++ b/cppe/src/IceE/Proxy.cpp
@@ -26,9 +26,6 @@ using namespace IceInternal;
void IceInternal::incRef(::IceProxy::Ice::Object* p) { p->__incRef(); }
void IceInternal::decRef(::IceProxy::Ice::Object* p) { p->__decRef(); }
-void IceInternal::incRef(::IceDelegate::Ice::Object* p) { p->__incRef(); }
-void IceInternal::decRef(::IceDelegate::Ice::Object* p) { p->__decRef(); }
-
void
Ice::__write(::IceInternal::BasicStream* __os, const ::Ice::Context& v, ::Ice::__U__Context)
{
@@ -174,8 +171,26 @@ IceProxy::Ice::Object::ice_isA(const string& __id, const Context& __context)
try
{
__checkTwowayOnly("ice_isA");
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> __del = __getDelegate();
- return __del->ice_isA(__id, __context);
+ static const string __operation("ice_isA");
+ __checkConnection();
+#ifdef ICEE_BLOCKING_CLIENT
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ if(_connection->blocking())
+# endif
+ {
+ Outgoing __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ return __ice_isA(__id, __og);
+ }
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ else
+# endif
+#endif
+#ifndef ICEE_PURE_BLOCKING_CLIENT
+ {
+ OutgoingM __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ return __ice_isA(__id, __og);
+ }
+#endif
}
catch(const NonRepeatable& __ex)
{
@@ -194,6 +209,46 @@ IceProxy::Ice::Object::ice_isA(const string& __id, const Context& __context)
}
}
+bool
+IceProxy::Ice::Object::__ice_isA(const string& __id, Outgoing& __og)
+{
+ try
+ {
+ BasicStream* __os = __og.os();
+ __os->write(__id);
+ }
+ catch(const ::Ice::LocalException& __ex)
+ {
+ __og.abort(__ex);
+ }
+ bool __ret;
+ bool __ok = __og.invoke();
+ try
+ {
+ BasicStream* __is = __og.is();
+ if(!__ok)
+ {
+ __is->throwException();
+ }
+ __is->read(__ret);
+ }
+ catch(const ::Ice::UserException&)
+ {
+ throw ::Ice::UnknownUserException(__FILE__, __LINE__);
+ }
+ catch(const ::Ice::LocalException& __ex)
+ {
+ throw ::IceInternal::NonRepeatable(__ex);
+ }
+#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
+ catch(...)
+ {
+ throw;
+ }
+#endif
+ return __ret;
+}
+
void
IceProxy::Ice::Object::ice_ping()
{
@@ -208,8 +263,26 @@ IceProxy::Ice::Object::ice_ping(const Context& __context)
{
try
{
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> __del = __getDelegate();
- __del->ice_ping(__context);
+ static const string __operation("ice_ping");
+ __checkConnection();
+#ifdef ICEE_BLOCKING_CLIENT
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ if(_connection->blocking())
+# endif
+ {
+ Outgoing __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ __ice_ping(__og);
+ }
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ else
+# endif
+#endif
+#ifndef ICEE_PURE_BLOCKING_CLIENT
+ {
+ OutgoingM __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ __ice_ping(__og);
+ }
+#endif
return;
}
catch(const NonRepeatable& __ex)
@@ -229,6 +302,36 @@ IceProxy::Ice::Object::ice_ping(const Context& __context)
}
}
+void
+IceProxy::Ice::Object::__ice_ping(Outgoing& __og)
+{
+ bool __ok = __og.invoke();
+ try
+ {
+ BasicStream* __is = __og.is();
+ if(!__ok)
+ {
+ __is->throwException();
+ }
+ }
+ catch(const ::Ice::UserException&)
+ {
+ throw ::Ice::UnknownUserException(__FILE__, __LINE__);
+ }
+ catch(const ::Ice::LocalException& __ex)
+ {
+ throw ::IceInternal::NonRepeatable(__ex);
+ }
+#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
+ catch(...)
+ {
+ throw;
+ }
+#endif
+}
+
+
+
vector<string>
IceProxy::Ice::Object::ice_ids()
{
@@ -244,8 +347,26 @@ IceProxy::Ice::Object::ice_ids(const Context& __context)
try
{
__checkTwowayOnly("ice_ids");
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> __del = __getDelegate();
- return __del->ice_ids(__context);
+ static const string __operation("ice_ids");
+ __checkConnection();
+#ifdef ICEE_BLOCKING_CLIENT
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ if(_connection->blocking())
+# endif
+ {
+ Outgoing __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ return __ice_ids(__og);
+ }
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ else
+# endif
+#endif
+#ifndef ICEE_PURE_BLOCKING_CLIENT
+ {
+ OutgoingM __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ return __ice_ids(__og);
+ }
+#endif
}
catch(const NonRepeatable& __ex)
{
@@ -264,6 +385,37 @@ IceProxy::Ice::Object::ice_ids(const Context& __context)
}
}
+vector<string>
+IceProxy::Ice::Object::__ice_ids(Outgoing& __og)
+{
+ vector<string> __ret;
+ bool __ok = __og.invoke();
+ try
+ {
+ BasicStream* __is = __og.is();
+ if(!__ok)
+ {
+ __is->throwException();
+ }
+ __is->read(__ret);
+ }
+ catch(const ::Ice::UserException&)
+ {
+ throw ::Ice::UnknownUserException(__FILE__, __LINE__);
+ }
+ catch(const ::Ice::LocalException& __ex)
+ {
+ throw ::IceInternal::NonRepeatable(__ex);
+ }
+#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
+ catch(...)
+ {
+ throw;
+ }
+#endif
+ return __ret;
+}
+
string
IceProxy::Ice::Object::ice_id()
{
@@ -279,8 +431,26 @@ IceProxy::Ice::Object::ice_id(const Context& __context)
try
{
__checkTwowayOnly("ice_id");
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> __del = __getDelegate();
- return __del->ice_id(__context);
+ static const string __operation("ice_id");
+ __checkConnection();
+#ifdef ICEE_BLOCKING_CLIENT
+#ifndef ICEE_PURE_BLOCKING_CLIENT
+ if(_connection->blocking())
+#endif
+ {
+ Outgoing __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ return __ice_id(__og);
+ }
+# ifndef ICEE_PURE_BLOCKING_CLIENT
+ else
+# endif
+#endif
+#ifndef ICEE_PURE_BLOCKING_CLIENT
+ {
+ OutgoingM __og(_connection.get(), _reference.get(), __operation, ::Ice::Nonmutating, __context);
+ return __ice_id(__og);
+ }
+#endif
}
catch(const NonRepeatable& __ex)
{
@@ -299,6 +469,38 @@ IceProxy::Ice::Object::ice_id(const Context& __context)
}
}
+string
+IceProxy::Ice::Object::__ice_id(Outgoing& __og)
+{
+ string __ret;
+ bool __ok = __og.invoke();
+ try
+ {
+ BasicStream* __is = __og.is();
+ if(!__ok)
+ {
+ __is->throwException();
+ }
+ __is->read(__ret);
+ }
+ catch(const ::Ice::UserException&)
+ {
+ throw ::Ice::UnknownUserException(__FILE__, __LINE__);
+ }
+ catch(const ::Ice::LocalException& __ex)
+ {
+ throw ::IceInternal::NonRepeatable(__ex);
+ }
+#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
+ catch(...)
+ {
+ throw;
+ }
+#endif
+ return __ret;
+}
+
+
Context
IceProxy::Ice::Object::ice_getContext() const
{
@@ -490,25 +692,7 @@ IceProxy::Ice::Object::ice_locator(const LocatorPrx& locator) const
ConnectionPtr
IceProxy::Ice::Object::ice_connection()
{
- int __cnt = 0;
- while(true)
- {
- try
- {
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> __del = __getDelegate();
- return __del->ice_connection();
- }
- catch(const LocalException& __ex)
- {
- __handleException(__ex, __cnt);
- }
-#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
- catch(...)
- {
- throw;
- }
-#endif
- }
+ return _connection;
}
ReferencePtr
@@ -521,13 +705,13 @@ void
IceProxy::Ice::Object::__copyFrom(const ObjectPrx& from)
{
ReferencePtr ref;
- ::IceInternal::Handle< ::IceDelegate::Ice::Object> delegate;
+ ConnectionPtr con;
{
::IceUtil::Mutex::Lock sync(*from.get());
ref = from->_reference;
- delegate = dynamic_cast< ::IceDelegate::Ice::Object*>(from->_delegate.get());
+ con = from->_connection;
}
//
@@ -536,26 +720,21 @@ IceProxy::Ice::Object::__copyFrom(const ObjectPrx& from)
//
assert(!_reference);
- assert(!_delegate);
+ assert(!_connection);
_reference = ref;
-
- if(delegate)
- {
- _delegate = __createDelegate();
- _delegate->__copyFrom(delegate);
- }
+ _connection = con;
}
void
IceProxy::Ice::Object::__handleException(const LocalException& ex, int& cnt)
{
//
- // Only _delegate needs to be mutex protected here.
+ // Only _connection needs to be mutex protected here.
//
{
- ::IceUtil::Mutex::Lock sync(*this);
- _delegate = 0;
+ ::IceUtil::Mutex::Lock sync(*this);
+ _connection = 0;
}
ProxyFactoryPtr proxyFactory = _reference->getInstance()->proxyFactory();
@@ -576,11 +755,11 @@ void
IceProxy::Ice::Object::__rethrowException(const LocalException& ex)
{
//
- // Only _delegate needs to be mutex protected here.
+ // Only _connection needs to be mutex protected here.
//
{
- ::IceUtil::Mutex::Lock sync(*this);
- _delegate = 0;
+ ::IceUtil::Mutex::Lock sync(*this);
+ _connection = 0;
}
ex.ice_throw();
@@ -602,40 +781,6 @@ IceProxy::Ice::Object::__checkTwowayOnly(const char* name) const
}
}
-::IceInternal::Handle< ::IceDelegate::Ice::Object>
-IceProxy::Ice::Object::__getDelegate()
-{
- ::IceUtil::Mutex::Lock sync(*this);
-
- if(!_delegate)
- {
- IceInternal::Handle< ::IceDelegate::Ice::Object> delegate = __createDelegate();
- delegate->setup(_reference);
- _delegate = delegate;
-
- //
- // If this proxy is for a non-local object, and we are
- // using a router, then add this proxy to the router info
- // object.
- //
-#ifdef ICEE_HAS_ROUTER
- RoutableReferencePtr rr = RoutableReferencePtr::dynamicCast(_reference);
- if(rr && rr->getRouterInfo())
- {
- rr->getRouterInfo()->addProxy(this);
- }
-#endif
- }
-
- return _delegate;
-}
-
-::IceInternal::Handle< ::IceDelegate::Ice::Object>
-IceProxy::Ice::Object::__createDelegate()
-{
- return ::IceInternal::Handle< ::IceDelegate::Ice::Object>(new ::IceDelegate::Ice::Object);
-}
-
const Context&
IceProxy::Ice::Object::__defaultContext() const
{
@@ -643,291 +788,42 @@ IceProxy::Ice::Object::__defaultContext() const
}
void
-IceProxy::Ice::Object::setup(const ReferencePtr& ref)
+IceProxy::Ice::Object::__checkConnection()
{
- //
- // No need to synchronize "*this", as this operation is only
- // called upon initialization.
- //
-
- assert(!_reference);
- assert(!_delegate);
-
- _reference = ref;
-}
-
-IceDelegate::Ice::Object::~Object()
-{
-}
-
-bool
-IceDelegate::Ice::Object::ice_isA(const string& __id, const Context& __context)
-{
- static const string __operation("ice_isA");
-#ifdef ICEE_BLOCKING_CLIENT
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- if(__connection->blocking())
-# endif
- {
- Outgoing __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- return __ice_isA(__id, __og);
- }
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- else
-# endif
-#endif
-#ifndef ICEE_PURE_BLOCKING_CLIENT
- {
- OutgoingM __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- return __ice_isA(__id, __og);
- }
-#endif
-}
-
-bool
-IceDelegate::Ice::Object::__ice_isA(const string& __id, Outgoing& __og)
-{
- try
- {
- BasicStream* __os = __og.os();
- __os->write(__id);
- }
- catch(const ::Ice::LocalException& __ex)
- {
- __og.abort(__ex);
- }
- bool __ret;
- bool __ok = __og.invoke();
- try
- {
- BasicStream* __is = __og.is();
- if(!__ok)
- {
- __is->throwException();
- }
- __is->read(__ret);
- }
- catch(const ::Ice::UserException&)
- {
- throw ::Ice::UnknownUserException(__FILE__, __LINE__);
- }
- catch(const ::Ice::LocalException& __ex)
- {
- throw ::IceInternal::NonRepeatable(__ex);
- }
-#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
- catch(...)
- {
- throw;
- }
-#endif
- return __ret;
-}
-
-void
-IceDelegate::Ice::Object::ice_ping(const Context& __context)
-{
- static const string __operation("ice_ping");
-#ifdef ICEE_BLOCKING_CLIENT
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- if(__connection->blocking())
-# endif
- {
- Outgoing __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- __ice_ping(__og);
- }
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- else
-# endif
-#endif
-#ifndef ICEE_PURE_BLOCKING_CLIENT
- {
- OutgoingM __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- __ice_ping(__og);
- }
-#endif
-
-}
-
-void
-IceDelegate::Ice::Object::__ice_ping(Outgoing& __og)
-{
- bool __ok = __og.invoke();
- try
- {
- BasicStream* __is = __og.is();
- if(!__ok)
- {
- __is->throwException();
- }
- }
- catch(const ::Ice::UserException&)
- {
- throw ::Ice::UnknownUserException(__FILE__, __LINE__);
- }
- catch(const ::Ice::LocalException& __ex)
- {
- throw ::IceInternal::NonRepeatable(__ex);
- }
-#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
- catch(...)
- {
- throw;
- }
-#endif
-}
-
-vector<string>
-IceDelegate::Ice::Object::ice_ids(const Context& __context)
-{
- static const string __operation("ice_ids");
-#ifdef ICEE_BLOCKING_CLIENT
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- if(__connection->blocking())
-# endif
- {
- Outgoing __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- return __ice_ids(__og);
- }
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- else
-# endif
-#endif
-#ifndef ICEE_PURE_BLOCKING_CLIENT
- {
- OutgoingM __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- return __ice_ids(__og);
- }
-#endif
-
-}
+ ::IceUtil::Mutex::Lock sync(*this);
-vector<string>
-IceDelegate::Ice::Object::__ice_ids(Outgoing& __og)
-{
- vector<string> __ret;
- bool __ok = __og.invoke();
- try
- {
- BasicStream* __is = __og.is();
- if(!__ok)
- {
- __is->throwException();
- }
- __is->read(__ret);
- }
- catch(const ::Ice::UserException&)
+ if(!_connection)
{
- throw ::Ice::UnknownUserException(__FILE__, __LINE__);
- }
- catch(const ::Ice::LocalException& __ex)
- {
- throw ::IceInternal::NonRepeatable(__ex);
- }
-#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
- catch(...)
- {
- throw;
- }
-#endif
- return __ret;
-}
+ _connection = _reference->getConnection();
-string
-IceDelegate::Ice::Object::ice_id(const Context& __context)
-{
- static const string __operation("ice_id");
-#ifdef ICEE_BLOCKING_CLIENT
-#ifndef ICEE_PURE_BLOCKING_CLIENT
- if(__connection->blocking())
-#endif
- {
- Outgoing __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- return __ice_id(__og);
- }
-# ifndef ICEE_PURE_BLOCKING_CLIENT
- else
-# endif
-#endif
-#ifndef ICEE_PURE_BLOCKING_CLIENT
- {
- OutgoingM __og(__connection.get(), __reference.get(), __operation, ::Ice::Nonmutating, __context);
- return __ice_id(__og);
- }
+ //
+ // If this proxy is for a non-local object, and we are
+ // using a router, then add this proxy to the router info
+ // object.
+ //
+#ifdef ICEE_HAS_ROUTER
+ RoutableReferencePtr rr = RoutableReferencePtr::dynamicCast(_reference);
+ if(rr && rr->getRouterInfo())
+ {
+ rr->getRouterInfo()->addProxy(this);
+ }
#endif
-
-}
-
-string
-IceDelegate::Ice::Object::__ice_id(Outgoing& __og)
-{
- string __ret;
- bool __ok = __og.invoke();
- try
- {
- BasicStream* __is = __og.is();
- if(!__ok)
- {
- __is->throwException();
- }
- __is->read(__ret);
- }
- catch(const ::Ice::UserException&)
- {
- throw ::Ice::UnknownUserException(__FILE__, __LINE__);
}
- catch(const ::Ice::LocalException& __ex)
- {
- throw ::IceInternal::NonRepeatable(__ex);
- }
-#if defined(_MSC_VER) && (_MSC_VER == 1201) && defined(_M_ARM) // EVC4 SP4 bug.
- catch(...)
- {
- throw;
- }
-#endif
- return __ret;
}
-ConnectionPtr
-IceDelegate::Ice::Object::ice_connection()
-{
- return __connection;
-}
void
-IceDelegate::Ice::Object::__copyFrom(const ::IceInternal::Handle< ::IceDelegate::Ice::Object>& from)
-{
- //
- // No need to synchronize "from", as the delegate is immutable
- // after creation.
- //
-
- //
- // No need to synchronize "*this", as this operation is only
- // called upon initialization.
- //
-
- assert(!__reference);
- assert(!__connection);
-
- __reference = from->__reference;
- __connection = from->__connection;
-}
-
-void
-IceDelegate::Ice::Object::setup(const ReferencePtr& ref)
+IceProxy::Ice::Object::setup(const ReferencePtr& ref)
{
//
// No need to synchronize "*this", as this operation is only
// called upon initialization.
//
- assert(!__reference);
- assert(!__connection);
+ assert(!_reference);
+ assert(!_connection);
- __reference = ref;
- __connection = __reference->getConnection();
+ _reference = ref;
}
bool
diff --git a/cppe/src/TcpTransport/Transceiver.cpp b/cppe/src/TcpTransport/Transceiver.cpp
index 465dc4d7c29..5809ec869fc 100644
--- a/cppe/src/TcpTransport/Transceiver.cpp
+++ b/cppe/src/TcpTransport/Transceiver.cpp
@@ -95,7 +95,7 @@ IceInternal::Transceiver::write(Buffer& buf, int timeout)
Buffer::Container::difference_type packetSize =
static_cast<Buffer::Container::difference_type>(buf.b.end() - buf.i);
-
+
#ifdef _WIN32
//
// Limit packet size to avoid performance problems on WIN32