diff options
Diffstat (limited to 'cpp/test/Ice/dispatcher/Dispatcher.cpp')
-rw-r--r-- | cpp/test/Ice/dispatcher/Dispatcher.cpp | 25 |
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) |