From d9c61bd526fd83165d583cb5d75be66385611be4 Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 4 Nov 2026 23:32:40 +0100 Subject: time blob messages --- src/swarm/blob.rs | 2 ++ 1 file changed, 2 insertions(+) (limited to 'src/swarm/blob.rs') diff --git a/src/swarm/blob.rs b/src/swarm/blob.rs index ce9a2bd..98dee66 100644 --- a/src/swarm/blob.rs +++ b/src/swarm/blob.rs @@ -278,6 +278,7 @@ async fn reply(state: &AppState, peer: &str, id: BlobId, body: BlobBody) { epoch_seq, id, body, + sent: state.clock.now_millis(), }); if let Err(error) = state.transport.send_message(peer, &message).await { debug!(peer = %peer, blob = %id, error = %format!("{error:#}"), "Blob answer failed"); @@ -347,6 +348,7 @@ async fn request( chunks, delta: delta.cloned(), }, + sent: state.clock.now_millis(), }); if let Err(error) = state.transport.send_message(peer, &message).await { debug!(peer = %peer, blob = %id, error = %format!("{error:#}"), "Blob request failed"); -- cgit v1.3.1