/home/bes3soft/bes3soft/Boss/7.0.2/dist/7.0.2/Event/ers/ers-00-00-03/src/HumanStream.cxx

Go to the documentation of this file.

/*
 *  HumanStream.cxx
 *  ers
 *
 *  Created by Matthias Wiesmann on 01.12.04.
 *  Copyright 2004 CERN. All rights reserved.
 *
 */

#include <assert.h>
#include "ers/ers.h"
#include "ers/HumanStream.h"


const char* const ers::HumanStream::KEY = "human" ; 

namespace {
    ers::Stream *create_stream(const std::string &protocol, const std::string &uri) { 
        (void) uri ;
        if (protocol==ers::HumanStream::KEY) {
            return new ers::HumanStream() ;  
        } 
        return 0 ; 
    } // 
    bool registered = ers::StreamFactory::instance()->register_factory(ers::HumanStream::KEY,create_stream) ;
} // anonymous namespace


std::string ers::HumanStream::to_string(const Issue *issue_ptr) throw() {
    try { 
        HumanStream ers_stream ;
        ers_stream.send(issue_ptr) ; 
        std::string str = ers_stream.to_string();
        return str ; 
    } catch (std::exception &ex) {
        std::string msg = "error while building message " + std::string(ex.what()) ; 
        return msg; 
    } // 
} // to_string

ers::HumanStream::HumanStream() : ers::Stream() {} // HumanStream
ers::HumanStream::HumanStream(const HumanStream &other) : ers::Stream(other) {} 
ers::HumanStream::~HumanStream() {} 

std::string ers::HumanStream::to_string() { 
     return m_out_stream.str(); 
} // to_string

void ers::HumanStream::clear() {
    m_out_stream.str(""); 
} // clear

void ers::HumanStream::print_to(std::ostream& stream) const {
    stream << ers::HumanStream::KEY << ':' ; 
} // print_to

void ers::HumanStream::send(const Issue *issue_ptr) {
    ERS_PRE_CHECK_PTR(issue_ptr); 
    if (m_out_stream) {
        try {
            const string_map_type *table = issue_ptr->get_value_table(); 
            const std::string message_str = issue_ptr->get_value(Issue::MESSAGE_KEY) ;
            const std::string severity_str = issue_ptr->get_value(Issue::SEVERITY_KEY) ;
            m_out_stream << "issue: " << message_str << "(" << severity_str << ")[" ; 
            bool first = true ; 
            for(string_map_type::const_iterator pos = table->begin();pos!=table->end();++pos) {
                const std::string &key = pos->first ; 
                const std::string &value = pos->second ; 
                if (first) {
                    first = false ;
                } else {
                    m_out_stream << ", " ;
                } // first or not
                m_out_stream  << key << "=\"" << value << '\"';
            } // for
            m_out_stream << "]" ; 
        } catch (std::ios_base::failure &ex) {
            throw ers::Issue(ERS_HERE,ers::error,&ex); 
        } // catch generic I/O errors 
    } // if m_out_stream
} // send

---