DevicesManager.cxx

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
#include "Framework/DevicesManager.h"
#include "Framework/RuntimeError.h"
#include "Framework/Logger.h"
#include "Framework/DeviceController.h"
#include "Framework/Signpost.h"
 
O2_DECLARE_DYNAMIC_LOG(devices_manager);
 
namespace o2::framework
{
 
void DevicesManager::queueMessage(char const* target, char const* message)
{
  O2_SIGNPOST_ID_GENERATE(sid, devices_manager);
  O2_SIGNPOST_EVENT_EMIT(devices_manager, sid, "queue",
                         "Queuing message for %{public}s: %{public}s",
                         target, message);
  for (int di = 0; di < specs.size(); ++di) {
    if (specs[di].id == target) {
      messages.push_back({di, message});
    }
  }
}
 
void DevicesManager::flush()
{
  static bool notifiedUnavailable = false;
  static bool notifiedAvailable = false;
  for (auto& handle : messages) {
    auto controller = controls[handle.ref.index].controller;
    // Device might not be started yet, by the time we write to it.
    if (!controller) {
      if (!notifiedUnavailable) {
        LOGP(info, "Controller for {} not yet available.", specs[handle.ref.index].id);
        notifiedUnavailable = true;
      }
      continue;
    }
    if (notifiedUnavailable && !notifiedAvailable) {
      LOGP(info, "Controller for {} now available.", specs[handle.ref.index].id);
      notifiedAvailable = true;
    }
    O2_SIGNPOST_ID_GENERATE(sid, devices_manager);
    O2_SIGNPOST_EVENT_EMIT(devices_manager, sid, "flush",
                           "Flushing message to %{public}s: %{public}s",
                           specs[handle.ref.index].id.c_str(), handle.message.c_str());
    controller->write(handle.message.c_str(), handle.message.size());
  }
 
  auto checkIfController = [this](DeviceMessageHandle const& handle) {
    return this->controls[handle.ref.index].controller != nullptr;
  };
  auto it = std::remove_if(messages.begin(), messages.end(), checkIfController);
  auto r = std::distance(it, messages.end());
  messages.erase(it, messages.end());
}
 
} // namespace o2::framework