forked from vitalif/vitastor
Compare commits
1 Commits
master
...
test-submi
Author | SHA1 | Date |
---|---|---|
Vitaliy Filippov | 9c33de5e57 |
|
@ -196,11 +196,6 @@ void blockstore_impl_t::loop()
|
||||||
{
|
{
|
||||||
flusher->loop();
|
flusher->loop();
|
||||||
}
|
}
|
||||||
int ret = ringloop->submit();
|
|
||||||
if (ret < 0)
|
|
||||||
{
|
|
||||||
throw std::runtime_error(std::string("io_uring_submit: ") + strerror(-ret));
|
|
||||||
}
|
|
||||||
if ((initial_ring_space - ringloop->space_left()) > 0)
|
if ((initial_ring_space - ringloop->space_left()) > 0)
|
||||||
{
|
{
|
||||||
live = true;
|
live = true;
|
||||||
|
|
1
osd.cpp
1
osd.cpp
|
@ -175,7 +175,6 @@ void osd_t::loop()
|
||||||
handle_peers();
|
handle_peers();
|
||||||
read_requests();
|
read_requests();
|
||||||
send_replies();
|
send_replies();
|
||||||
ringloop->submit();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void osd_t::handle_epoll_events()
|
void osd_t::handle_epoll_events()
|
||||||
|
|
|
@ -146,8 +146,7 @@ public:
|
||||||
}
|
}
|
||||||
inline int wait()
|
inline int wait()
|
||||||
{
|
{
|
||||||
struct io_uring_cqe *cqe;
|
return io_uring_submit_and_wait(&ring, 1);
|
||||||
return io_uring_wait_cqe(&ring, &cqe);
|
|
||||||
}
|
}
|
||||||
inline unsigned space_left()
|
inline unsigned space_left()
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue