diff options
| author | Alex Auvolat <alex@adnab.me> | 2024-03-27 16:00:46 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2024-03-27 16:22:40 +0100 |
| commit | 85f580cbde4913fe8382316ff3c27b8443c61dd7 (patch) | |
| tree | b5bf432281b746706c38fd4e494240997b66e9d1 /src/block/resync.rs | |
| parent | 0d3e285d133459fd53e28f879a86c0de1a0c36df (diff) | |
| download | garage-85f580cbde4913fe8382316ff3c27b8443c61dd7.tar.gz garage-85f580cbde4913fe8382316ff3c27b8443c61dd7.zip | |
[fix-buffering] change request sending strategy and fix prioritiesfix-buffering
remove LAS, priorize new requests but otherwise just do standard queuing
Diffstat (limited to 'src/block/resync.rs')
| -rw-r--r-- | src/block/resync.rs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/block/resync.rs b/src/block/resync.rs index 9c1da4a7..7221b093 100644 --- a/src/block/resync.rs +++ b/src/block/resync.rs @@ -436,7 +436,7 @@ impl BlockResyncManager { &manager.endpoint, &need_nodes[..], put_block_message, - RequestStrategy::with_priority(PRIO_BACKGROUND) + RequestStrategy::with_priority(PRIO_BACKGROUND | PRIO_SECONDARY) .with_quorum(need_nodes.len()), ) .await @@ -460,7 +460,9 @@ impl BlockResyncManager { hash ); - let block_data = manager.rpc_get_raw_block(hash, None).await?; + let block_data = manager + .rpc_get_raw_block(hash, PRIO_BACKGROUND | PRIO_SECONDARY, None) + .await?; manager.metrics.resync_recv_counter.add(1); |