MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-06-07 12:38:56 +02:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:vm::fetch: Replace coarse sleep() w/ prev wait notify.

Browse source
This commit is contained in:
Jason Volk 2023-02-03 23:12:29 -08:00
parent 9ecf389007
commit 4fe55722c9
1 changed files with 21 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
matrix/vm_fetch.cc
View file

@ -723,26 +723,12 @@ ircd::m::vm::fetch::prev_fetch(const event &event,
return ret;
}
//TODO: Adjust when PDU lookahead/lookaround is fixed in the vm::eval iface.
//TODO: Wait on another eval completion instead of just coarse sleep()'s.
bool
ircd::m::vm::fetch::prev_wait(const event &event,
vm::eval &eval)
{
const auto &opts(*eval.opts);
const event::prev prev(event);
const size_t prev_count
{
prev.prev_events_count()
};
const size_t &wait_count
{
ssize_t(opts.fetch_prev_wait_count) >= 0?
opts.fetch_prev_wait_count:
size_t(prev_wait_count)
};
const milliseconds &wait_time
{
opts.fetch_prev_wait_time >= 0ms?
@ -750,14 +736,29 @@ ircd::m::vm::fetch::prev_wait(const event &event,
milliseconds(prev_wait_time)
};
size_t i(0); while(i < wait_count)
const auto ids
{
sleep(milliseconds(++i * wait_time));
if(prev_count == prev.prev_events_exist())
return true;
}
prev.prev_events_count()
};
return false;
assume(ids <= event::prev::MAX);
event::id buf[event::prev::MAX];
const vector_view<const event::id> prev_id
(
prev.ids(buf)
);
const auto exists
{
notify::wait(prev_id, wait_time)
};
const bool obtained
{
exists == ids
};
return obtained;
}
void