dandri/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity/ synced 2026-08-28 05:54:12 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(sender): Don't attempt to send concurrent transactions to a remote

Browse Source
This commit is contained in:
timedout
2026-08-11 17:31:43 +01:00
parent 8610d921f4
commit 46e7520180
1 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/service/sending/sender.rs
+13 -6
View File
@@ -398,18 +398,25 @@ fn should_attempt_send(
dest: &Destination,
statuses: &mut CurTransactionStatus,
) -> Result<(bool, bool)> {
let (mut allow, mut retry) = (true, false);
if let Destination::Federation(server_name) = dest {
let status = statuses
statuses
.entry(dest.clone())
.and_modify(|e| match e {
| TransactionStatus::Running | TransactionStatus::Retrying(_) => {
allow = false; // already running
},
| TransactionStatus::Failed(tries, _) => {
*e = TransactionStatus::Retrying(*tries);
retry = true;
},
})
.or_insert(TransactionStatus::Running);
let retry = matches!(status, TransactionStatus::Failed(_, _));
return match self.services.federation.retry_after(server_name) {
| None => Ok((true, retry)),
| Some(t) => Ok((t.as_millis() > 0, retry)),
| None => Ok((allow, retry)),
| Some(t) => Ok((t.as_millis() > 0 && allow, retry)),
};
}
let (mut allow, mut retry) = (true, false);
statuses
.entry(dest.clone())
.and_modify(|e| match e {