Remove spdlog copy

//

// Copyright(c) 2018 Gabi Melman.

// Distributed under the MIT License (http://opensource.org/licenses/MIT)

//

#pragma once

//

// Async logging using global thread pool

// All loggers created here share same global thread pool.

// Each log message is pushed to a queue along withe a shared pointer to the

// logger.

// If a logger deleted while having pending messages in the queue, it's actual

// destruction will defer

// until all its messages are processed by the thread pool.

// This is because each message in the queue holds a shared_ptr to the

// originating logger.

#include "spdlog/async_logger.h"

#include "spdlog/details/registry.h"

#include "spdlog/details/thread_pool.h"

#include <memory>

#include <mutex>

namespace spdlog {

namespace details {

static const size_t default_async_q_size = 8192;

}

// async logger factory - creates async loggers backed with thread pool.

// if a global thread pool doesn't already exist, create it with default queue

// size of 8192 items and single thread.

template<async_overflow_policy OverflowPolicy = async_overflow_policy::block>

struct async_factory_impl

{

    template<typename Sink, typename... SinkArgs>

    static std::shared_ptr<async_logger> create(std::string logger_name, SinkArgs &&... args)

    {

        auto &registry_inst = details::registry::instance();

        // create global thread pool if not already exists..

        std::lock_guard<std::recursive_mutex> tp_lock(registry_inst.tp_mutex());

        auto tp = registry_inst.get_tp();

        if (tp == nullptr)

        {

            tp = std::make_shared<details::thread_pool>(details::default_async_q_size, 1);

            registry_inst.set_tp(tp);

        }

        auto sink = std::make_shared<Sink>(std::forward<SinkArgs>(args)...);

        auto new_logger = std::make_shared<async_logger>(std::move(logger_name), std::move(sink), std::move(tp), OverflowPolicy);

        registry_inst.initialize_logger(new_logger);

        return new_logger;

    }

};

using async_factory = async_factory_impl<async_overflow_policy::block>;

using async_factory_nonblock = async_factory_impl<async_overflow_policy::overrun_oldest>;

template<typename Sink, typename... SinkArgs>

inline std::shared_ptr<spdlog::logger> create_async(std::string logger_name, SinkArgs &&... sink_args)

{

    return async_factory::create<Sink>(std::move(logger_name), std::forward<SinkArgs>(sink_args)...);

}

template<typename Sink, typename... SinkArgs>

inline std::shared_ptr<spdlog::logger> create_async_nb(std::string logger_name, SinkArgs &&... sink_args)

{

    return async_factory_nonblock::create<Sink>(std::move(logger_name), std::forward<SinkArgs>(sink_args)...);

}

// set global thread pool.

inline void init_thread_pool(size_t q_size, size_t thread_count)

{

    auto tp = std::make_shared<details::thread_pool>(q_size, thread_count);

    details::registry::instance().set_tp(std::move(tp));

}

// get the global thread pool.

inline std::shared_ptr<spdlog::details::thread_pool> thread_pool()

{

    return details::registry::instance().get_tp();

}

} // namespace spdlog

//

// Copyright(c) 2015 Gabi Melman.

// Distributed under the MIT License (http://opensource.org/licenses/MIT)

//

#pragma once

// Very fast asynchronous logger (millions of logs per second on an average

// desktop)

// Uses pre allocated lockfree queue for maximum throughput even under large

// number of threads.

// Creates a single back thread to pop messages from the queue and log them.

//

// Upon each log write the logger:

//    1. Checks if its log level is enough to log the message

//    2. Push a new copy of the message to a queue (or block the caller until

//    space is available in the queue)

//    3. will throw spdlog_ex upon log exceptions

// Upon destruction, logs all remaining messages in the queue before

// destructing..

#include "spdlog/common.h"

#include "spdlog/logger.h"

#include <chrono>

#include <memory>

#include <string>

namespace spdlog {

// Async overflow policy - block by default.

enum class async_overflow_policy

{

    block,         // Block until message can be enqueued

    overrun_oldest // Discard oldest message in the queue if full when trying to

                   // add new item.

};

namespace details {

class thread_pool;

}

class async_logger final : public std::enable_shared_from_this<async_logger>, public logger

{

    friend class details::thread_pool;

public:

    template<typename It>

    async_logger(std::string logger_name, It begin, It end, std::weak_ptr<details::thread_pool> tp,

        async_overflow_policy overflow_policy = async_overflow_policy::block);

    async_logger(std::string logger_name, sinks_init_list sinks_list, std::weak_ptr<details::thread_pool> tp,

        async_overflow_policy overflow_policy = async_overflow_policy::block);

    async_logger(std::string logger_name, sink_ptr single_sink, std::weak_ptr<details::thread_pool> tp,

        async_overflow_policy overflow_policy = async_overflow_policy::block);

    std::shared_ptr<logger> clone(std::string new_name) override;

protected:

    void sink_it_(details::log_msg &msg) override;

    void flush_() override;

    void backend_log_(const details::log_msg &incoming_log_msg);

    void backend_flush_();

private:

    std::weak_ptr<details::thread_pool> thread_pool_;

    async_overflow_policy overflow_policy_;

};

} // namespace spdlog

#include "details/async_logger_impl.h"

//

// Copyright(c) 2015 Gabi Melman.

// Distributed under the MIT License (http://opensource.org/licenses/MIT)

//

#pragma once

#include "spdlog/tweakme.h"

#include <atomic>

#include <chrono>

#include <functional>

#include <initializer_list>

#include <memory>

#include <stdexcept>

#include <string>

#include <cstring>

#include <type_traits>

#include <unordered_map>

#if defined(SPDLOG_WCHAR_FILENAMES) || defined(SPDLOG_WCHAR_TO_UTF8_SUPPORT)

#include <codecvt>

#include <locale>

#endif

#include "spdlog/details/null_mutex.h"

#include "spdlog/fmt/fmt.h"

// visual studio upto 2013 does not support noexcept nor constexpr

#if defined(_MSC_VER) && (_MSC_VER < 1900)

#define SPDLOG_NOEXCEPT throw()

#define SPDLOG_CONSTEXPR

#else

#define SPDLOG_NOEXCEPT noexcept

#define SPDLOG_CONSTEXPR constexpr

#endif

#if defined(__GNUC__) || defined(__clang__)

#define SPDLOG_DEPRECATED __attribute__((deprecated))

#elif defined(_MSC_VER)

#define SPDLOG_DEPRECATED __declspec(deprecated)

#else

#define SPDLOG_DEPRECATED

#endif

// disable thread local on msvc 2013

#ifndef SPDLOG_NO_TLS

#if (defined(_MSC_VER) && (_MSC_VER < 1900)) || defined(__cplusplus_winrt)

#define SPDLOG_NO_TLS 1

#endif

#endif

// Get the basename of __FILE__ (at compile time if possible)

#if FMT_HAS_FEATURE(__builtin_strrchr)

#define SPDLOG_STRRCHR(str, sep) __builtin_strrchr(str, sep)

#else

#define SPDLOG_STRRCHR(str, sep) strrchr(str, sep)

#endif //__builtin_strrchr not defined

#ifdef _WIN32

#define SPDLOG_FILE_BASENAME(file) SPDLOG_STRRCHR("\\" file, '\\') + 1

#else

#define SPDLOG_FILE_BASENAME(file) SPDLOG_STRRCHR("/" file, '/') + 1

#endif

#ifndef SPDLOG_FUNCTION

#define SPDLOG_FUNCTION __FUNCTION__

#endif

namespace spdlog {

class formatter;

namespace sinks {

class sink;

}

using log_clock = std::chrono::system_clock;

using sink_ptr = std::shared_ptr<sinks::sink>;

using sinks_init_list = std::initializer_list<sink_ptr>;

using log_err_handler = std::function<void(const std::string &err_msg)>;

// string_view type - either std::string_view or fmt::string_view (pre c++17)

#if defined(FMT_USE_STD_STRING_VIEW)

using string_view_t = std::string_view;

#else

using string_view_t = fmt::string_view;

#endif

#if defined(SPDLOG_NO_ATOMIC_LEVELS)

using level_t = details::null_atomic_int;

#else

using level_t = std::atomic<int>;

#endif

#define SPDLOG_LEVEL_TRACE 0

#define SPDLOG_LEVEL_DEBUG 1

#define SPDLOG_LEVEL_INFO 2

#define SPDLOG_LEVEL_WARN 3

#define SPDLOG_LEVEL_ERROR 4

#define SPDLOG_LEVEL_CRITICAL 5

#define SPDLOG_LEVEL_OFF 6

#if !defined(SPDLOG_ACTIVE_LEVEL)

#define SPDLOG_ACTIVE_LEVEL SPDLOG_LEVEL_INFO

#endif

// Log level enum

namespace level {

enum level_enum

{

    trace = SPDLOG_LEVEL_TRACE,

    debug = SPDLOG_LEVEL_DEBUG,

    info = SPDLOG_LEVEL_INFO,

    warn = SPDLOG_LEVEL_WARN,

    err = SPDLOG_LEVEL_ERROR,

    critical = SPDLOG_LEVEL_CRITICAL,

    off = SPDLOG_LEVEL_OFF,

};

#if !defined(SPDLOG_LEVEL_NAMES)

#define SPDLOG_LEVEL_NAMES                                                                                                                 \

    {                                                                                                                                      \

        "trace", "debug", "info", "warning", "error", "critical", "off"                                                                    \

    }

#endif

static string_view_t level_string_views[] SPDLOG_LEVEL_NAMES;

static const char *short_level_names[]{"T", "D", "I", "W", "E", "C", "O"};

inline string_view_t &to_string_view(spdlog::level::level_enum l) SPDLOG_NOEXCEPT

{

    return level_string_views[l];

}

inline const char *to_short_c_str(spdlog::level::level_enum l) SPDLOG_NOEXCEPT

{

    return short_level_names[l];

}

inline spdlog::level::level_enum from_str(const std::string &name) SPDLOG_NOEXCEPT

{

    int level = 0;

    for (const auto &level_str : level_string_views)

    {

        if (level_str == name)

        {

            return static_cast<level::level_enum>(level);

        }

        level++;

    }

    return level::off;

}

using level_hasher = std::hash<int>;

} // namespace level

//

// Pattern time - specific time getting to use for pattern_formatter.

// local time by default

//

enum class pattern_time_type

{

    local, // log localtime

    utc    // log utc

};

//

// Log exception

//

class spdlog_ex : public std::exception

{

public:

    explicit spdlog_ex(std::string msg)

        : msg_(std::move(msg))

    {

    }

    spdlog_ex(const std::string &msg, int last_errno)

    {

        fmt::memory_buffer outbuf;

        fmt::format_system_error(outbuf, last_errno, msg);

        msg_ = fmt::to_string(outbuf);

    }

    const char *what() const SPDLOG_NOEXCEPT override

    {

        return msg_.c_str();

    }

private:

    std::string msg_;

};

//

// wchar support for windows file names (SPDLOG_WCHAR_FILENAMES must be defined)

//

#if defined(_WIN32) && defined(SPDLOG_WCHAR_FILENAMES)

using filename_t = std::wstring;

#else

using filename_t = std::string;

#endif

struct source_loc

{

    SPDLOG_CONSTEXPR source_loc()

        : filename{""}

        , line{0}

        , funcname{""}

    {

    }

    SPDLOG_CONSTEXPR source_loc(const char *filename, int line, const char *funcname)

        : filename{filename}

        , line{static_cast<uint32_t>(line)}

        , funcname{funcname}

    {

    }

    SPDLOG_CONSTEXPR bool empty() const SPDLOG_NOEXCEPT

    {

        return line == 0;

    }

    const char *filename;

    uint32_t line;

    const char *funcname;

};

namespace details {

// make_unique support for pre c++14

#if __cplusplus >= 201402L // C++14 and beyond

using std::make_unique;

#else

template<typename T, typename... Args>

std::unique_ptr<T> make_unique(Args &&... args)

{

    static_assert(!std::is_array<T>::value, "arrays not supported");

    return std::unique_ptr<T>(new T(std::forward<Args>(args)...));

}

#endif

} // namespace details

} // namespace spdlog

//

// Copyright(c) 2015 Gabi Melman.

// Distributed under the MIT License (http://opensource.org/licenses/MIT)

//

#pragma once

// async logger implementation

// uses a thread pool to perform the actual logging

#include "spdlog/details/thread_pool.h"

#include <chrono>

#include <memory>

#include <string>

template<typename It>

inline spdlog::async_logger::async_logger(

    std::string logger_name, It begin, It end, std::weak_ptr<details::thread_pool> tp, async_overflow_policy overflow_policy)

    : logger(std::move(logger_name), begin, end)

    , thread_pool_(std::move(tp))

    , overflow_policy_(overflow_policy)

{

}

inline spdlog::async_logger::async_logger(

    std::string logger_name, sinks_init_list sinks_list, std::weak_ptr<details::thread_pool> tp, async_overflow_policy overflow_policy)

    : async_logger(std::move(logger_name), sinks_list.begin(), sinks_list.end(), std::move(tp), overflow_policy)

{

}

inline spdlog::async_logger::async_logger(

    std::string logger_name, sink_ptr single_sink, std::weak_ptr<details::thread_pool> tp, async_overflow_policy overflow_policy)

    : async_logger(std::move(logger_name), {std::move(single_sink)}, std::move(tp), overflow_policy)

{

}

// send the log message to the thread pool

inline void spdlog::async_logger::sink_it_(details::log_msg &msg)

{

#if defined(SPDLOG_ENABLE_MESSAGE_COUNTER)

    incr_msg_counter_(msg);

#endif

    if (auto pool_ptr = thread_pool_.lock())

    {

        pool_ptr->post_log(shared_from_this(), msg, overflow_policy_);

    }

    else

    {

        throw spdlog_ex("async log: thread pool doesn't exist anymore");

    }

}

// send flush request to the thread pool

inline void spdlog::async_logger::flush_()

{

    if (auto pool_ptr = thread_pool_.lock())

    {

        pool_ptr->post_flush(shared_from_this(), overflow_policy_);

    }

    else

    {

        throw spdlog_ex("async flush: thread pool doesn't exist anymore");

    }

}

//

// backend functions - called from the thread pool to do the actual job

//

inline void spdlog::async_logger::backend_log_(const details::log_msg &incoming_log_msg)

{

    try

    {

        for (auto &s : sinks_)

        {

            if (s->should_log(incoming_log_msg.level))

            {

                s->log(incoming_log_msg);

            }

        }

    }

    SPDLOG_CATCH_AND_HANDLE

    if (should_flush_(incoming_log_msg))

    {

        backend_flush_();

    }

}

inline void spdlog::async_logger::backend_flush_()

{

    try

    {

        for (auto &sink : sinks_)

        {

            sink->flush();

        }

    }

    SPDLOG_CATCH_AND_HANDLE

}

inline std::shared_ptr<spdlog::logger> spdlog::async_logger::clone(std::string new_name)

{

    auto cloned = std::make_shared<spdlog::async_logger>(std::move(new_name), sinks_.begin(), sinks_.end(), thread_pool_, overflow_policy_);

    cloned->set_level(this->level());

    cloned->flush_on(this->flush_level());

    cloned->set_error_handler(this->error_handler());

    return std::move(cloned);

}

//

// Copyright(c) 2018 Gabi Melman.

// Distributed under the MIT License (http://opensource.org/licenses/MIT)

//

// cirucal q view of std::vector.

#pragma once

#include <vector>

namespace spdlog {

namespace details {

template<typename T>

class circular_q

{

public:

    using item_type = T;

    explicit circular_q(size_t max_items)

        : max_items_(max_items + 1) // one item is reserved as marker for full q

        , v_(max_items_)

    {

    }

    // push back, overrun (oldest) item if no room left

    void push_back(T &&item)

    {

        v_[tail_] = std::move(item);

        tail_ = (tail_ + 1) % max_items_;

        if (tail_ == head_) // overrun last item if full

        {

            head_ = (head_ + 1) % max_items_;

            ++overrun_counter_;

        }

    }

    // Pop item from front.

    // If there are no elements in the container, the behavior is undefined.

    void pop_front(T &popped_item)

    {

        popped_item = std::move(v_[head_]);

        head_ = (head_ + 1) % max_items_;

    }

    bool empty()

    {

        return tail_ == head_;

    }

    bool full()

    {

        // head is ahead of the tail by 1

        return ((tail_ + 1) % max_items_) == head_;

    }

    size_t overrun_counter() const

    {

        return overrun_counter_;

    }

private:

    size_t max_items_;

    typename std::vector<T>::size_type head_ = 0;

    typename std::vector<T>::size_type tail_ = 0;

    std::vector<T> v_;

    size_t overrun_counter_ = 0;

};

} // namespace details

} // namespace spdlog