@@ -259,7 +259,7 @@ namespace asyncpp::uring {
259
259
constexpr unsigned int sqe_size () const noexcept { return m_sqe_size; }
260
260
};
261
261
262
- uring (const params& p = params{}) : m_ring{}, m_caps{capability_set::no_parse_tag}, m_params{p } {
262
+ uring (const params& p = params{}) : m_params{p}, m_ring{}, m_caps{capability_set::no_parse_tag} {
263
263
264
264
auto res = io_uring_queue_init_params (m_params.sqe_size (), &m_ring, &m_params.raw ());
265
265
// auto res = io_uring_queue_init(m_params.sqe_size(), &m_ring, 0);
@@ -395,12 +395,12 @@ namespace asyncpp::uring {
395
395
396
396
io_service (const params& params = io_service::params{}) //
397
397
: uring{params}, //
398
- m_dispatched_wake{eventfd (0 , 0 )}, //
399
398
#ifdef IORING_FEAT_CQE_SKIP
400
- skip_success_flags{has_feature (IORING_FEAT_CQE_SKIP) ? ioseq_flag::cqe_skip_success : ioseq_flag::none}
399
+ skip_success_flags{has_feature (IORING_FEAT_CQE_SKIP) ? ioseq_flag::cqe_skip_success : ioseq_flag::none},
401
400
#else
402
- skip_success_flags{ioseq_flag::none}
401
+ skip_success_flags{ioseq_flag::none},
403
402
#endif
403
+ m_dispatched_wake{eventfd (0 , 0 )} //
404
404
{
405
405
set_null_cqe_handler ([](const io_uring_cqe* cqe) {
406
406
if (cqe->res < 0 ) std::cerr << " Error on null sqe: " << cqe->res << " " << strerror (-cqe->res ) << std::endl;
@@ -881,7 +881,7 @@ namespace asyncpp::uring {
881
881
buffer_handle ptr;
882
882
if (cqe->flags & IORING_CQE_F_BUFFER) {
883
883
auto bufidx = cqe->flags >> IORING_CQE_BUFFER_SHIFT;
884
- assert (cqe->res <= m_group.block_size ());
884
+ assert (cqe->res <= static_cast < long >( m_group.block_size () ));
885
885
ptr = buffer_handle (m_group, bufidx);
886
886
}
887
887
return {cqe->res , ptr};
@@ -892,7 +892,7 @@ namespace asyncpp::uring {
892
892
buffer_handle ptr;
893
893
if (cqe->flags & IORING_CQE_F_BUFFER) {
894
894
auto bufidx = cqe->flags >> IORING_CQE_BUFFER_SHIFT;
895
- assert (cqe->res <= m_group.block_size ());
895
+ assert (cqe->res <= static_cast < long >( m_group.block_size () ));
896
896
ptr = buffer_handle (m_group, bufidx);
897
897
}
898
898
return {cqe->res , ptr};
0 commit comments