MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-26 07:23:53 +01:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:dbs: Supersede index query tool with parallel impl.

Browse source
This commit is contained in:
Jason Volk 2020-09-16 23:31:19 -07:00
parent 099b6d8301
commit 9165975953
2 changed files with 42 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
include/ircd/m/dbs/dbs.h
View file

@ -201,5 +201,17 @@ struct ircd::m::dbs::init
// Internal utils (here for now)
namespace ircd::m::dbs
{
size_t find_event_idx(const vector_view<event::idx> &out, const vector_view<const event::id> &in, const write_opts &);
event::idx find_event_idx(const event::id &, const write_opts &);
}
inline ircd::m::event::idx
ircd::m::dbs::find_event_idx(const event::id &event_id,
const write_opts &wopts)
{
event::idx ret{0};
const vector_view<event::idx> out(&ret, 1);
const vector_view<const event::id> in(&event_id, 1);
find_event_idx(out, in, wopts);
return ret;
}

37
matrix/dbs.cc
View file

@ -390,16 +390,39 @@ ircd::m::dbs::_index_room_redact(db::txn &txn,
}
// NOTE: QUERY
ircd::m::event::idx
ircd::m::dbs::find_event_idx(const event::id &event_id,
size_t
ircd::m::dbs::find_event_idx(const vector_view<event::idx> &idx,
const vector_view<const event::id> &event_id,
const write_opts &wopts)
{
event::idx ret{0};
if(wopts.interpose)
ret = wopts.interpose->val(db::op::SET, "_event_idx", event_id, 0UL);
const size_t num
{
std::min(idx.size(), event_id.size())
};
if(wopts.allow_queries && !ret)
ret = m::index(std::nothrow, event_id); // query
size_t ret(0);
if(wopts.interpose)
for(size_t i(0); i < num; ++i)
{
idx[i] = wopts.interpose->val(db::op::SET, "_event_idx", event_id[i], 0UL);
ret += idx[i] != 0;
}
// Taken when everything satisfied by interpose
if(ret == num || !wopts.allow_queries)
return ret;
// Only do parallel m::index() if there's no results from the prior
// queries; they'll get clobbered by the parallel m::index().
if(likely(!ret))
return m::index(idx, event_id);
// Fallback to serial queries.
for(size_t i(0); i < num; ++i)
{
idx[i] = m::index(std::nothrow, event_id[i]);
ret += idx[i] != 0;
}
return ret;
}