2016-01-04 54 views
0

我使用boost日誌以兩個單獨的文件輸出我的日誌,問題是我需要立即寫入這些輸出,但是boost會等待200多行輸出到文件中。我不想要一個超快的輸出,但是每秒鐘兩次或者每秒都會很好。實時提升日誌記錄

有沒有辦法管理這段時間或每次寫入之間的行數?

我的H(BoostLogging.h):

#ifndef AUDIO_RECO_MODULES_COMMON_BOOSTLOGGING_H_ 
#define AUDIO_RECO_MODULES_COMMON_BOOSTLOGGING_H_ 

#include <cstddef> 
#include <string> 
#include <ostream> 
#include <fstream> 
#include <iomanip> 
#include <boost/smart_ptr/shared_ptr.hpp> 
#include <boost/smart_ptr/make_shared_object.hpp> 
#include <boost/phoenix/bind.hpp> 
#include <boost/date_time/posix_time/posix_time.hpp> 
#include <boost/log/core.hpp> 
#include <boost/log/expressions.hpp> 
#include <boost/log/attributes.hpp> 
#include <boost/log/sources/basic_logger.hpp> 
#include <boost/log/sources/severity_logger.hpp> 
#include <boost/log/sources/severity_channel_logger.hpp> 
#include <boost/log/sources/record_ostream.hpp> 
#include <boost/log/sinks/sync_frontend.hpp> 
#include <boost/log/sinks/text_ostream_backend.hpp> 
#include <boost/log/attributes/scoped_attribute.hpp> 
#include <boost/log/utility/value_ref.hpp> 
#include <boost/log/utility/setup/common_attributes.hpp> 

namespace logging = boost::log; 
namespace src = boost::log::sources; 
namespace expr = boost::log::expressions; 
namespace sinks = boost::log::sinks; 
namespace attrs = boost::log::attributes; 
namespace keywords = boost::log::keywords; 

enum severity_level { 
    TRACE, 
    DEBUG, 
    INFO, 
    WARNING, 
    ERROR, 
    FATAL, 
    NODE 
}; 

BOOST_LOG_ATTRIBUTE_KEYWORD(line_id, "LineID", unsigned int) 
BOOST_LOG_ATTRIBUTE_KEYWORD(severity, "Severity", severity_level) 
BOOST_LOG_ATTRIBUTE_KEYWORD(tag_attr, "Tag", std::string) 

std::ostream& operator<<(std::ostream& strm, severity_level level); 
void InitBoostLog(severity_level logging_level, std::string module_name); 

#endif //AUDIO_RECO_MODULES_COMMON_BOOSTLOGGING_H_ 

源(BoostLogging.cc):

#include <BoostLogging.h> 

std::ostream& operator<<(std::ostream& strm, severity_level level) { 
    static const char* strings[] = { 
     "trace", 
     "debug", 
     "info", 
     "warning", 
     "error", 
     "fatal", 
     "node" 
    }; 

    if (static_cast<std::size_t>(level) < sizeof(strings)/sizeof(*strings)) 
    strm << strings[level]; 
    else 
    strm << static_cast<int>(level); 

    return strm; 
} 

void InitBoostLog(severity_level logging_level, std::string module_name) { 
    // Setup the common formatter for all sinks 
    logging::formatter fmt = expr::stream 
     << std::setw(6) << std::setfill('0') << line_id << std::setfill(' ') 
     << ": <" << severity << ">\t" 
     << expr::if_(expr::has_attr(tag_attr)) 
    [ 
     expr::stream << "[" << tag_attr << "] " 
    ] 
     << expr::smessage; 

    // Initialize sinks 
    boost::shared_ptr<logging::core> core = logging::core::get(); 
    typedef sinks::synchronous_sink <sinks::text_ostream_backend> text_sink; 
    boost::shared_ptr<text_sink> sink = boost::make_shared<text_sink>(); 

    sink->locked_backend()->add_stream(
     boost::make_shared<std::ofstream>("arm-" + module_name + ".log")); 
    sink->set_formatter(fmt); 
    sink->set_filter(severity != NODE && severity >= logging_level); 
    core->add_sink(sink); 

    sink = boost::make_shared<text_sink>(); 
    sink->locked_backend()->add_stream(
     boost::make_shared<std::ofstream>("arm-" + module_name + "-node.log")); 
    sink->set_filter(severity == NODE); 
    core->add_sink(sink); 

    // Add attributes 
    logging::add_common_attributes(); 
} 

回答

0

啓用自動作爲@Andy T建議的沖洗是做這件事的好方法,在將接收器添加到內核之前,我們需要啓用自動沖洗功能。

sink->locked_backend()->add_stream(
    boost::make_shared<std::ofstream>("arm-" + module_name + ".log")); 
sink->set_formatter(fmt); 
sink->set_filter(severity != NODE && severity >= logging_level); 
sink->locked_backend()->auto_flush(true); // HERE 
core->add_sink(sink); 

sink = boost::make_shared<text_sink>(); 
sink->locked_backend()->add_stream(
    boost::make_shared<std::ofstream>("arm-" + module_name + "-node.log")); 
sink->set_filter(severity == NODE); 
sink->locked_backend()->auto_flush(true); // AND HERE 
core->add_sink(sink);