asyncbuffer.h

Go to the documentation of this file.

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#ifndef LOG4CXX_ASYNC_BUFFER_H
#define LOG4CXX_ASYNC_BUFFER_H
 
#include <log4cxx/helpers/messagebuffer.h>
#include <functional>
#include <vector>
 
namespace LOG4CXX_NS
{
 
namespace helpers
{

class LOG4CXX_EXPORT AsyncBuffer
{
public:
    AsyncBuffer();

    AsyncBuffer(AsyncBuffer&& other);

    ~AsyncBuffer();

    template<typename T>
    AsyncBuffer& operator<<(const T& value)
    {
        append([value](LogCharMessageBuffer& msgBuf)
            {
                msgBuf << value;
            });
        return *this;
    }
 
#ifdef __cpp_init_captures // C++ >= 14
    template<typename T>
    AsyncBuffer& operator<<(const T&& rvalue)
    {
        append([value = std::move(rvalue)](LogCharMessageBuffer& msgBuf)
            {
                msgBuf << value;
            });
        return *this;
    }
#endif
    bool empty() const;

    void renderMessage(LogCharMessageBuffer& msg);

    void clear();
 
private:
    AsyncBuffer(const AsyncBuffer&) = delete;
    AsyncBuffer& operator=(const AsyncBuffer&) = delete;
 
    LOG4CXX_DECLARE_PRIVATE_MEMBER_PTR(Private, m_priv)
    using MessageBufferAppender = std::function<void(LogCharMessageBuffer&)>;

    void append(const MessageBufferAppender& f);
};
 
} // namespace helpers
} // namespace LOG4CXX_NS

 
#if !defined(LOG4CXX_THRESHOLD) || LOG4CXX_THRESHOLD <= 10000
#define LOG4CXX_DEBUG_ASYNC(logger, message) do { \
        if (LOG4CXX_UNLIKELY(::LOG4CXX_NS::Logger::isDebugEnabledFor(logger))) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf; \
            logger->addDebugEvent(std::move(buf << message), LOG4CXX_LOCATION); }} while (0)
#else
#define LOG4CXX_DEBUG_ASYNC(logger, message)
#endif
 
#if !defined(LOG4CXX_THRESHOLD) || LOG4CXX_THRESHOLD <= 5000
#define LOG4CXX_TRACE_ASYNC(logger, message) do { \
        if (LOG4CXX_UNLIKELY(::LOG4CXX_NS::Logger::isTraceEnabledFor(logger))) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf; \
            logger->addTraceEvent(std::move(buf << message), LOG4CXX_LOCATION); }} while (0)
#else
#define LOG4CXX_TRACE_ASYNC(logger, message)
#endif
 
#if !defined(LOG4CXX_THRESHOLD) || LOG4CXX_THRESHOLD <= 20000
#define LOG4CXX_INFO_ASYNC(logger, message) do { \
        if (::LOG4CXX_NS::Logger::isInfoEnabledFor(logger)) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf;\
            logger->addInfoEvent(std::move(buf << message), LOG4CXX_LOCATION);\
        }} while (0)
 
#endif
 
#else
#define LOG4CXX_INFO_ASYNC(logger, message)
#endif
 
#if !defined(LOG4CXX_THRESHOLD) || LOG4CXX_THRESHOLD <= 30000
#define LOG4CXX_WARN_ASYNC(logger, message) do { \
        if (::LOG4CXX_NS::Logger::isWarnEnabledFor(logger)) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf; \
            logger->addWarnEvent(std::move(buf << message), LOG4CXX_LOCATION); }} while (0)
#else
#define LOG4CXX_WARN_ASYNC(logger, message)
#endif
 
#if !defined(LOG4CXX_THRESHOLD) || LOG4CXX_THRESHOLD <= 40000
#define LOG4CXX_ERROR_ASYNC(logger, message) do { \
        if (::LOG4CXX_NS::Logger::isErrorEnabledFor(logger)) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf; \
            logger->addErrorEvent(std::move(buf << message), LOG4CXX_LOCATION); }} while (0)

#define LOG4CXX_ASSERT_ASYNC(logger, condition, message) do { \
        if (!(condition) && ::LOG4CXX_NS::Logger::isErrorEnabledFor(logger)) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf; \
            LOG4CXX_STACKTRACE \
            logger->addErrorEvent(std::move(buf << message), LOG4CXX_LOCATION); }} while (0)
 
#else
#define LOG4CXX_ERROR_ASYNC(logger, message)
#define LOG4CXX_ASSERT_ASYNC(logger, condition, message)
#endif
 
#if !defined(LOG4CXX_THRESHOLD) || LOG4CXX_THRESHOLD <= 50000
#define LOG4CXX_FATAL_ASYNC(logger, message) do { \
        if (::LOG4CXX_NS::Logger::isFatalEnabledFor(logger)) {\
            ::LOG4CXX_NS::helpers::AsyncBuffer buf; \
            logger->addFatalEvent(std::move(buf << message), LOG4CXX_LOCATION); }} while (0)
 
#else
#define LOG4CXX_FATAL_ASYNC(logger, message)
#endif