logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-01-02 14:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: avoid blocking nodes when channels are full

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-08 12:35:47 +03:00
parent e8588762f4
commit 7e60e972c5
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
waku/nwaku.go
View File

@ -484,7 +484,11 @@ func (n *WakuNode) parseMessageEvent(eventStr string) {
if err != nil {
Error("could not parse message %v", err)
}
n.MsgChan <- *envelope
select {
case n.MsgChan <- *envelope:
default:
Warn("Can't deliver message to subscription, MsgChan is full")
}
}
func (n *WakuNode) parseTopicHealthChangeEvent(eventStr string) {
@ -494,7 +498,12 @@ func (n *WakuNode) parseTopicHealthChangeEvent(eventStr string) {
if err != nil {
Error("could not parse topic health change %v", err)
}
n.TopicHealthChan <- topicHealth
select {
case n.TopicHealthChan <- topicHealth:
default:
Warn("Can't deliver topic health event, TopicHealthChan is full")
}
}
func (n *WakuNode) parseConnectionChangeEvent(eventStr string) {
@ -504,7 +513,12 @@ func (n *WakuNode) parseConnectionChangeEvent(eventStr string) {
if err != nil {
Error("could not parse connection change %v", err)
}
n.ConnectionChangeChan <- connectionChange
select {
case n.ConnectionChangeChan <- connectionChange:
default:
Warn("Can't deliver connection change event, ConnectionChangeChan is full")
}
}
func (n *WakuNode) GetNumConnectedRelayPeers(optPubsubTopic ...string) (int, error) {