control.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "ublk/detail/control.hpp"
#include "ublk/detail/task.hpp"
 
namespace ublk {

inline auto get_queue_affinity(int control_fd, uint32_t dev_id, uint16_t q_id,
                               cpu_set_t *cpuset) noexcept {
    return detail::task_invoke(detail::control_get_queue_affinity_t{},
                               control_fd, dev_id, q_id, cpuset);
}

inline auto get_dev_info(int control_fd, uint32_t dev_id,
                         ublksrv_ctrl_dev_info *info) noexcept {
    return detail::task_invoke(detail::control_get_dev_info_t{}, control_fd,
                               dev_id, info);
}

inline auto add_dev(int control_fd, ublksrv_ctrl_dev_info *info) noexcept {
    return raw::add_dev(control_fd, info) |
           detail::ex::then([](int32_t) noexcept {});
}

inline auto del_dev(int control_fd, uint32_t dev_id) noexcept {
    return detail::task_invoke(detail::control_del_dev_t{}, control_fd, dev_id);
}

inline auto start_dev(int control_fd, uint32_t dev_id,
                      int32_t daemon_pid) noexcept {
    return detail::task_invoke(detail::control_start_dev_t{}, control_fd,
                               dev_id, daemon_pid);
}

inline auto stop_dev(int control_fd, uint32_t dev_id) noexcept {
    return detail::task_invoke(detail::control_stop_dev_t{}, control_fd,
                               dev_id);
}

inline auto set_params(int control_fd, uint32_t dev_id,
                       const ublk_params *params) noexcept {
    return detail::task_invoke(detail::control_set_params_t{}, control_fd,
                               dev_id, params);
}

inline auto get_params(int control_fd, uint32_t dev_id,
                       ublk_params *params) noexcept {
    return detail::task_invoke(detail::control_get_params_t{}, control_fd,
                               dev_id, params);
}

inline auto start_user_recovery(int control_fd, uint32_t dev_id) noexcept {
    return detail::task_invoke(detail::control_start_user_recovery_t{},
                               control_fd, dev_id);
}

inline auto end_user_recovery(int control_fd, uint32_t dev_id,
                              int32_t daemon_pid) noexcept {
    return detail::task_invoke(detail::control_end_user_recovery_t{},
                               control_fd, dev_id, daemon_pid);
}

inline auto get_features(int control_fd, uint64_t *features) noexcept {
    return raw::get_features(control_fd, features) |
           detail::ex::then([](int32_t) noexcept {});
}

inline auto del_dev_async(int control_fd, uint32_t dev_id) noexcept {
    return detail::task_invoke(detail::control_del_dev_async_t{}, control_fd,
                               dev_id);
}

inline auto update_size(int control_fd, uint32_t dev_id,
                        uint64_t sectors) noexcept {
    return detail::task_invoke(detail::control_update_size_t{}, control_fd,
                               dev_id, sectors);
}

inline auto quiesce_dev(int control_fd, uint32_t dev_id,
                        uint64_t timeout_ms) noexcept {
    return detail::task_invoke(detail::control_quiesce_dev_t{}, control_fd,
                               dev_id, timeout_ms);
}

inline auto try_stop_dev(int control_fd, uint32_t dev_id) noexcept {
    return detail::task_invoke(detail::control_try_stop_dev_t{}, control_fd,
                               dev_id);
}

inline auto register_shm_buf(int control_fd, uint32_t dev_id,
                             const ublk_shmem_buf_reg *reg) noexcept {
    return detail::task_invoke(detail::control_register_shm_buf_t{}, control_fd,
                               dev_id, reg);
}

inline auto unregister_shm_buf(int control_fd, uint32_t dev_id,
                               uint64_t buf_index) noexcept {
    return detail::task_invoke(detail::control_unregister_shm_buf_t{},
                               control_fd, dev_id, buf_index);
}
 
} // namespace ublk