StreamFactory.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/StreamFactory.h to include/ers/StreamFactory.hpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
/*
 *  StreamFactory.h
 *  ers
 *
 *  Created by Matthias Wiesmann on 21.01.05.
 *  Modified by Serguei Kolos on 21.11.05.
 *  Copyright 2005 CERN. All rights reserved.
 *
 */
 
#ifndef ERS_STREAM_FACTORY_H
#define ERS_STREAM_FACTORY_H
 
#include <ers/Context.hpp>
#include <ers/Issue.hpp>
#include <ers/Severity.hpp>
 
#include <map>

 
ERS_DECLARE_ISSUE(ers, InvalidFormat, "Creator for the \"" << key << "\" stream is not found", ((std::string)key))
 
namespace ers {
class InputStream;
class OutputStream;
template<class>
class SingletonCreator;

 
class StreamFactory
{
  friend std::ostream& operator<<(std::ostream&, const ers::StreamFactory&);
  template<class>
  friend class SingletonCreator;
 
  typedef ers::InputStream* (*InputStreamCreator)(const std::initializer_list<std::string>& params);
  typedef ers::OutputStream* (*OutputStreamCreator)(const std::string& format);
 
public:
  static StreamFactory& instance(); 
 
  void register_in_stream(const std::string& name,
                          InputStreamCreator callback); 
 
  void register_out_stream(const std::string& name,
                           OutputStreamCreator callback); 
 
  InputStream* create_in_stream(const std::string& stream,
                                const std::string& filter) const; 
 
  InputStream* create_in_stream(const std::string& stream, const std::initializer_list<std::string>& params)
    const; 
 
  OutputStream* create_out_stream(const std::string& format) const; 
 
private:
  StreamFactory() { ; }
 
  typedef std::map<std::string, InputStreamCreator> InFunctionMap;
  typedef std::map<std::string, OutputStreamCreator> OutFunctionMap;
 
  InFunctionMap m_in_factories;   
  OutFunctionMap m_out_factories; 
};
 
std::ostream&
operator<<(std::ostream&, const ers::StreamFactory&);
}
 
#endif