MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-18 07:50:57 +01:00
Code Issues Releases Wiki Activity

ircd::db: Minor commentary on interruption.

Browse source
This commit is contained in:
Jason Volk 2018-08-18 21:02:42 -07:00
parent c2c68e386d
commit ff4e20d948
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ircd/db.cc
View file

@ -4527,13 +4527,16 @@ size_t
ircd::db::seek(row &r, ircd::db::seek(row &r,
const pos &p) const pos &p)
{ {
// This frame can't be interrupted because it may have requests
// pending in the request pool which must synchronize back here.
const ctx::uninterruptible ui;
#ifdef RB_DEBUG_DB_SEEK #ifdef RB_DEBUG_DB_SEEK
const ircd::timer timer; const ircd::timer timer;
#endif #endif
size_t ret{0}; size_t ret{0};
ctx::latch latch{r.size()}; ctx::latch latch{r.size()};
const ctx::uninterruptible ui;
for(auto &cell : r) request([&latch, &ret, &cell, &p] for(auto &cell : r) request([&latch, &ret, &cell, &p]
{ {
ret += bool(seek(cell, p)); ret += bool(seek(cell, p));
@ -4566,6 +4569,10 @@ size_t
ircd::db::seek(row &r, ircd::db::seek(row &r,
const string_view &key) const string_view &key)
{ {
// This frame can't be interrupted because it may have requests
// pending in the request pool which must synchronize back here.
const ctx::uninterruptible ui;
#ifdef RB_DEBUG_DB_SEEK #ifdef RB_DEBUG_DB_SEEK
const ircd::timer timer; const ircd::timer timer;
#endif #endif
@ -4579,7 +4586,6 @@ ircd::db::seek(row &r,
latch.count_down(); latch.count_down();
}}; }};
const ctx::uninterruptible ui;
for(auto &cell : r) for(auto &cell : r)
{ {
db::column &column(cell); db::column &column(cell);