diff options
Diffstat (limited to 'general/WinHEC 2017 Lab/Toaster Support App/App/CustomCapability/cpp/ServiceViewModel.cpp')
| -rw-r--r-- | general/WinHEC 2017 Lab/Toaster Support App/App/CustomCapability/cpp/ServiceViewModel.cpp | 282 |
1 files changed, 0 insertions, 282 deletions
diff --git a/general/WinHEC 2017 Lab/Toaster Support App/App/CustomCapability/cpp/ServiceViewModel.cpp b/general/WinHEC 2017 Lab/Toaster Support App/App/CustomCapability/cpp/ServiceViewModel.cpp deleted file mode 100644 index 9f9674c4..00000000 --- a/general/WinHEC 2017 Lab/Toaster Support App/App/CustomCapability/cpp/ServiceViewModel.cpp +++ /dev/null @@ -1,282 +0,0 @@ -#include "pch.h" -#include "ServiceViewModel.h" -#include "MainPage.xaml.h" - -using namespace Concurrency; -using namespace Platform; -using namespace SDKTemplate; -using namespace Windows::System::Threading; -using namespace Windows::UI::Xaml::Data; - -ServiceViewModel::ServiceViewModel() -{ - // Set default rate - samplePeriod = 100; - - // Initialize UI state - startButtonEnabled = true; - stopButtonEnabled = false; - sliderEnabled = true; - sliderValue = samplePeriod; - actualRpcCallbackRate = "0"; - expectedRpcCallbackRate = "0"; - - meteringOn = false; - - // Get the dispatcher for notifying property change - dispatcher = Windows::UI::Core::CoreWindow::GetForCurrentThread()->Dispatcher; - - sampleArray = ref new Platform::Array<__int64>(1000); -} - -// -// if errCode represents an error, then display a message and return true. -// -inline bool ServiceViewModel::NotifyIfAnyError(__int64 errCode) -{ - if (errCode != 0) - { - meteringOn = false; - NotifyStatusMessage("Error occured while communicating with RPC server: " + errCode.ToString(), NotifyType::ErrorMessage); - - // Reset button state - StartButtonEnabled = true; - StopButtonEnabled = false; - return true; - } - return false; -} - -// Bindable properties -#pragma region BindableProperties - -String^ ServiceViewModel::ExpectedRpcCallbackRate::get() { return expectedRpcCallbackRate; } -void ServiceViewModel::ExpectedRpcCallbackRate::set(String^ value) -{ - if (expectedRpcCallbackRate != value) - { - expectedRpcCallbackRate = value; - NotifyPropertyChanged("ExpectedRpcCallbackRate"); - } -} - -String^ ServiceViewModel::ActualRpcCallbackRate::get() { return actualRpcCallbackRate; } -void ServiceViewModel::ActualRpcCallbackRate::set(String^ value) -{ - if (actualRpcCallbackRate != value) - { - actualRpcCallbackRate = value; - NotifyPropertyChanged("ActualRpcCallbackRate"); - } -} - -String^ ServiceViewModel::SampleMessage::get() { return sampleMessage; } -void ServiceViewModel::SampleMessage::set(String^ value) -{ - if (sampleMessage != value) - { - sampleMessage = value; - NotifyPropertyChanged("SampleMessage"); - } -} - -bool ServiceViewModel::StartButtonEnabled::get() { return startButtonEnabled; } -void ServiceViewModel::StartButtonEnabled::set(bool value) -{ - if (startButtonEnabled != value) - { - startButtonEnabled = value; - NotifyPropertyChanged("StartButtonEnabled"); - } -} - -bool ServiceViewModel::StopButtonEnabled::get() { return stopButtonEnabled; } -void ServiceViewModel::StopButtonEnabled::set(bool value) -{ - if (stopButtonEnabled != value) - { - stopButtonEnabled = value; - NotifyPropertyChanged("StopButtonEnabled"); - } -} - -bool ServiceViewModel::SliderEnabled::get() { return sliderEnabled; } -void ServiceViewModel::SliderEnabled::set(bool value) -{ - if (sliderEnabled != value) - { - sliderEnabled = value; - NotifyPropertyChanged("SliderEnabled"); - } -} - -double ServiceViewModel::SliderValue::get() { return sliderValue; } -void ServiceViewModel::SliderValue::set(double value) -{ - if (sliderValue != value) - { - sliderValue = value; - NotifyPropertyChanged("SliderValue"); - } -} -#pragma endregion BindableProperties - -void SDKTemplate::ServiceViewModel::NotifyPropertyChanged(Platform::String^ prop) -{ - if (dispatcher != nullptr) - { - dispatcher->RunAsync( - Windows::UI::Core::CoreDispatcherPriority::Normal, - ref new Windows::UI::Core::DispatchedHandler([this, prop]() - { - PropertyChangedEventArgs^ args = - ref new PropertyChangedEventArgs(prop); - PropertyChanged(this, args); - })); - } - // else log error -} - -// -// Initializes rpcclient and metering -// -void ServiceViewModel::StartMetering(int sampleRate) -{ - create_task([this, sampleRate] - { - SampleMessage = ""; - StartButtonEnabled = false; - StopButtonEnabled = true; - stopMeteringRequested = false; - - rpcclient = std::make_unique<RpcClient>(); - if (NotifyIfAnyError(rpcclient->Initialize())) return; - - meteringOn = true; - sampleRefreshCount = 0; - sampleArray[0] = 0; - - // Set the sample rate on server - this->samplePeriod = sampleRate; - __int64 retCode = rpcclient->SetSampleRate(sampleRate); - - FILETIME initialSystemTime; - GetSystemTimeAsFileTime(&initialSystemTime); - lastUpdateTime.LowPart = initialSystemTime.dwLowDateTime; - lastUpdateTime.HighPart = initialSystemTime.dwHighDateTime; - - if (!NotifyIfAnyError(retCode)) - { - // Set up worker for UI update. - Windows::Foundation::TimeSpan span{ 100 * 10000 }; // 100ms refresh rate - - auto timerHandler = ref new TimerElapsedHandler([this](ThreadPoolTimer^) - { - __int64 meteringData = rpcclient->MeteringData; - - // If there is no new data, return - if (sampleArray[0] == meteringData) - { - return; - } - - // Arithmetic subtraction of time - // https://msdn.microsoft.com/en-us/library/ms724950%28VS.85%29.aspx?f=255&MSPPError=-2147217396 - FILETIME currentSystemTime; - ULARGE_INTEGER currentTimeUi; - GetSystemTimeAsFileTime(¤tSystemTime); - currentTimeUi.LowPart = currentSystemTime.dwLowDateTime; - currentTimeUi.HighPart = currentSystemTime.dwHighDateTime; - - // Calculate number of samples received since last callback - __int64 now = rpcclient->CallbackCount; - __int64 diff = now - rpcDataCountOld; - rpcDataCountOld = now; - - // Calculate incoming sample rate - double rate = (double)diff*1E7 / (currentTimeUi.QuadPart - lastUpdateTime.QuadPart); - ExpectedRpcCallbackRate = (1E3 / this->samplePeriod).ToString() + " /sec"; - lastUpdateTime = currentTimeUi; - - ActualRpcCallbackRate = rate.ToString() + " /sec"; - - // Construct the sample data string - String^ sampleMessage = meteringData + "\n"; - unsigned int length = sampleArray->Length; - if (sampleRefreshCount < length) - { - ++sampleRefreshCount; - length = sampleRefreshCount; - } - - // Insert the new data point at the top of the array. - // Old data falls off the end of the array. - for (unsigned int i = 1; i < length; ++i) - { - sampleArray[i] = sampleArray[i - 1]; - sampleMessage += sampleArray[i] + "\n"; - } - sampleArray[0] = meteringData; - - SampleMessage = sampleMessage; - }); - - ThreadPoolTimer^ periodicTimer = ThreadPoolTimer::CreatePeriodicTimer(timerHandler, span); - NotifyStatusMessage("Metering start command sent successfully", NotifyType::StatusMessage); - retCode = this->rpcclient->StartMeteringAndWaitForStop(sampleRate); - meteringOn = false; - periodicTimer->Cancel(); - if (!NotifyIfAnyError(retCode) && !stopMeteringRequested) - { - NotifyStatusMessage("Rpc server connection closed without stop metering being requested", - NotifyType::ErrorMessage); - StartButtonEnabled = true; - StopButtonEnabled = false; - } - } - }); -} - -// -// Stop metering -// -void ServiceViewModel::StopMetering() -{ - create_task([this] - { - StopButtonEnabled = false; - SliderEnabled = false; - stopMeteringRequested = true; - - __int64 retCode = this->rpcclient->StopMetering(); - if (!NotifyIfAnyError(retCode)) - { - NotifyStatusMessage("Metering stop command sent successfully", - NotifyType::StatusMessage); - } - - SliderEnabled = true; - StartButtonEnabled = true; - }); -} - -// -// Set sample period -// -void ServiceViewModel::SetSamplePeriod(int samplePeriod) -{ - create_task([this, samplePeriod] - { - this->samplePeriod = samplePeriod; - if (meteringOn) - { - _int64 retCode = rpcclient->SetSampleRate(samplePeriod); - if (!NotifyIfAnyError(retCode)) - { - NotifyStatusMessage( - "Sample period set to: " + samplePeriod, - NotifyType::StatusMessage); - } - } - }); -}
\ No newline at end of file |