diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2007-11-27 11:58:35 +0100 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2007-11-27 11:58:35 +0100 |
| commit | 47f800495093fd7679a315e2d730fea22f6135b7 (patch) | |
| tree | a7b8d3488f3841367dd03d10cae293f36fd10481 /cpp/test/Ice/operations/TestAMDI.cpp | |
| parent | Fixed SystemException to no longer derive from LocalException (diff) | |
| download | ice-47f800495093fd7679a315e2d730fea22f6135b7.tar.bz2 ice-47f800495093fd7679a315e2d730fea22f6135b7.tar.xz ice-47f800495093fd7679a315e2d730fea22f6135b7.zip | |
- Added support for non-blocking AMI/batch requests, connection
creation.
- Added support for AMI oneway requests.
- Changed collocation optimization to not perform any DNS lookups.
Diffstat (limited to 'cpp/test/Ice/operations/TestAMDI.cpp')
| -rw-r--r-- | cpp/test/Ice/operations/TestAMDI.cpp | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/cpp/test/Ice/operations/TestAMDI.cpp b/cpp/test/Ice/operations/TestAMDI.cpp index 0227c30075f..f3baed1e676 100644 --- a/cpp/test/Ice/operations/TestAMDI.cpp +++ b/cpp/test/Ice/operations/TestAMDI.cpp @@ -37,10 +37,13 @@ private: void MyDerivedClassI::shutdown_async(const Test::AMD_MyClass_shutdownPtr& cb, const Ice::Current& current) { - if(_opVoidThread) { - _opVoidThread->getThreadControl().join(); - _opVoidThread = 0; + IceUtil::Mutex::Lock sync(_opVoidMutex); + if(_opVoidThread) + { + _opVoidThread->getThreadControl().join(); + _opVoidThread = 0; + } } current.adapter->getCommunicator()->shutdown(); @@ -50,6 +53,7 @@ MyDerivedClassI::shutdown_async(const Test::AMD_MyClass_shutdownPtr& cb, const I void MyDerivedClassI::opVoid_async(const Test::AMD_MyClass_opVoidPtr& cb, const Ice::Current&) { + IceUtil::Mutex::Lock sync(_opVoidMutex); if(_opVoidThread) { _opVoidThread->getThreadControl().join(); |