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

fix: more nph

Browse Source
This commit is contained in:
jm-clius 2025-05-28 18:32:47 +01:00
parent 40a87a7064
commit 403974ec1a
No known key found for this signature in database
GPG Key ID: 5FCD9D5211B952DA
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/reliability.nim
View File

@ -208,10 +208,8 @@ proc unwrapReceivedMessage*(
break break
if depsInBuffer: if depsInBuffer:
rm.incomingBuffer[msg.messageId] = IncomingMessage( rm.incomingBuffer[msg.messageId] =
message: msg, IncomingMessage(message: msg, missingDeps: initHashSet[SdsMessageID]())
missingDeps: initHashSet[SdsMessageID]()
)
else: else:
# All dependencies met, add to history # All dependencies met, add to history
rm.addToHistory(msg.messageId) rm.addToHistory(msg.messageId)
@ -219,10 +217,8 @@ proc unwrapReceivedMessage*(
if not rm.onMessageReady.isNil(): if not rm.onMessageReady.isNil():
rm.onMessageReady(msg.messageId) rm.onMessageReady(msg.messageId)
else: else:
rm.incomingBuffer[msg.messageId] = IncomingMessage( rm.incomingBuffer[msg.messageId] =
message: msg, IncomingMessage(message: msg, missingDeps: missingDeps.toHashSet())
missingDeps: missingDeps.toHashSet()
)
if not rm.onMissingDependencies.isNil(): if not rm.onMissingDependencies.isNil():
rm.onMissingDependencies(msg.messageId, missingDeps) rm.onMissingDependencies(msg.messageId, missingDeps)