Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for peersLogOnceIf (0.23 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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  2. cmd/admin-server-info.go

    				if err := isServerResolvable(endpoint, 5*time.Second); err == nil {
    					network[nodeName] = string(madmin.ItemOnline)
    				} else {
    					network[nodeName] = string(madmin.ItemOffline)
    					// log once the error
    					peersLogOnceIf(context.Background(), err, nodeName)
    				}
    			}
    		}
    	}
    
    	var memstats runtime.MemStats
    	runtime.ReadMemStats(&memstats)
    
    	gcStats := debug.GCStats{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  3. cmd/logging.go

    	logger.LogIf(ctx, "peers", err, errKind...)
    }
    
    func peersLogAlwaysIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogAlwaysIf(ctx, "peers", err, errKind...)
    }
    
    func peersLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, "peers", err, id, errKind...)
    }
    
    func bugLogIf(ctx context.Context, err error, errKind ...interface{}) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 6.6K bytes
    - Viewed (0)
  4. cmd/peer-rest-server.go

    	for {
    		select {
    		case <-ctx.Done():
    			grid.PutByteBuffer(buf.Bytes())
    			return nil
    		case ev := <-ch:
    			buf.Reset()
    			tmpEvt.Records[0] = ev
    			if err := enc.Encode(tmpEvt); err != nil {
    				peersLogOnceIf(ctx, err, "event: Encode failed")
    				continue
    			}
    			out <- grid.NewBytesWithCopyOf(buf.Bytes())
    		}
    	}
    }
    
    // TraceHandler sends http trace messages back to peer rest client
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
Back to top