effd8568a4
Boost.Interprocess doesn't compile on Cygwin: https://github.com/boostorg/interprocess/issues/76 Also, disable affected tests and examples.
68 lines
2.0 KiB
C++
68 lines
2.0 KiB
C++
/*
|
|
* Copyright Lingxi Li 2015.
|
|
* Copyright Andrey Semashev 2016.
|
|
* 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)
|
|
*/
|
|
/*!
|
|
* \file sink_text_ipc_mq_backend.cpp
|
|
* \author Lingxi Li
|
|
* \author Andrey Semashev
|
|
* \date 19.10.2015
|
|
*
|
|
* \brief The test verifies that \c text_ipc_message_queue_backend works as expected.
|
|
*/
|
|
|
|
#if !defined(BOOST_LOG_WITHOUT_IPC)
|
|
|
|
#define BOOST_TEST_MODULE sink_text_ipc_mq_backend
|
|
|
|
#include <boost/log/sinks/text_ipc_message_queue_backend.hpp>
|
|
#include <boost/log/utility/ipc/reliable_message_queue.hpp>
|
|
#include <boost/log/utility/ipc/object_name.hpp>
|
|
#include <boost/log/utility/open_mode.hpp>
|
|
#include <boost/log/core/record_view.hpp>
|
|
#include <boost/test/unit_test.hpp>
|
|
#include <string>
|
|
#include "make_record.hpp"
|
|
#include "char_definitions.hpp"
|
|
|
|
const boost::log::ipc::object_name ipc_queue_name(boost::log::ipc::object_name::session, "boost_log_test_text_ipc_mq_backend");
|
|
const unsigned int capacity = 512;
|
|
const unsigned int block_size = 1024;
|
|
const char message[] = "Hello, world!";
|
|
|
|
// The test checks that `text_ipc_message_queue_backend` works.
|
|
BOOST_AUTO_TEST_CASE(text_ipc_message_queue_backend)
|
|
{
|
|
typedef boost::log::ipc::reliable_message_queue queue_t;
|
|
typedef boost::log::sinks::text_ipc_message_queue_backend< queue_t > backend_t;
|
|
|
|
// Do a remove in case if a previous test failed
|
|
queue_t::remove(ipc_queue_name);
|
|
|
|
backend_t backend;
|
|
BOOST_CHECK(!backend.is_open());
|
|
|
|
backend.message_queue().create(ipc_queue_name, capacity, block_size);
|
|
BOOST_CHECK(backend.is_open());
|
|
|
|
queue_t queue(boost::log::open_mode::open_only, ipc_queue_name);
|
|
boost::log::record_view rec = make_record_view();
|
|
backend.consume(rec, message);
|
|
|
|
std::string msg;
|
|
BOOST_CHECK(queue.try_receive(msg));
|
|
BOOST_CHECK(equal_strings(msg, message));
|
|
}
|
|
|
|
#else // !defined(BOOST_LOG_WITHOUT_IPC)
|
|
|
|
int main()
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
#endif // !defined(BOOST_LOG_WITHOUT_IPC)
|