|
@@ -129,7 +129,7 @@ func SetupMQTT(fatal bool) {
|
|
|
|
|
|
|
|
// Keepalive -- periodically pings all nodes to let them know server is still alive and doing well
|
|
// Keepalive -- periodically pings all nodes to let them know server is still alive and doing well
|
|
|
func Keepalive(ctx context.Context) {
|
|
func Keepalive(ctx context.Context) {
|
|
|
- go PublishPeerUpdate(false)
|
|
|
|
|
|
|
+ go PublishPeerUpdate(true)
|
|
|
for {
|
|
for {
|
|
|
select {
|
|
select {
|
|
|
case <-ctx.Done():
|
|
case <-ctx.Done():
|
abhishek9686