Skip to content
Snippets Groups Projects
Commit a8c53294 authored by Martin Stiemerling's avatar Martin Stiemerling :speech_balloon:
Browse files

changed enum names

parent 19c921f3
No related branches found
No related tags found
1 merge request!9First working draft version
...@@ -15,10 +15,10 @@ import ( ...@@ -15,10 +15,10 @@ import (
type KmsPeerStatus int16 type KmsPeerStatus int16
const ( const (
kmsPeerUp KmsPeerStatus = iota // peer was seen up lately KmsPeerUp KmsPeerStatus = iota // peer was seen up lately
kmsPeerDown // peer not reachable anymore KmsPeerDown // peer not reachable anymore
kmsPeerPending // peer was added and has to be succesfully contacted once KmsPeerPending // peer was added and has to be succesfully contacted once
kmsPeerUnknown // not known, not initialized KmsPeerUnknown // not known, not initialized
) )
type kmsPeerInfo interface { type kmsPeerInfo interface {
...@@ -68,7 +68,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { ...@@ -68,7 +68,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) {
r, err := c.ETSICapabilities(ctx, &pb.ETSICapabilitiesRequest{MyKmsName: kmsName}) r, err := c.ETSICapabilities(ctx, &pb.ETSICapabilitiesRequest{MyKmsName: kmsName})
if err != nil { if err != nil {
log.Printf("could not greet: %v", err) log.Printf("could not greet: %v", err)
ph.peerStatus = kmsPeerDown ph.peerStatus = KmsPeerDown
// Send notification about change // Send notification about change
if ph.externalNotifierKMSPeer != nil { if ph.externalNotifierKMSPeer != nil {
ph.externalNotifierKMSPeer <- ph.tcpSocketStr ph.externalNotifierKMSPeer <- ph.tcpSocketStr
...@@ -76,7 +76,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { ...@@ -76,7 +76,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) {
return return
} }
// Works and peer moves to kmsPeerUp // Works and peer moves to kmsPeerUp
ph.peerStatus = kmsPeerUp ph.peerStatus = KmsPeerUp
// Send notification about change // Send notification about change
if ph.externalNotifierKMSPeer != nil { if ph.externalNotifierKMSPeer != nil {
...@@ -94,7 +94,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) { ...@@ -94,7 +94,7 @@ func (ph *kmsPeer) PeerHandler(kmsName string) {
_, err := c.ETSICapabilities(ctx, &pb.ETSICapabilitiesRequest{MyKmsName: kmsName}) _, err := c.ETSICapabilities(ctx, &pb.ETSICapabilitiesRequest{MyKmsName: kmsName})
if err != nil { if err != nil {
log.Printf("could not greet: %v", err) log.Printf("could not greet: %v", err)
ph.peerStatus = kmsPeerDown ph.peerStatus = KmsPeerDown
// Send notification about change // Send notification about change
if ph.externalNotifierKMSPeer != nil { if ph.externalNotifierKMSPeer != nil {
ph.externalNotifierKMSPeer <- ph.tcpSocketStr ph.externalNotifierKMSPeer <- ph.tcpSocketStr
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment