mirror of
https://github.com/boostorg/log.git
synced 2026-01-28 07:12:23 +00:00
70 lines
2.4 KiB
C++
70 lines
2.4 KiB
C++
/*
|
|
* Copyright Lingxi Li 2015.
|
|
* Distributed under the Boost Software License, Version 1.0.
|
|
* (See accompanying file LICENSE_1_0.txt or copy at
|
|
* http://www.boost.org/LICENSE_1_0.txt)
|
|
*/
|
|
|
|
#include <iostream>
|
|
#include <sstream>
|
|
#include <boost/smart_ptr/shared_ptr.hpp>
|
|
#include <boost/thread.hpp>
|
|
#include <boost/log/core.hpp>
|
|
#include <boost/log/sources/logger.hpp>
|
|
#include <boost/log/sources/record_ostream.hpp>
|
|
#include <boost/log/sinks/sync_frontend.hpp>
|
|
#include <boost/log/sinks/text_ipc_message_queue_backend.hpp>
|
|
|
|
namespace logging = boost::log;
|
|
namespace src = boost::log::sources;
|
|
namespace sinks = boost::log::sinks;
|
|
namespace keywords = boost::log::keywords;
|
|
|
|
//[ example_sinks_ipc_logger
|
|
int main()
|
|
{
|
|
typedef sinks::text_ipc_message_queue_backend backend_t;
|
|
typedef sinks::synchronous_sink<backend_t> sink_t;
|
|
|
|
try
|
|
{
|
|
// Create a backend that is associated with the interprocess message queue
|
|
// named "ipc_message_queue".
|
|
boost::shared_ptr<backend_t> p_backend(new backend_t(
|
|
keywords::message_queue_name = "ipc_message_queue",
|
|
keywords::open_mode = backend_t::open_or_create,
|
|
keywords::max_queue_size = 5,
|
|
keywords::max_message_size = 30,
|
|
keywords::queue_policy = backend_t::drop_when_full,
|
|
keywords::message_policy = backend_t::truncate_when_too_long));
|
|
boost::shared_ptr<sink_t> p_sink(new sink_t(p_backend));
|
|
logging::core::get()->add_sink(p_sink);
|
|
|
|
// Try to synthesize an identifier for the logger.
|
|
src::logger logger;
|
|
std::ostringstream stream;
|
|
stream << boost::this_thread::get_id();
|
|
std::string id = stream.str();
|
|
id.resize(5, '0');
|
|
std::cout << "Logger process " << id << " running..." << std::endl;
|
|
|
|
// Keep sending numbered messages to the associated message queue until EOF.
|
|
for (unsigned i = 1; std::cin.get() != std::istream::traits_type::eof(); ++i)
|
|
{
|
|
std::cout << "Send message #" << i << " from " << id << '.' << std::endl;
|
|
BOOST_LOG(logger) << "Message #" << i << " from " << id << '.';
|
|
}
|
|
}
|
|
catch (std::exception const& e)
|
|
{
|
|
std::cout << e.what() << std::endl;
|
|
}
|
|
catch (...)
|
|
{
|
|
std::cout << "Unknown exception caught." << std::endl;
|
|
}
|
|
|
|
logging::core::get()->remove_all_sinks();
|
|
}
|
|
//]
|