avi/Keynctr
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Trim metadata publish latency: skip global connection wait, 6s send cap

Browse source
This commit is contained in:
Avi 2026-08-23 19:09:46 -05:00
commit cb23a5e32d
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/profiles.rs
View file

@ -10,11 +10,9 @@ use crate::relays;
use crate::settings::Settings; use crate::settings::Settings;
use crate::vault::{unix_timestamp, StoredProfile, Vault}; use crate::vault::{unix_timestamp, StoredProfile, Vault};
/// How long to wait for relays to accept a connection attempt.
const METADATA_CONNECT_TIMEOUT: Duration = Duration::from_secs(5);
/// How long to wait for a single relay to accept the metadata event. Relays /// How long to wait for a single relay to accept the metadata event. Relays
/// are sent to in parallel, so this caps the whole publish, not each relay. /// are sent to in parallel, so this caps the whole publish, not each relay.
const METADATA_SEND_TIMEOUT: Duration = Duration::from_secs(8); const METADATA_SEND_TIMEOUT: Duration = Duration::from_secs(6);
/// A safe view of a profile that contains no secret key material. /// A safe view of a profile that contains no secret key material.
#[derive(Debug, Clone, Serialize, PartialEq, Eq)] #[derive(Debug, Clone, Serialize, PartialEq, Eq)]
@ -342,7 +340,10 @@ async fn publish_metadata_async(
let _ = client.add_relay(url.as_str()).await; let _ = client.add_relay(url.as_str()).await;
} }
client.connect().await; client.connect().await;
let _ = client.wait_for_connection(METADATA_CONNECT_TIMEOUT).await; // No explicit wait for connections here: `send_event` waits for each relay
// to become writable itself, and the per-send timeout below already bounds
// the whole publish. Waiting for *all* relays first would burn the full
// timeout whenever a single relay is unreachable.
// Send to every relay in parallel so one slow or dead relay cannot drag // Send to every relay in parallel so one slow or dead relay cannot drag
// the whole publish out to (relays x timeout). // the whole publish out to (relays x timeout).