summaryrefslogtreecommitdiff
path: root/cpp/test/Ice/dispatcher/Dispatcher.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/test/Ice/dispatcher/Dispatcher.cpp')
-rw-r--r--cpp/test/Ice/dispatcher/Dispatcher.cpp25
1 files changed, 14 insertions, 11 deletions
diff --git a/cpp/test/Ice/dispatcher/Dispatcher.cpp b/cpp/test/Ice/dispatcher/Dispatcher.cpp
index 559852b4318..32e6109e1d6 100644
--- a/cpp/test/Ice/dispatcher/Dispatcher.cpp
+++ b/cpp/test/Ice/dispatcher/Dispatcher.cpp
@@ -10,6 +10,8 @@
#include <Dispatcher.h>
#include <TestCommon.h>
+using namespace std;
+
Dispatcher* Dispatcher::_instance = 0;
Dispatcher::Dispatcher()
@@ -22,17 +24,6 @@ Dispatcher::Dispatcher()
}
void
-Dispatcher::dispatch(const Ice::DispatcherCallPtr& call, const Ice::ConnectionPtr&)
-{
- Lock sync(*this);
- _calls.push_back(call);
- if(_calls.size() == 1)
- {
- notify();
- }
-}
-
-void
Dispatcher::terminate()
{
{
@@ -52,6 +43,18 @@ Dispatcher::isDispatcherThread()
}
void
+Dispatcher::dispatch(const Ice::DispatcherCallPtr& call, const Ice::ConnectionPtr&)
+
+{
+ Lock sync(*this);
+ _calls.push_back(call);
+ if(_calls.size() == 1)
+ {
+ notify();
+ }
+}
+
+void
Dispatcher::run()
{
while(true)