Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for peersLogOnceIf (0.34 sec)

  1. cmd/notification.go

    			if sys.peerClients[index] != nil {
    				reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress",
    					sys.peerClients[index].host.String())
    				peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), err, sys.peerClients[index].host.String())
    			} else {
    				peersLogOnceIf(ctx, err, "peer-offline")
    			}
    			continue
    		}
    		wg.Add(1)
    		go func(ctx context.Context, peerChannel <-chan MetricV2, wg *sync.WaitGroup) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  2. cmd/logging.go

    	}
    }
    
    func peersLogAlwaysIf(ctx context.Context, err error, errKind ...any) {
    	if !errors.Is(err, grid.ErrDisconnected) {
    		logger.LogAlwaysIf(ctx, "peers", err, errKind...)
    	}
    }
    
    func peersLogOnceIf(ctx context.Context, err error, id string, errKind ...any) {
    	if !errors.Is(err, grid.ErrDisconnected) {
    		logger.LogOnceIf(ctx, "peers", err, id, errKind...)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.8K bytes
    - Viewed (0)
Back to top