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/Severity.hpp>
#include <ers/Context.hpp>
#include <ers/Issue.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