From 8d70536fd267e7ee730c390b6b47c03ddbef7df9 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Mon, 26 Oct 2026 18:51:01 +0100
Subject: read stamps sync and lock free

---
 src/swarm/blob.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src/swarm/blob.rs')

diff --git a/src/swarm/blob.rs b/src/swarm/blob.rs
index c153a17..4b69562 100644
--- a/src/swarm/blob.rs
+++ b/src/swarm/blob.rs
@@ -166,7 +166,7 @@ async fn prepare(state: &AppState, id: BlobId) -> Option<Arc<Prepared>> {
 }
 
 async fn reply(state: &AppState, peer: &str, id: BlobId, body: BlobBody) {
-    let (epoch, epoch_seq) = state.epoch_stamp().await;
+    let (epoch, epoch_seq) = state.epoch_stamp();
     let message = ParsedMessage::Blob(BlobMessage {
         epoch,
         epoch_seq,
@@ -220,7 +220,7 @@ impl Drop for Registration<'_> {
 }
 
 async fn request(state: &AppState, peer: &str, id: BlobId, chunks: Vec<u32>) {
-    let (epoch, epoch_seq) = state.epoch_stamp().await;
+    let (epoch, epoch_seq) = state.epoch_stamp();
     let message = ParsedMessage::Blob(BlobMessage {
         epoch,
         epoch_seq,
-- 
cgit v1.3.1