diff options
Diffstat (limited to 'cpp/test/Ice/dispatcher/TestI.cpp')
-rw-r--r-- | cpp/test/Ice/dispatcher/TestI.cpp | 52 |
1 files changed, 52 insertions, 0 deletions
diff --git a/cpp/test/Ice/dispatcher/TestI.cpp b/cpp/test/Ice/dispatcher/TestI.cpp new file mode 100644 index 00000000000..2957ab0fb66 --- /dev/null +++ b/cpp/test/Ice/dispatcher/TestI.cpp @@ -0,0 +1,52 @@ +// ********************************************************************** +// +// Copyright (c) 2003-2009 ZeroC, Inc. All rights reserved. +// +// This copy of Ice is licensed to you under the terms described in the +// ICE_LICENSE file included in this distribution. +// +// ********************************************************************** + +#include <TestI.h> +#include <Ice/Ice.h> +#include <Dispatcher.h> +#include <TestCommon.h> + +using namespace std; + +void +TestIntfI::op(const Ice::Current& current) +{ + test(Dispatcher::isDispatcherThread()); +} + +void +TestIntfI::opWithPayload(const Ice::ByteSeq&, const Ice::Current& current) +{ + test(Dispatcher::isDispatcherThread()); +} + +void +TestIntfI::shutdown(const Ice::Current& current) +{ + test(Dispatcher::isDispatcherThread()); + current.adapter->getCommunicator()->shutdown(); +} + +void +TestIntfControllerI::holdAdapter(const Ice::Current&) +{ + test(Dispatcher::isDispatcherThread()); + _adapter->hold(); +} + +void +TestIntfControllerI::resumeAdapter(const Ice::Current&) +{ + test(Dispatcher::isDispatcherThread()); + _adapter->activate(); +} + +TestIntfControllerI::TestIntfControllerI(const Ice::ObjectAdapterPtr& adapter) : _adapter(adapter) +{ +} |