diff options
| author | Dwayne Boone <dwayne@zeroc.com> | 2005-12-12 16:13:15 +0000 |
|---|---|---|
| committer | Dwayne Boone <dwayne@zeroc.com> | 2005-12-12 16:13:15 +0000 |
| commit | f2a48984a6f77743180602b2da0d07dc5dfee3e3 (patch) | |
| tree | da55120b35c3ea5a3244364f321e9aaeb457b7c7 /cppe/src/IceE/Instance.cpp | |
| parent | Fixed IceGrid and IceBox bug where spaces in directory names were not (diff) | |
| download | ice-f2a48984a6f77743180602b2da0d07dc5dfee3e3.tar.bz2 ice-f2a48984a6f77743180602b2da0d07dc5dfee3e3.tar.xz ice-f2a48984a6f77743180602b2da0d07dc5dfee3e3.zip | |
Added blocking client support
Diffstat (limited to 'cppe/src/IceE/Instance.cpp')
| -rw-r--r-- | cppe/src/IceE/Instance.cpp | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/cppe/src/IceE/Instance.cpp b/cppe/src/IceE/Instance.cpp index 612a28fd6c2..0f3f59a89a2 100644 --- a/cppe/src/IceE/Instance.cpp +++ b/cppe/src/IceE/Instance.cpp @@ -202,6 +202,14 @@ IceInternal::Instance::objectAdapterFactory() const } #endif +#if defined(ICEE_BLOCKING_CLIENT) && !defined(ICEE_PURE_BLOCKING_CLIENT) +bool +IceInternal::Instance::blocking() const +{ + return _blocking; +} +#endif + size_t IceInternal::Instance::threadPerConnectionStackSize() const { @@ -292,6 +300,9 @@ IceInternal::Instance::Instance(const CommunicatorPtr& communicator, const Prope _properties(properties), _messageSizeMax(0), _threadPerConnectionStackSize(0) +#if defined(ICEE_BLOCKING_CLIENT) && !defined(ICEE_PURE_BLOCKING_CLIENT) + , _blocking(false) +#endif { try { @@ -438,6 +449,11 @@ IceInternal::Instance::Instance(const CommunicatorPtr& communicator, const Prope } } +#ifndef ICEE_PURE_BLOCKING_CLIENT +# ifdef ICEE_BLOCKING_CLIENT + const_cast<bool&>(_blocking) = _properties->getPropertyAsInt("Ice.Blocking") > 0; +# endif + { Int stackSize = _properties->getPropertyAsInt("Ice.ThreadPerConnection.StackSize"); if(stackSize < 0) @@ -446,6 +462,7 @@ IceInternal::Instance::Instance(const CommunicatorPtr& communicator, const Prope } const_cast<size_t&>(_threadPerConnectionStackSize) = static_cast<size_t>(stackSize); } +#endif #ifdef ICEE_HAS_ROUTER _routerManager = new RouterManager; |