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 (#63)

Browse Source
This commit is contained in:
gabrielmer 2025-04-08 17:02:37 +03:00 committed by GitHub
parent 8193867e44
commit 6d7387e88e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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 { if err != nil {
Error("could not parse message %v", err) 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) { func (n *WakuNode) parseTopicHealthChangeEvent(eventStr string) {
@ -494,7 +498,12 @@ func (n *WakuNode) parseTopicHealthChangeEvent(eventStr string) {
if err != nil { if err != nil {
Error("could not parse topic health change %v", err) 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) { func (n *WakuNode) parseConnectionChangeEvent(eventStr string) {
@ -504,7 +513,12 @@ func (n *WakuNode) parseConnectionChangeEvent(eventStr string) {
if err != nil { if err != nil {
Error("could not parse connection change %v", err) 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) { func (n *WakuNode) GetNumConnectedRelayPeers(optPubsubTopic ...string) (int, error) {