diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-12 15:07:23 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-12 15:07:23 +0100 |
| commit | cbe7e1a66a9dceaaeae0467b4eefe51afd5b297c (patch) | |
| tree | e31874c3ac2a01e19e62226bdabcf74d0c57d1f3 /src/table/sync.rs | |
| parent | 8860aa19b867183b83ee48efd9990cd34e567f53 (diff) | |
| download | garage-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.rs | 6 |
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; |