X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=core%2Fconnection.go;fp=core%2Fconnection.go;h=605e1efa7170d458c8f3deac3027c18008d25af8;hb=4dca07c803308611275f78b490ac0352c1052fe2;hp=02f980a7cf5c752e764c44e9345dbe2bc4eb6f41;hpb=b1006dced4cc0c23d9dc754e97d89500aeb55170;p=govpp.git diff --git a/core/connection.go b/core/connection.go index 02f980a..605e1ef 100644 --- a/core/connection.go +++ b/core/connection.go @@ -30,8 +30,8 @@ import ( ) const ( - DefaultReconnectInterval = time.Second // default interval between reconnect attempts - DefaultMaxReconnectAttempts = 3 // default maximum number of reconnect attempts + DefaultReconnectInterval = time.Second / 2 // default interval between reconnect attempts + DefaultMaxReconnectAttempts = 3 // default maximum number of reconnect attempts ) var ( @@ -255,7 +255,7 @@ func (c *Connection) releaseAPIChannel(ch *Channel) { // connectLoop attempts to connect to VPP until it succeeds. // Then it continues with healthCheckLoop. func (c *Connection) connectLoop(connChan chan ConnectionEvent) { - reconnectAttempts := 0 + var reconnectAttempts int // loop until connected for { @@ -268,7 +268,7 @@ func (c *Connection) connectLoop(connChan chan ConnectionEvent) { break } else if reconnectAttempts < c.maxAttempts { reconnectAttempts++ - log.Errorf("connecting failed (attempt %d/%d): %v", reconnectAttempts, c.maxAttempts, err) + log.Warnf("connecting failed (attempt %d/%d): %v", reconnectAttempts, c.maxAttempts, err) time.Sleep(c.recInterval) } else { connChan <- ConnectionEvent{Timestamp: time.Now(), State: Failed, Error: err}