Fixing typos and logging

Author: hurricanehrndz

client/internal/dns/upstream.go

@@ -92,15 +92,15 @@ func (u *upstreamResolverBase) watchPeersConnStatusChanges() {
 
 		u.probeAvailability()
 		if u.disabled {
-			return fmt.Errorf("probe faled")
+			return fmt.Errorf("probe failed")
 		}
 		return nil
 	}
 
 	continualProbe := func() {
 		// probe continually for 30s when peer count >= 1
 		if u.statusRecorder.GetConnectedPeersCount() == 0 {
-			log.Debug("O peer connected, running one more DNS probe")
+			log.Debug("O peers connected, running one more DNS probe")
 			// cancel backoff operation
 			if cancelBackOff != nil {
 				cancelBackOff()
@@ -111,13 +111,13 @@ func (u *upstreamResolverBase) watchPeersConnStatusChanges() {
 		}
 
 		if probeRunning.Load() {
-			log.Info("restarting DNS probing")
+			log.Info("restart DNS probing")
 			cancelBackOff()
 			cancelBackOff = nil
 		}
 		defer func() {
 			u.mutex.Lock()
-			log.Infof("DNS probing finished, servers %s disabled: %t", u.upstreamServers, u.disabled)
+			log.Infof("DNS probe finished, servers %s disabled: %t", u.upstreamServers, u.disabled)
 			u.mutex.Unlock()
 			probeRunning.Store(false)
 		}()
@@ -128,7 +128,6 @@ func (u *upstreamResolverBase) watchPeersConnStatusChanges() {
 		err := backoff.Retry(func() error {
 			select {
 			case <-ctx.Done():
-				log.Warn("DNS probing cancelled")
 				return backoff.Permanent(ctx.Err())
 			default:
 				return operation()
@@ -317,7 +316,8 @@ func (u *upstreamResolverBase) waitUntilResponse() {
 	err := backoff.Retry(func() error {
 		u.probeAvailability()
 		if u.disabled {
-			return fmt.Errorf("failed to enable upsstream")
+			log.Tracef("checking connectivity with upstreams %s failed. Retrying in %s", u.upstreamServers, exponentialBackOff.NextBackOff())
+			return fmt.Errorf("upstream check call error")
 		}
 		return nil
 	}, exponentialBackOff)