- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for peersLogOnceIf (0.23 sec)
-
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) -
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) -
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) -
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)