MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2025-03-13 21:10:32 +01:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:vm::fetch: Add conf item for in-flight race check interval time.

Browse source
This commit is contained in:
Jason Volk 2020-04-17 14:08:32 -07:00
parent de8f32e86a
commit 5c0ad71066
1 changed files with 16 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
modules/m_vm_fetch.cc
View file

@ -21,6 +21,7 @@ namespace ircd::m::vm::fetch
static void auth(const event &, vm::eval &, const room &);
static void handle(const event &, vm::eval &);
extern conf::item<milliseconds> prev_fetch_check_interval;
extern conf::item<milliseconds> prev_wait_time;
extern conf::item<size_t> prev_wait_count;
extern conf::item<size_t> prev_backfill_limit;
@ -102,6 +103,13 @@ ircd::m::vm::fetch::prev_wait_time
{ "default", 200L },
};
decltype(ircd::m::vm::fetch::prev_fetch_check_interval)
ircd::m::vm::fetch::prev_fetch_check_interval
{
{ "name", "ircd.m.vm.fetch.prev.fetch.check_interval" },
{ "default", 500L },
};
//
// fetch_phase
//
@ -623,13 +631,20 @@ ircd::m::vm::fetch::prev(const event &event,
now<system_point>() + seconds(event_timeout)
};
const milliseconds &check_interval
{
prev_fetch_check_interval
};
// Rather than waiting for all of the events to arrive or for the entire
// timeout to expire, we check if the sought events made it to the server
// in the meantime. If so we can drop these requests and bail.
//TODO: Ideally should be replaced with listener/notification/hook on the
//TODO: events arriving rather than this coarse sleep cycles.
while(now<system_point>() < timeout)
{
// Wait for an interval to give this loop some iterations.
if(fetching.wait(milliseconds(500), std::nothrow))
if(fetching.wait(check_interval, std::nothrow))
break;
// Check for satisfaction.