Mocking.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.
#include "test_HelperMacros.h"
#include "Framework/ConfigContext.h"
#include "Framework/WorkflowSpec.h"
#include "Framework/DataSpecUtils.h"
#include "Framework/SimpleOptionsRetriever.h"
#include "Framework/WorkflowCustomizationHelpers.h"
#include "Framework/ChannelConfigurationPolicy.h"
 
namespace
{
std::unique_ptr<o2::framework::ConfigContext> makeEmptyConfigContext()
{
  using namespace o2::framework;
  // FIXME: Ugly... We need to fix ownership and make sure the ConfigContext
  //        either owns or shares ownership of the registry.
  std::vector<std::unique_ptr<ParamRetriever>> retrievers;
  static std::vector<ConfigParamSpec> specs = WorkflowCustomizationHelpers::requiredWorkflowOptions();
  for (auto& spec : specs) {
    if (spec.name == "timeframes-rate-limit-ipcid") {
      spec.defaultValue = "1";
    }
  }
  auto store = std::make_unique<ConfigParamStore>(specs, std::move(retrievers));
  store->preload();
  store->activate();
  static ConfigParamRegistry registry(std::move(store));
  static std::unique_ptr<ServiceRegistry> services;
  // We need to reset it because we will inject services into it.
  services = std::make_unique<ServiceRegistry>();
  auto context = std::make_unique<ConfigContext>(registry, ServiceRegistryRef{*services}, 0, nullptr);
  return context;
}
 
using namespace o2::framework;
 
std::vector<ChannelConfigurationPolicy> makeTrivialChannelPolicies(ConfigContext const& configContext)
{
  ChannelConfigurationPolicy defaultPolicy;
  FairMQChannelConfigSpec spec;
  spec.rateLogging = 0;
  spec.recvBufferSize = 1;
  spec.sendBufferSize = 1;
  spec.ipcPrefix = "@";
 
  defaultPolicy.match = ChannelConfigurationPolicyHelpers::matchAny;
  defaultPolicy.modifyInput = ChannelConfigurationPolicyHelpers::pullInput(spec);
  defaultPolicy.modifyOutput = ChannelConfigurationPolicyHelpers::pushOutput(spec);
 
  return {defaultPolicy};
}
} // namespace