MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-30 12:48:54 +02:00
Code Issues Releases Wiki Activity

ircd::db: Add interruption threshold at seek call.

Browse source
This commit is contained in:
Jason Volk 2019-02-07 20:57:44 -08:00
parent 72a3ff2856
commit a4bd140cc2
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ircd/db.cc
View file

@ -6923,10 +6923,10 @@ ircd::db::seek(database::column &c,
const rocksdb::ReadOptions &opts, const rocksdb::ReadOptions &opts,
std::unique_ptr<rocksdb::Iterator> &it) std::unique_ptr<rocksdb::Iterator> &it)
{ {
const ctx::uninterruptible::nothrow ui;
if(!it) if(!it)
{ {
const ctx::uninterruptible::nothrow ui;
database &d(*c.d); database &d(*c.d);
rocksdb::ColumnFamilyHandle *const &cf(c); rocksdb::ColumnFamilyHandle *const &cf(c);
it.reset(d.d->NewIterator(opts, cf)); it.reset(d.d->NewIterator(opts, cf));
@ -6941,6 +6941,8 @@ ircd::db::_seek(database::column &c,
const rocksdb::ReadOptions &opts, const rocksdb::ReadOptions &opts,
rocksdb::Iterator &it) rocksdb::Iterator &it)
{ {
const ctx::uninterruptible ui;
#ifdef RB_DEBUG_DB_SEEK #ifdef RB_DEBUG_DB_SEEK
database &d(*c.d); database &d(*c.d);
const ircd::timer timer; const ircd::timer timer;