aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/blob.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-26 18:51:01 +0100
committertv <tv@krebsco.de>2026-10-26 18:51:01 +0100
commit93f1cc4005937667015c1554c9efdc10a5f781d2 (patch)
tree70abb8e436376b32c90cc49351d51768b978ee8e /src/swarm/blob.rs
parent1c78c817472de3c57aabf1bd8d0f44a4fdf512ff (diff)
read stamps sync and lock free
Diffstat (limited to 'src/swarm/blob.rs')
-rw-r--r--src/swarm/blob.rs4
1 files changed, 2 insertions, 2 deletions
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,