logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-06-05 13:39:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix logic issue added recently

Browse Source
This commit is contained in:
Ivan FB 2026-05-29 09:06:07 +02:00
parent 41a43174be
commit 95f56e653e
No known key found for this signature in database
GPG Key ID: DF0C67A04C543270
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
channels/reliable_channel.nim
View File

@ -137,7 +137,11 @@ proc pruneCompletedChannelReqs(self: ReliableChannel) =
## segment doesn't trigger a drop on its own — we wait until siblings ## segment doesn't trigger a drop on its own — we wait until siblings
## are also accounted for, so the channel-level outcome is decided ## are also accounted for, so the channel-level outcome is decided
## from a complete picture. ## from a complete picture.
self.pendingMessagingRequests.keepItIf(not it.segmentSendState.isFinal()) var channelsWithPending = initHashSet[RequestId]()
for entry in self.pendingMessagingRequests:
if not entry.segmentSendState.isFinal():
channelsWithPending.incl(entry.channelReqId)
self.pendingMessagingRequests.keepItIf(it.channelReqId in channelsWithPending)
proc onMessageSent(self: ReliableChannel, messagingReqId: RequestId) = proc onMessageSent(self: ReliableChannel, messagingReqId: RequestId) =
## Invoked from this channel's `MessageSentEvent` listener. Flips ## Invoked from this channel's `MessageSentEvent` listener. Flips