diff options
Diffstat (limited to 'cpp/test/uwp/controller/ViewController.xaml.cpp')
| -rw-r--r-- | cpp/test/uwp/controller/ViewController.xaml.cpp | 507 |
1 files changed, 0 insertions, 507 deletions
diff --git a/cpp/test/uwp/controller/ViewController.xaml.cpp b/cpp/test/uwp/controller/ViewController.xaml.cpp deleted file mode 100644 index 99d594fb81e..00000000000 --- a/cpp/test/uwp/controller/ViewController.xaml.cpp +++ /dev/null @@ -1,507 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2018 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 "ViewController.xaml.h" - -#include <Ice/Ice.h> -#include <Controller.h> -#include <TestHelper.h> - -#include <string> -#include <iostream> -#include <memory> -#include <condition_variable> - -using namespace std; -using namespace Controller; -using namespace Test::Common; - -using namespace Platform; -using namespace Windows::Foundation; -using namespace Windows::Foundation::Collections; -using namespace Windows::UI::Core; -using namespace Windows::UI::Xaml; -using namespace Windows::UI::Xaml::Controls; -using namespace Windows::UI::Xaml::Controls::Primitives; -using namespace Windows::UI::Xaml::Data; -using namespace Windows::UI::Xaml::Input; -using namespace Windows::UI::Xaml::Media; -using namespace Windows::UI::Xaml::Navigation; - -using namespace Windows::Networking::Connectivity; - -using namespace Platform::Collections; - -namespace -{ - -typedef int(*MAIN_ENTRY_POINT)(int, char**, Test::MainHelper*); -typedef int(*SHUTDOWN_ENTRY_POINT)(); - -class MainHelperI : public Test::MainHelper -{ -public: - - MainHelperI(ViewController^, const string&, const StringSeq&); - - virtual void serverReady(); - virtual void shutdown(); - virtual void waitForCompleted() - { - } - virtual bool redirect(); - virtual void print(const std::string&); - - virtual void run(); - void join(); - void completed(int); - void waitReady(int) const; - int waitSuccess(int) const; - string getOutput() const; - -private: - - ViewController^ _controller; - string _dll; - StringSeq _args; - FARPROC _dllTestShutdown; - bool _ready; - bool _completed; - int _status; - ostringstream _out; - thread _thread; - mutable mutex _mutex; - mutable condition_variable _condition; -}; - -class ProcessI : public Process -{ -public: - - ProcessI(ViewController^, shared_ptr<MainHelperI>); - - void waitReady(int, const Ice::Current&); - int waitSuccess(int, const Ice::Current&); - string terminate(const Ice::Current&); - -private: - - ViewController^ _controller; - shared_ptr<MainHelperI> _helper; -}; - -class ProcessControllerI : public ProcessController -{ -public: - - ProcessControllerI(ViewController^); - shared_ptr<ProcessPrx> start(string, string, StringSeq, const Ice::Current&); - virtual string getHost(string, bool, const Ice::Current&); - -private: - - ViewController^ _controller; - string _host; -}; - -class ControllerHelper -{ -public: - - ControllerHelper(ViewController^); - virtual ~ControllerHelper(); - - void - registerProcessController(ViewController^, - const Ice::ObjectAdapterPtr&, - const shared_ptr<ProcessControllerRegistryPrx>&, - const shared_ptr<ProcessControllerPrx>&); - -private: - - shared_ptr<Ice::Communicator> _communicator; - shared_ptr<Test::Common::ProcessControllerRegistryPrx> _registry; -}; - -} - -MainHelperI::MainHelperI(ViewController^ controller, const string& dll, const StringSeq& args) : - _controller(controller), - _dll(dll), - _args(args), - _ready(false), - _completed(false), - _status(0) -{ -} - -void -MainHelperI::serverReady() -{ - unique_lock<mutex> lock(_mutex); - _ready = true; - _condition.notify_all(); -} - -void -MainHelperI::shutdown() -{ - unique_lock<mutex> lock(_mutex); - if(_completed) - { - return; - } - - if(_dllTestShutdown) - { - _dllTestShutdown(); - } -} - -bool -MainHelperI::redirect() -{ - return _dll.find("client") != string::npos || _dll.find("collocated") != string::npos; -} - -void - -MainHelperI::print(const std::string& msg) -{ - _out << msg; - //_controller->println(msg); -} - -void -MainHelperI::run() -{ - thread t([this]() - { - HINSTANCE hnd = _controller->loadDll(_dll); - if(hnd == 0) - { - ostringstream os; - os << "failed to load `" << _dll << "': error code: " << GetLastError(); - print(os.str()); - completed(EXIT_FAILURE); - return; - } - - _dllTestShutdown = GetProcAddress(hnd, "dllTestShutdown"); - if(_dllTestShutdown == 0) - { - print("failed to find dllTestShutdown function from `" + _dll + "'"); - completed(EXIT_FAILURE); - return; - } - - FARPROC sym = GetProcAddress(hnd, "dllMain"); - if(sym == 0) - { - print("failed to find dllMain function from `" + _dll + "'"); - completed(EXIT_FAILURE); - return; - } - - MAIN_ENTRY_POINT dllMain = reinterpret_cast<MAIN_ENTRY_POINT>(sym); - char** argv = new char*[_args.size() + 1]; - for(unsigned int i = 0; i < _args.size(); ++i) - { - argv[i] = const_cast<char*>(_args[i].c_str()); - } - argv[_args.size()] = 0; - try - { - completed(dllMain(static_cast<int>(_args.size()), argv, this)); - } - catch(const std::exception& ex) - { - print("unexpected exception while running `" + _args[0] + "':\n" + ex.what()); - completed(EXIT_FAILURE); - } - catch(...) - { - print("unexpected unknown exception while running `" + _args[0] + "'"); - completed(EXIT_FAILURE); - } - delete[] argv; - }); - _thread = move(t); -} - -void -MainHelperI::join() -{ - _thread.join(); -} - -void -MainHelperI::completed(int status) -{ - unique_lock<mutex> lock(_mutex); - _completed = true; - _status = status; - _condition.notify_all(); -} - -void -MainHelperI::waitReady(int timeout) const -{ - unique_lock<mutex> lock(_mutex); - while(!_ready && !_completed) - { - - if(_condition.wait_for(lock, chrono::seconds(timeout)) == cv_status::timeout) - { - throw ProcessFailedException("timed out waiting for the process to be ready"); - } - } - if(_completed && _status == EXIT_FAILURE) - { - throw ProcessFailedException(_out.str()); - } -} - -int -MainHelperI::waitSuccess(int timeout) const -{ - unique_lock<mutex> lock(_mutex); - while(!_completed) - { - if(_condition.wait_for(lock, chrono::seconds(timeout)) == cv_status::timeout) - { - throw ProcessFailedException("timed out waiting for the process to succeed"); - } - } - return _status; -} - -string -MainHelperI::getOutput() const -{ - assert(_completed); - return _out.str(); -} - -ProcessI::ProcessI(ViewController^ controller, shared_ptr<MainHelperI> helper) : _controller(controller), _helper(helper) -{ -} - -void -ProcessI::waitReady(int timeout, const Ice::Current&) -{ - _helper->waitReady(timeout); -} - -int -ProcessI::waitSuccess(int timeout, const Ice::Current&) -{ - return _helper->waitSuccess(timeout); -} - -string -ProcessI::terminate(const Ice::Current& current) -{ - _helper->shutdown(); - current.adapter->remove(current.id); - _helper->join(); - return _helper->getOutput(); -} - -ProcessControllerI::ProcessControllerI(ViewController^ controller) : - _controller(controller), - _host(_controller->getHost()) -{ -} - -shared_ptr<ProcessPrx> -ProcessControllerI::start(string testSuite, string exe, StringSeq args, const Ice::Current& c) -{ - ostringstream os; - os << "starting " << testSuite << " " << exe << "... "; - _controller->println(os.str()); - replace(testSuite.begin(), testSuite.end(), '/', '_'); - args.insert(args.begin(), testSuite + '_' + exe + ".dll"); - auto helper = make_shared<MainHelperI>(_controller, testSuite + '_' + exe + ".dll", args); - helper->run(); - return Ice::uncheckedCast<ProcessPrx>(c.adapter->addWithUUID(make_shared<ProcessI>(_controller, helper))); -} - -string -ProcessControllerI::getHost(string, bool, const Ice::Current&) -{ - return _host; -} - -ControllerHelper::ControllerHelper(ViewController^ controller) -{ - Ice::InitializationData initData = Ice::InitializationData(); - initData.properties = Ice::createProperties(); - initData.properties->setProperty("Ice.ThreadPool.Client.SizeMax", "10"); - initData.properties->setProperty("Ice.Default.Host", "127.0.0.1"); - initData.properties->setProperty("Ice.Override.ConnectTimeout", "1000"); - //initData.properties->setProperty("Ice.Trace.Network", "3"); - //initData.properties->setProperty("Ice.Trace.Protocol", "1"); - initData.properties->setProperty("ControllerAdapter.AdapterId", Ice::generateUUID()); - - _communicator = Ice::initialize(initData); - - auto registry = Ice::uncheckedCast<ProcessControllerRegistryPrx>( - _communicator->stringToProxy("Util/ProcessControllerRegistry:tcp -h 127.0.0.1 -p 15001")); - Ice::ObjectAdapterPtr adapter = _communicator->createObjectAdapterWithEndpoints("ControllerAdapter", ""); - Ice::Identity ident = { "ProcessController", "UWP"}; - auto processController = - Ice::uncheckedCast<ProcessControllerPrx>(adapter->add(make_shared<ProcessControllerI>(controller), ident)); - adapter->activate(); - - registerProcessController(controller, adapter, registry, processController); -} - -void -ControllerHelper::registerProcessController(ViewController^ controller, - const Ice::ObjectAdapterPtr& adapter, - const shared_ptr<ProcessControllerRegistryPrx>& registry, - const shared_ptr<ProcessControllerPrx>& processController) -{ - registry->ice_pingAsync( - [this, controller, adapter, registry, processController]() - { - auto connection = registry->ice_getCachedConnection(); - connection->setAdapter(adapter); - connection->setACM(5, Ice::ACMClose::CloseOff, Ice::ACMHeartbeat::HeartbeatAlways); - connection->setCloseCallback([=](const shared_ptr<Ice::Connection>&) - { - controller->println("connection with process controller registry closed"); - std::this_thread::sleep_for(2s); - registerProcessController(controller, adapter, registry, processController); - }); - - registry->setProcessControllerAsync(processController, nullptr, - [controller](exception_ptr e) - { - try - { - rethrow_exception(e); - } - catch(const Ice::CommunicatorDestroyedException&) - { - } - catch(const std::exception& ex) - { - ostringstream os; - os << "unexpected exception while connecting to process controller registry:\n" << ex.what(); - controller->println(os.str()); - } - }); - }, - [this, controller, adapter, registry, processController](exception_ptr e) - { - try - { - rethrow_exception(e); - } - catch(const Ice::ConnectFailedException&) - { - std::this_thread::sleep_for(2s); - registerProcessController(controller, adapter, registry, processController); - } - catch(const Ice::TimeoutException&) - { - std::this_thread::sleep_for(2s); - registerProcessController(controller, adapter, registry, processController); - } - catch(const Ice::CommunicatorDestroyedException&) - { - } - catch(const std::exception& ex) - { - ostringstream os; - os << "unexpected exception while connecting to process controller registry:\n" << ex.what(); - controller->println(os.str()); - } - }); -} - -ControllerHelper::~ControllerHelper() -{ - _communicator->destroy(); -} - -static ControllerHelper* controllerHelper = 0; - -ViewController::ViewController() -{ - InitializeComponent(); - auto hostnames = NetworkInformation::GetHostNames(); - ipv4Addresses->Items->Append("127.0.0.1"); - for(unsigned int i = 0; i < hostnames->Size; ++i) - { - auto hostname = hostnames->GetAt(i); - if(hostname->Type == Windows::Networking::HostNameType::Ipv4) - { - ipv4Addresses->Items->Append(hostname->RawName); - } - } - ipv4Addresses->SelectedIndex = 0; -} - -string -ViewController::getHost() const -{ - return Ice::wstringToString(ipv4Addresses->SelectedItem->ToString()->Data()); -} - -void -ViewController::Hostname_SelectionChanged(Platform::Object^, Windows::UI::Xaml::Controls::SelectionChangedEventArgs^) -{ - if(controllerHelper) - { - delete controllerHelper; - controllerHelper = 0; - } - controllerHelper = new ControllerHelper(this); -} - -void -ViewController::println(const string& s) -{ - if(s.empty()) - { - return; - } - this->Dispatcher->RunAsync(CoreDispatcherPriority::Normal, ref new DispatchedHandler( - [=]() - { - Output->Items->Append(ref new String(Ice::stringToWstring(s).c_str())); - Output->SelectedIndex = Output->Items->Size - 1; - Output->ScrollIntoView(Output->SelectedItem); - })); -} - -HINSTANCE -ViewController::loadDll(const string& name) -{ - unique_lock<mutex> lock(_mutex); - map<string, HINSTANCE>::iterator p = _dlls.find(name); - if(p == _dlls.end()) - { - HINSTANCE hnd = LoadPackagedLibrary(Ice::stringToWstring(name).c_str(), 0); - p = _dlls.insert(make_pair(name, hnd)).first; - } - return p->second; -} - -ViewController::~ViewController() -{ - if(controllerHelper) - { - delete controllerHelper; - controllerHelper = 0; - } -} |