huynp911
/
vitastor
forked from vitalif/vitastor
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Forgot to pass cqe result :)

blocking-uring-test
Vitaliy Filippov 2019-11-17 22:26:55 +03:00
parent c2de733e35
commit d9d6a4f9c4
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ringloop.cpp
View File

@ -43,6 +43,7 @@ void ring_loop_t::loop(bool sleep)
struct ring_data_t *d = (struct ring_data_t*)cqe->user_data; struct ring_data_t *d = (struct ring_data_t*)cqe->user_data;
if (d->callback) if (d->callback)
{ {
d->res = cqe->res;
d->callback(d); d->callback(d);
} }
io_uring_cqe_seen(&ring, cqe); io_uring_cqe_seen(&ring, cqe);

4
test_blockstore.cpp
View File

@ -75,15 +75,15 @@ int main(int narg, char *args[])
config["journal_device"] = "./test_journal.bin"; config["journal_device"] = "./test_journal.bin";
config["data_device"] = "./test_data.bin"; config["data_device"] = "./test_data.bin";
ring_loop_t *ringloop = new ring_loop_t(512); ring_loop_t *ringloop = new ring_loop_t(512);
blockstore *bs = new blockstore(config, ringloop);
// print "tick" every second // print "tick" every second
timerfd_interval tick_tfd(ringloop, 1); timerfd_interval tick_tfd(ringloop, 1);
while (true) while (true)
{ {
ringloop->loop(true); ringloop->loop(true);
} }
//blockstore *bs = new blockstore(config, ringloop);
//delete bs; delete bs;
delete ringloop; delete ringloop;
return 0; return 0;
} }