logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-05 07:23:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: waku sync timing (#3337)

Browse Source
This commit is contained in:
Simon-Pierre Vivier 2025-03-24 08:36:19 -04:00 committed by GitHub
parent 0369679704
commit dc571d0101
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
waku/node/waku_node.nim
View File

@ -214,9 +214,9 @@ proc mountStoreSync*(
storeSyncInterval = 300,
storeSyncRelayJitter = 20,
): Future[Result[void, string]] {.async.} =
let idsChannel = newAsyncQueue[SyncID](100)
let wantsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](100)
let needsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](100)
let idsChannel = newAsyncQueue[SyncID](0)
let wantsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](0)
let needsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](0)
var cluster: uint16
var shards: seq[uint16]

4
waku/waku_store_sync/reconciliation.nim
View File

@ -135,10 +135,10 @@ proc processRequest(
sendPayload.shards = self.shards.toSeq()
for hash in hashToSend:
await self.remoteNeedsTx.addLast((conn.peerId, hash))
self.remoteNeedsTx.addLastNoWait((conn.peerId, hash))
for hash in hashToRecv:
await self.localWantstx.addLast((conn.peerId, hash))
self.localWantsTx.addLastNoWait((conn.peerId, hash))
rawPayload = sendPayload.deltaEncode()