diff --git a/kms/kmspeers.go b/kms/kmspeers.go index dbe077501a311f9cdd87ee95ec8e83a9b7e641c2..67d2bdb61f4a33d33ee9aecc25230e1583758041 100644 --- a/kms/kmspeers.go +++ b/kms/kmspeers.go @@ -69,6 +69,10 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { if err != nil { log.Printf("could not greet: %v", err) ph.peerStatus = kmsPeerDown + // Send notification about change + if ph.externalNotifierKMSPeer != nil { + ph.externalNotifierKMSPeer <- ph.tcpSocketStr + } return } // Works and peer moves to kmsPeerUp