DispatchPolicy.h

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.
#ifndef FRAMEWORK_DISPATCHPOLICY_H
#define FRAMEWORK_DISPATCHPOLICY_H
 
#include <functional>
#include <string>
#include <vector>
 
namespace o2
{
namespace framework
{
 
struct DeviceSpec;
struct Output;
 
struct DispatchPolicy {
  enum struct DispatchOp {
    AfterComputation,
    WhenReady,
  };
 
  using DeviceMatcher = std::function<bool(DeviceSpec const& device)>;
  // OutputMatcher can be a later extension, but not expected to be of high priority
  using TriggerMatcher = std::function<bool(Output const&)>;
 
  std::string name;
  DeviceMatcher deviceMatcher;
  DispatchOp action = DispatchOp::AfterComputation;
  TriggerMatcher triggerMatcher = defaultDispatchPolicy();
 
  static TriggerMatcher defaultDispatchPolicy();
 
  static std::vector<DispatchPolicy> createDefaultPolicies();
};
 
std::ostream& operator<<(std::ostream& oss, DispatchPolicy::DispatchOp const& val);
 
} // namespace framework
} // namespace o2
 
#endif // FRAMEWORK_DISPATCHPOLICY_H