ClickHouse/src/Storages/RabbitMQ/UVLoop.h

#pragma once

#include <memory>

#include <boost/noncopyable.hpp>
#include <uv.h>

#include <Common/Exception.h>

namespace DB
{

namespace ErrorCodes
{
    extern const int SYSTEM_ERROR;
}

/// RAII wrapper arount uv event loop
class UVLoop: public boost::noncopyable
{
public:
    UVLoop(): loop_ptr(new uv_loop_t())
    {
        int res = uv_loop_init(loop_ptr.get());

        if (res != 0)
            throw Exception("UVLoop could not initialize", ErrorCodes::SYSTEM_ERROR);
    }

    ~UVLoop()
    {
        if (loop_ptr)
            uv_loop_close(loop_ptr.get());
    }

    inline uv_loop_t * getLoop() { return loop_ptr.get(); }

    inline const uv_loop_t * getLoop() const { return loop_ptr.get(); }

private:
    std::unique_ptr<uv_loop_t> loop_ptr;
};

}