MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-25 08:12:37 +01:00
Code Issues Releases Wiki Activity

modules/federation/send: Relax default restrictions on parallel evaluations.

Browse source
This commit is contained in:
Jason Volk 2020-04-20 00:29:41 -07:00
parent 1a0a24d91a
commit 59e24e19bd
1 changed files with 24 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
modules/federation/send.cc
View file

@ -37,7 +37,7 @@ conf::item<size_t>
eval_max_per_node
{
{ "name", "ircd.federation.send.eval.max_per_node" },
{ "default", 1L },
{ "default", 4L },
};
conf::item<bool>
@ -217,40 +217,39 @@ handle_put(client &client,
};
size_t evals{0};
const bool txn_in_progress
bool txn_in_progress{false};
m::vm::eval::for_each([&txn_id, &request, &evals, &txn_in_progress]
(const auto &eval)
{
!m::vm::eval::for_each([&txn_id, &request, &evals]
(const auto &eval)
assert(eval.opts);
const bool match_node
{
assert(eval.opts);
const bool match_node
{
eval.opts->node_id == request.node_id
};
const bool match_txn
{
match_node &&
eval.opts->txn_id == txn_id
};
evals += match_node;
return !match_txn; // false to break; for_each() returns false
})
};
if(txn_in_progress)
return m::resource::response
{
client, http::ACCEPTED
eval.opts->node_id == request.node_id
};
const bool match_txn
{
match_node &&
eval.opts->txn_id == txn_id
};
evals += match_node;
txn_in_progress |= match_txn;
return evals < size_t(eval_max_per_node);
});
if(evals >= size_t(eval_max_per_node))
return m::resource::response
{
client, http::TOO_MANY_REQUESTS
};
if(txn_in_progress)
return m::resource::response
{
client, http::ACCEPTED
};
// Lazy-allocated response buffer; only for error transcription
unique_mutable_buffer response_buffer;
const json::object &response