go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-11-24 08:02:32 +02:00
Code Issues Releases Activity

Send solicit message to ControlChannel

Browse Source
This commit is contained in:
Milos Gajdos 2019-09-10 12:11:59 +01:00
parent 195c6a8c90
commit baf4c05663
No known key found for this signature in database
GPG Key ID: 8B31058CC55DFD4F
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
network/default.go
View File

@ -314,6 +314,7 @@ func (n *network) processNetChan(client transport.Client, listener tunnel.Listen
if err := n.sendMsg("solicit", ControlChannel); err != nil {
log.Debugf("Network failed to send solicit message: %s", err)
}
// after adding new peer go to the next step
continue
}
// NOTE: we don't update max topology depth as we dont include this network node
@ -598,7 +599,7 @@ func (n *network) processCtrlChan(client transport.Client, listener tunnel.Liste
}
n.peers[pbRtrAdvert.Id] = advertNode
// send a solicit message when discovering a new node
if err := n.sendMsg("solicit", NetworkChannel); err != nil {
if err := n.sendMsg("solicit", ControlChannel); err != nil {
log.Debugf("Network failed to send solicit message: %s", err)
}
}