service.hpp

Go to the documentation of this file.

#pragma once
 
#include <boost/capy/ex/execution_context.hpp>
#include <libusb.h>
#include <memory>
#include <optional>
#include <stop_token>
#include <thread>
#include <utility>
 
namespace co_usb::detail
{
 
struct handler_service : public boost::capy::execution_context::service
{
    using handler_fn_t = void (*)(libusb_context *, std::stop_token);
    handler_service(boost::capy::execution_context &ctx);
 
    template <std::invocable<libusb_context *, std::stop_token> HandlerFn>
    void start_thread (std::shared_ptr<libusb_context> ctx, HandlerFn &&handler_fn)
    {
        m_ctx            = ctx;
        m_handler_thread = std::jthread{
            [ctx = ctx.get(), handler_fn = std::forward<HandlerFn>(handler_fn)] (std::stop_token st)
            { handler_fn(ctx, st); }};
    }
 
    std::stop_source stop_source();
 
    ~handler_service() override;
    void shutdown() override;
 
  private:
    std::shared_ptr<libusb_context> m_ctx;
    std::optional<std::jthread> m_handler_thread;
};
 
} // namespace co_usb::detail