From d9d6a4f9c4e970ae87526dcad6870ad5f70ac0c2 Mon Sep 17 00:00:00 2001 From: Vitaliy Filippov Date: Sun, 17 Nov 2019 22:26:55 +0300 Subject: [PATCH] Forgot to pass cqe result :) --- ringloop.cpp | 1 + test_blockstore.cpp | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/ringloop.cpp b/ringloop.cpp index 02145710d..4d45068a8 100644 --- a/ringloop.cpp +++ b/ringloop.cpp @@ -43,6 +43,7 @@ void ring_loop_t::loop(bool sleep) struct ring_data_t *d = (struct ring_data_t*)cqe->user_data; if (d->callback) { + d->res = cqe->res; d->callback(d); } io_uring_cqe_seen(&ring, cqe); diff --git a/test_blockstore.cpp b/test_blockstore.cpp index 1b6d12e74..6ad092332 100644 --- a/test_blockstore.cpp +++ b/test_blockstore.cpp @@ -75,15 +75,15 @@ int main(int narg, char *args[]) config["journal_device"] = "./test_journal.bin"; config["data_device"] = "./test_data.bin"; ring_loop_t *ringloop = new ring_loop_t(512); + blockstore *bs = new blockstore(config, ringloop); // print "tick" every second timerfd_interval tick_tfd(ringloop, 1); while (true) { ringloop->loop(true); } - //blockstore *bs = new blockstore(config, ringloop); - //delete bs; + delete bs; delete ringloop; return 0; }