diff options
| author | tv <tv@krebsco.de> | 2026-10-26 18:51:01 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 18:51:01 +0100 |
| commit | 8d70536fd267e7ee730c390b6b47c03ddbef7df9 (patch) | |
| tree | fbbd93242874765903ce7113fe78e3159f304a29 /src/swarm/blob.rs | |
| parent | 8b7bf576d2b3ceb3e5b6cdae7a00989bebb3b4c4 (diff) | |
read stamps sync and lock free
Diffstat (limited to 'src/swarm/blob.rs')
| -rw-r--r-- | src/swarm/blob.rs | 4 |
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, |