MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-29 20:28:52 +02:00
Code Issues Releases Wiki Activity

modules/client/sync/rooms/state: Make initial-phase state event queries concurrent.

Browse source
This commit is contained in:
Jason Volk 2019-07-14 13:40:25 -07:00
parent 5242432e0c
commit 5e15364e42
1 changed files with 24 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -255,48 +255,40 @@ ircd::m::sync::room_state_polylog_events(data &data)
bool
ircd::m::sync::room_state_phased_events(data &data)
{
bool ret{false};
ctx::mutex mutex;
json::stack::array array
{
*data.out, "events"
};
bool ret{false};
data.room->get(std::nothrow, "m.room.create", "", [&]
(const m::event &event)
static const std::pair<string_view, string_view> keys[]
{
ret = true;
room_state_append(data, array, event, index(event));
});
{ "m.room.create", "" },
{ "m.room.canonical_alias", "" },
{ "m.room.name", "" },
{ "m.room.avatar", "" },
{ "m.room.aliases", data.user.user_id.host() },
{ "m.room.member", data.user.user_id },
};
data.room->get(std::nothrow, "m.room.canonical_alias", "", [&]
(const m::event &event)
const auto append
{
room_state_append(data, array, event, index(event));
});
[&data, &array, &ret, &mutex](const m::event &event)
{
ret |= true;
const std::lock_guard lock{mutex};
room_state_append(data, array, event, index(event));
}
};
data.room->get(std::nothrow, "m.room.aliases", data.user.user_id.host(), [&]
(const m::event &event)
ctx::concurrent_for_each<const std::pair<string_view, string_view>>
{
room_state_append(data, array, event, index(event));
});
data.room->get(std::nothrow, "m.room.name", "", [&]
(const m::event &event)
{
room_state_append(data, array, event, index(event));
});
data.room->get(std::nothrow, "m.room.avatar", "", [&]
(const m::event &event)
{
room_state_append(data, array, event, index(event));
});
data.room->get(std::nothrow, "m.room.member", data.user.user_id, [&]
(const m::event &event)
{
room_state_append(data, array, event, index(event));
});
sync::pool, keys, [&data, &append](const auto &key)
{
data.room->get(std::nothrow, key.first, key.second, append);
}
};
ret |= room_state_phased_member_events(data, array);
return ret;