diff --git a/src/ringloop.cpp b/src/ringloop.cpp index 1060b7b4..13fbbe19 100644 --- a/src/ringloop.cpp +++ b/src/ringloop.cpp @@ -25,7 +25,6 @@ ring_loop_t::ring_loop_t(int qd) { free_ring_data[i] = i; } - wait_sqe_id = 1; } ring_loop_t::~ring_loop_t() @@ -83,11 +82,6 @@ void ring_loop_t::loop() } io_uring_cqe_seen(&ring, cqe); } - while (get_sqe_queue.size() > 0) - { - (get_sqe_queue[0].second)(); - get_sqe_queue.erase(get_sqe_queue.begin()); - } do { loop_again = false; diff --git a/src/ringloop.h b/src/ringloop.h index 7bf4dec3..de9343d8 100644 --- a/src/ringloop.h +++ b/src/ringloop.h @@ -119,11 +119,9 @@ struct ring_consumer_t class ring_loop_t { - std::vector>> get_sqe_queue; std::vector consumers; struct ring_data_t *ring_datas; int *free_ring_data; - int wait_sqe_id; unsigned free_ring_data_ptr; bool loop_again; struct io_uring ring; @@ -145,21 +143,6 @@ public: } return sqe; } - inline int wait_sqe(std::function cb) - { - get_sqe_queue.push_back({ wait_sqe_id, cb }); - return wait_sqe_id++; - } - inline void cancel_wait_sqe(int wait_id) - { - for (int i = 0; i < get_sqe_queue.size(); i++) - { - if (get_sqe_queue[i].first == wait_id) - { - get_sqe_queue.erase(get_sqe_queue.begin()+i, get_sqe_queue.begin()+i+1); - } - } - } inline int submit() { return io_uring_submit(&ring);