From 13143726a6be4baff56e6a48390dcdc13a26563b Mon Sep 17 00:00:00 2001 From: SionoiS Date: Thu, 16 Jan 2025 09:21:53 -0500 Subject: [PATCH] renaming & typo --- waku/waku_store_sync/reconciliation.nim | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/waku/waku_store_sync/reconciliation.nim b/waku/waku_store_sync/reconciliation.nim index 4e2a7237b1..18ff211aaa 100644 --- a/waku/waku_store_sync/reconciliation.nim +++ b/waku/waku_store_sync/reconciliation.nim @@ -43,13 +43,13 @@ type SyncReconciliation* = ref object of LPProtocol idsRx: AsyncQueue[ID] # Send Hashes to transfer protocol for reception - wantsTx: AsyncQueue[(PeerId, Fingerprint)] + localWantsTx: AsyncQueue[(PeerId, Fingerprint)] # Send Hashes to transfer protocol for transmission - needsTx: AsyncQueue[(PeerId, Fingerprint)] + remoteNeedsTx: AsyncQueue[(PeerId, Fingerprint)] # params - syncInterval: timer.Duration # Time between each syncronisation attempt + syncInterval: timer.Duration # Time between each synchronization attempt syncRange: timer.Duration # Amount of time in the past to sync relayJitter: Duration # Amount of time since the present to ignore when syncing @@ -114,7 +114,7 @@ proc processRequest( let sendPayload = self.storage.processPayload(recvPayload, hashToSend, hashToRecv) for hash in hashToSend: - await self.needsTx.addLast((conn.peerId, hash)) + await self.remoteNeedsTx.addLast((conn.peerId, hash)) for hash in hashToRecv: await self.wantstx.addLast((conn.peerId, hash)) @@ -258,8 +258,8 @@ proc new*( syncInterval: timer.Duration = DefaultSyncInterval, relayJitter: timer.Duration = DefaultGossipSubJitter, idsRx: AsyncQueue[ID], - wantsTx: AsyncQueue[(PeerId, Fingerprint)], - needsTx: AsyncQueue[(PeerId, Fingerprint)], + localWantsTx: AsyncQueue[(PeerId, Fingerprint)], + remoteNeedsTx: AsyncQueue[(PeerId, Fingerprint)], ): Future[Result[T, string]] {.async.} = let res = await initFillStorage(syncRange, wakuArchive) let storage = @@ -276,8 +276,8 @@ proc new*( syncInterval: syncInterval, relayJitter: relayJitter, idsRx: idsRx, - wantsTx: wantsTx, - needsTx: needsTx, + localWantsTx: localWantsTx, + remoteNeedsTx: remoteNeedsTx, ) let handler = proc(conn: Connection, proto: string) {.async, closure.} =