ChannelSpecHelpers.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 O2_FRAMEWORK_CHANNELSPECHELPERS_H_
#define O2_FRAMEWORK_CHANNELSPECHELPERS_H_
 
#include "Framework/ChannelSpec.h"
#include <iosfwd>
#include <string_view>
#include <vector>
 
namespace o2::framework
{
 
struct FairMQChannelConfigParser {
  virtual void beginChannel() {}
  virtual void endChannel() {}
  virtual void property(std::string_view /* key */, std::string_view /* value */) {}
  virtual void error() {}
};
 
struct OutputChannelSpecConfigParser : FairMQChannelConfigParser {
  void beginChannel() override;
  void endChannel() override;
  void property(std::string_view /* key */, std::string_view /* value */) override;
  void error() override;
  std::vector<OutputChannelSpec> specs;
  int channelCount = 0;
};
 
struct ChannelSpecHelpers {
  static char const* typeAsString(enum ChannelType type);
  static char const* methodAsString(enum ChannelMethod method);
  static std::string channelUrl(InputChannelSpec const&);
  static std::string channelUrl(OutputChannelSpec const&);
  static void parseChannelConfig(char const* channelConfig, FairMQChannelConfigParser& parser);
  static std::string defaultIPCFolder();
};
 
std::ostream& operator<<(std::ostream& s, ChannelType const& type);
std::ostream& operator<<(std::ostream& s, ChannelMethod const& method);
 
} // namespace o2::framework
 
#endif // O2_FRAMEWORK_CHANNELSPECHELPERS_H_