mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-12 16:21:13 +00:00
e2452fa7e4
This was not really broken, but it generated a debug log message containing the keyword 'error' consistently, which is convoluting any debugging session. This commit also adds some trace log message on plugin device control API calls.
90 lines
3.0 KiB
C++
90 lines
3.0 KiB
C++
/********************************************************************************
|
|
* Copyright (C) 2017 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH *
|
|
* *
|
|
* This software is distributed under the terms of the *
|
|
* GNU Lesser General Public Licence (LGPL) version 3, *
|
|
* copied verbatim in the file "LICENSE" *
|
|
********************************************************************************/
|
|
|
|
#include <fairlogger/Logger.h>
|
|
#include <fairmq/PluginServices.h>
|
|
#include <fairmq/tools/Strings.h>
|
|
|
|
using namespace fair::mq;
|
|
using namespace std;
|
|
|
|
auto PluginServices::ChangeDeviceState(const string& controller, const DeviceStateTransition next) -> bool
|
|
{
|
|
lock_guard<mutex> lock{fDeviceControllerMutex};
|
|
|
|
if (!fDeviceController) fDeviceController = controller;
|
|
|
|
if (fDeviceController == controller) {
|
|
return fDevice.ChangeState(next);
|
|
} else {
|
|
throw DeviceControlError{tools::ToString(
|
|
"Plugin '", controller, "' is not allowed to change device states. ",
|
|
"Currently, plugin '", *fDeviceController, "' has taken control."
|
|
)};
|
|
}
|
|
}
|
|
|
|
auto PluginServices::TakeDeviceControl(const string& controller) -> void
|
|
{
|
|
lock_guard<mutex> lock{fDeviceControllerMutex};
|
|
|
|
if (!fDeviceController) {
|
|
fDeviceController = controller;
|
|
LOG(trace) << "Plugin '" << controller << "' took over control.";
|
|
} else if (fDeviceController == controller) {
|
|
// nothing to do
|
|
LOG(trace) << "Plugin '" << controller << "' is already in control.";
|
|
} else {
|
|
throw DeviceControlError{tools::ToString(
|
|
"Plugin '", controller, "' is not allowed to take over control. ",
|
|
"Currently, plugin '", *fDeviceController, "' has taken control."
|
|
)};
|
|
}
|
|
}
|
|
|
|
auto PluginServices::StealDeviceControl(const string& controller) -> void
|
|
{
|
|
lock_guard<mutex> lock{fDeviceControllerMutex};
|
|
|
|
fDeviceController = controller;
|
|
LOG(trace) << "Plugin '" << controller << "' steals control!";
|
|
}
|
|
|
|
auto PluginServices::ReleaseDeviceControl(const string& controller) -> void
|
|
{
|
|
{
|
|
lock_guard<mutex> lock{fDeviceControllerMutex};
|
|
|
|
if (fDeviceController == controller) {
|
|
fDeviceController = boost::none;
|
|
LOG(trace) << "Plugin '" << controller << "' releases control.";
|
|
} else {
|
|
LOG(debug) << "Plugin '" << controller << "' cannot release control "
|
|
<< "because it has no control.";
|
|
}
|
|
}
|
|
|
|
fReleaseDeviceControlCondition.notify_one();
|
|
}
|
|
|
|
auto PluginServices::GetDeviceController() const -> boost::optional<string>
|
|
{
|
|
lock_guard<mutex> lock{fDeviceControllerMutex};
|
|
|
|
return fDeviceController;
|
|
}
|
|
|
|
auto PluginServices::WaitForReleaseDeviceControl() -> void
|
|
{
|
|
unique_lock<mutex> lock{fDeviceControllerMutex};
|
|
|
|
while (fDeviceController) {
|
|
fReleaseDeviceControlCondition.wait(lock);
|
|
}
|
|
}
|