aboutsummaryrefslogtreecommitdiff
path: root/src/table/sync.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-03-12 15:07:23 +0100
committerAlex Auvolat <alex@adnab.me>2021-03-12 15:07:23 +0100
commitcbe7e1a66a9dceaaeae0467b4eefe51afd5b297c (patch)
treee31874c3ac2a01e19e62226bdabcf74d0c57d1f3 /src/table/sync.rs
parent8860aa19b867183b83ee48efd9990cd34e567f53 (diff)
downloadgarage-cbe7e1a66a9dceaaeae0467b4eefe51afd5b297c.tar.gz
garage-cbe7e1a66a9dceaaeae0467b4eefe51afd5b297c.zip
Move table rpc client out of tableaux
Diffstat (limited to 'src/table/sync.rs')
-rw-r--r--src/table/sync.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs
index 23161d15..4be8cd10 100644
--- a/src/table/sync.rs
+++ b/src/table/sync.rs
@@ -31,7 +31,7 @@ const ANTI_ENTROPY_INTERVAL: Duration = Duration::from_secs(10 * 60);
pub struct TableSyncer<F: TableSchema, R: TableReplication> {
data: Arc<TableData<F>>,
- aux: Arc<TableAux<F, R>>,
+ aux: Arc<TableAux<R>>,
todo: Mutex<SyncTodo>,
rpc_client: Arc<RpcClient<SyncRPC>>,
@@ -78,7 +78,7 @@ where
{
pub(crate) fn launch(
data: Arc<TableData<F>>,
- aux: Arc<TableAux<F, R>>,
+ aux: Arc<TableAux<R>>,
rpc_server: &mut RpcServer,
) -> Arc<Self> {
let rpc_path = format!("table_{}/sync", data.name);
@@ -605,7 +605,7 @@ impl SyncTodo {
fn add_full_sync<F: TableSchema, R: TableReplication>(
&mut self,
data: &TableData<F>,
- aux: &TableAux<F, R>,
+ aux: &TableAux<R>,
) {
let my_id = aux.system.id;