diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-11-14 15:40:46 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-11-14 15:40:46 +0100 |
| commit | 90e1619b1e9f5d81e59da371f04717f0c4fe5afc (patch) | |
| tree | 914435938c6134bb959baaa4ffbd4f575730e9c0 /src/table/gc.rs | |
| parent | 3b361d2959e3d577bdae6f8a5ccb0c9d5526b7ea (diff) | |
| download | garage-90e1619b1e9f5d81e59da371f04717f0c4fe5afc.tar.gz garage-90e1619b1e9f5d81e59da371f04717f0c4fe5afc.zip | |
table: take into account multiple write sets in inserts
Diffstat (limited to 'src/table/gc.rs')
| -rw-r--r-- | src/table/gc.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/table/gc.rs b/src/table/gc.rs index 002cfbf4..ef788749 100644 --- a/src/table/gc.rs +++ b/src/table/gc.rs @@ -230,7 +230,7 @@ impl<F: TableSchema, R: TableReplication> TableGc<F, R> { .rpc_helper() .try_call_many( &self.endpoint, - &nodes[..], + &nodes, GcRpc::Update(updates), RequestStrategy::with_priority(PRIO_BACKGROUND).with_quorum(nodes.len()), ) @@ -251,7 +251,7 @@ impl<F: TableSchema, R: TableReplication> TableGc<F, R> { .rpc_helper() .try_call_many( &self.endpoint, - &nodes[..], + &nodes, GcRpc::DeleteIfEqualHash(deletes), RequestStrategy::with_priority(PRIO_BACKGROUND).with_quorum(nodes.len()), ) |