InputStream.hpp

Go to the documentation of this file.

/*
 * DUNE DAQ modification notice:
 * This file has been modified from the original ATLAS ers source for the DUNE DAQ project.
 * Fork baseline commit: 8267df82a4f6fe6bf02c4014923eba19eddc4614 (2020-04-14).
 * Renamed since fork: yes (from ers/InputStream.h to include/ers/InputStream.hpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
/*
 *  InputStream.h
 *  ers
 *
 *  Created by Serguei Kolos on 02.08.05.
 *  Copyright 2004 CERN. All rights reserved.
 *
 */
 
#ifndef ERS_INPUT_STREAM_H
#define ERS_INPUT_STREAM_H
 
#include <ers/Issue.hpp>
#include <ers/IssueReceiver.hpp>
#include <string>

namespace ers {
class Issue;

class InputStream
{
  friend class StreamManager;
 
public:
  virtual ~InputStream() { ; }
 
protected:
  InputStream();

  void receive(const Issue& issue);
 
private:
  InputStream(const InputStream& other) = delete;
  InputStream& operator=(const InputStream&) = delete;
 
  void set_receiver(IssueReceiver* receiver) { m_receiver = receiver; }
 
  IssueReceiver* m_receiver;
};
}
 
#include <ers/StreamFactory.hpp>
 
#define ERS_REGISTER_INPUT_STREAM(class, name, params)                                                                 \
  namespace {                                                                                                          \
  struct InputStreamRegistrator                                                                                        \
  {                                                                                                                    \
    static ers::InputStream* create(const std::initializer_list<std::string>& params)                                  \
    {                                                                                                                  \
      return new class(params);                                                                                        \
    }                                                                                                                  \
    InputStreamRegistrator()                                                                                           \
    {                                                                                                                  \
      ers::StreamFactory::instance().register_in_stream(name, create);                                                 \
    }                                                                                                                  \
  } registrator_mp;                                                                                                    \
  }
 
#endif