StreamManager.cpp File Reference

#include <assert.h>
#include <iostream>
#include <ers/Issue.hpp>
#include <ers/InputStream.hpp>
#include <ers/OutputStream.hpp>
#include <ers/StreamManager.hpp>
#include <ers/StreamFactory.hpp>
#include <ers/Severity.hpp>
#include <ers/Configuration.hpp>
#include <ers/ers.hpp>
#include <ers/internal/macro.hpp>
#include <ers/internal/Util.hpp>
#include <ers/internal/PluginManager.hpp>
#include <ers/internal/NullStream.hpp>
#include <ers/internal/SingletonCreator.hpp>

Include dependency graph for StreamManager.cpp:

Go to the source code of this file.

Classes
class	ers::StreamInitializer

Namespaces
namespace	ers

Functions
	ERS_DECLARE_ISSUE (ers, BadConfiguration, "The stream configuration string \""<< config<< "\" has syntax errors.",((std::string) config)) namespace

Function Documentation

ERS_DECLARE_ISSUE()

ERS_DECLARE_ISSUE	(	ers	,
		BadConfiguration	,
		"The stream configuration string \""<< config<< "\" has syntax errors."	,
		((std::string) config)	)

This variable contains the default keys for building the default streams. The default is to use the default stream, in verbose mode for errors and fatals.

Definition at line 39 of file StreamManager.cpp.

{
    const char SEPARATOR = ',';
    
    const char * const DefaultOutputStreams[] =
    {
    "lstdout",      // Debug
    "lstdout",      // Log
    "throttle,lstdout", // Information
    "throttle,lstderr", // Warning
        "throttle,lstderr", // Error
        "lstderr"       // Fatal
    };
    
    const char *
    get_stream_description( ers::severity severity )
    {
    assert( ers::Debug <= severity && severity <= ers::Fatal );
        
    std::string env_name( "DUNEDAQ_ERS_" );
    env_name += ers::to_string( severity );
    const char * env = ::getenv( env_name.c_str() );
    return env ? env : DefaultOutputStreams[severity];
    }
    
    void
    parse_stream_definition(    const std::string & text,
                std::vector<std::string> & result )
    {
    std::string::size_type start_p = 0, end_p = 0;
    short brackets_open = 0;
    while ( end_p < text.length() )
    {
        switch ( text[end_p] )
        {
        case '(':
            ++brackets_open;
            break;
        case ')':
            --brackets_open;
            break;
        case SEPARATOR:
            if ( !brackets_open )
            {
            result.push_back( text.substr( start_p, end_p - start_p ) );
            start_p = end_p + 1;
            }
                    break;
        default:
            break;
        }
        end_p++;
    }
        if ( brackets_open )
        {
            throw ers::BadConfiguration( ERS_HERE, text );
        }
        if ( start_p != end_p )
        {
        result.push_back( text.substr( start_p, end_p - start_p ) );
        }
    }
}