summaryrefslogtreecommitdiff
path: root/TAO/tao/ORB_Core.cpp
diff options
context:
space:
mode:
authorvzykov <vzykov@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2009-12-09 09:50:25 +0000
committervzykov <vzykov@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2009-12-09 09:50:25 +0000
commit6206a32a101fc957f1bb737c75a1d6879dd5638f (patch)
treeca84fd14e596acd3200483192d33e170d127b6d2 /TAO/tao/ORB_Core.cpp
parent7f791d780ab74cfd56eb201850ab06b6e2f3e747 (diff)
downloadATCD-6206a32a101fc957f1bb737c75a1d6879dd5638f.tar.gz
Wed Dec 9 09:40:10 UTC 2009 Vladimir Zykov <vladimir.zykov@prismtech.com>
* tests/Bug_1361_Regression/Echo_Caller.cpp: * tests/Bug_1361_Regression/Echo_Caller.h: * tests/Bug_1361_Regression/server.cpp: * tests/Bug_1361_Regression/Server_Thread_Pool.cpp: * tests/Bug_1361_Regression/Server_Thread_Pool.h: * tests/Bug_1361_Regression/run_test.pl: Changed the test so that it doesn't shutdown the orb until all threads are done with the remote calls. Substantially extended the time for server shutdown since threads in server's pool don't handle shutdown message until they send all (50) remote messages. * tao/ORB_Core.cpp: * tao/Messaging/Messaging_Policy_i.cpp: * tao/ORB_Core.h: This fixes Bug#3682. SYNC_WITH_TRANSPORT is now really default synch scope policy in TAO. * tao/Leader_Follower_Flushing_Strategy.cpp: Changed the code to poll the reactor instead of running it indefinitely. This fixes bug#3697.
Diffstat (limited to 'TAO/tao/ORB_Core.cpp')
-rw-r--r--TAO/tao/ORB_Core.cpp11
1 files changed, 11 insertions, 0 deletions
diff --git a/TAO/tao/ORB_Core.cpp b/TAO/tao/ORB_Core.cpp
index ddadaf39689..73689794ef0 100644
--- a/TAO/tao/ORB_Core.cpp
+++ b/TAO/tao/ORB_Core.cpp
@@ -294,6 +294,7 @@ TAO_ORB_Core::TAO_ORB_Core (const char *orbid,
ACE_NEW (this->request_dispatcher_,
TAO_Request_Dispatcher);
+ this->set_sync_scope_hook (TAO_ORB_Core::default_sync_scope_hook);
}
TAO_ORB_Core::~TAO_ORB_Core (void)
@@ -2962,6 +2963,16 @@ TAO_ORB_Core::implrepo_service (void)
}
void
+TAO_ORB_Core::default_sync_scope_hook (TAO_ORB_Core *,
+ TAO_Stub *,
+ bool &has_synchronization,
+ Messaging::SyncScope &scope)
+{
+ has_synchronization = true;
+ scope = Messaging::SYNC_WITH_TRANSPORT;
+}
+
+void
TAO_ORB_Core::call_sync_scope_hook (TAO_Stub *stub,
bool &has_synchronization,
Messaging::SyncScope &scope)