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

modules/client/rooms/state: Optimize parallel closure invariant.

Browse source
This commit is contained in:
Jason Volk 2019-04-26 05:41:35 -07:00
parent 6335a0ce09
commit ea7e06fe27
1 changed files with 11 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
modules/client/sync/rooms/state.cc
View file

@ -192,18 +192,19 @@ ircd::m::sync::room_state_polylog_events(data &data)
*data.out, "events"
};
bool ret{false};
ctx::mutex mutex;
const event::closure_idx each_idx{[&data, &array, &mutex, &ret]
std::array<event::idx, 64> md; //TODO: conf
std::vector<event::fetch> event(md.size() * 2);
for(auto &fetch : event)
fetch = event::fetch{_default_fopts};
size_t _i(0);
bool ret{false};
const event::closure_idx each_idx{[&data, &array, &mutex, &ret, &event, &_i]
(const m::event::idx event_idx)
{
const event::fetch event
{
event_idx, std::nothrow, _default_fopts
};
//assert(event.valid);
if(unlikely(!event.valid))
const size_t i{_i++ % event.size()};
if(unlikely(!seek(event.at(i), event_idx, std::nothrow)))
{
assert(data.room);
log::error
@ -217,12 +218,10 @@ ircd::m::sync::room_state_polylog_events(data &data)
}
const std::lock_guard lock{mutex};
room_state_append(data, array, event, event_idx);
room_state_append(data, array, event.at(i), event_idx);
ret = true;
}};
//TODO: conf
std::array<event::idx, 64> md;
ctx::parallel<event::idx> parallel
{
m::sync::pool, md, each_idx