- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for bugLogIf (0.04 sec)
-
cmd/metacache.go
if m.bucket == "" || m.id == "" { bugLogIf(ctx, fmt.Errorf("metacache.delete: bucket (%s) or id (%s) empty", m.bucket, m.id)) return } objAPI := newObjectLayerFn() if objAPI == nil { internalLogIf(ctx, errors.New("metacache.delete: no object layer")) return } ez, ok := objAPI.(deleteAllStorager) if !ok {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
cmd/api-headers.go
} // Encodes the response headers into XML format. func encodeResponse(response any) []byte { var buf bytes.Buffer buf.WriteString(xml.Header) if err := xml.NewEncoder(&buf).Encode(response); err != nil { bugLogIf(GlobalContext, err) return nil } return buf.Bytes() } // Use this encodeResponseList() to support control characters // this function must be used by only ListObjects() for objects
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.6K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for { select { case ev := <-localCh: buf.Reset() tmpEvt.Records[0] = ev if err := enc.Encode(tmpEvt); err != nil { bugLogIf(ctx, err, "event: Encode failed") continue } mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...) case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
cmd/background-heal-ops.go
workers := runtime.GOMAXPROCS(0) / 2 if envHealWorkers := env.Get("_MINIO_HEAL_WORKERS", ""); envHealWorkers != "" { if numHealers, err := strconv.Atoi(envHealWorkers); err != nil { bugLogIf(context.Background(), fmt.Errorf("invalid _MINIO_HEAL_WORKERS value: %w", err)) } else { workers = numHealers } } if workers == 0 { workers = 4 } return &healRoutine{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 4.6K bytes - Viewed (0) -
cmd/logging.go
} } func peersLogOnceIf(ctx context.Context, err error, id string, errKind ...any) { if !errors.Is(err, grid.ErrDisconnected) { logger.LogOnceIf(ctx, "peers", err, id, errKind...) } } func bugLogIf(ctx context.Context, err error, errKind ...any) { logger.LogIf(ctx, "internal", err, errKind...) } func healingLogIf(ctx context.Context, err error, errKind ...any) { logger.LogIf(ctx, "healing", err, 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) -
cmd/metacache-bucket.go
func (b *bucketMetacache) deleteAll() { ctx := context.Background() objAPI := newObjectLayerFn() if objAPI == nil { return } ez, ok := objAPI.(deleteAllStorager) if !ok { bugLogIf(ctx, errors.New("bucketMetacache: expected objAPI to be 'deleteAllStorager'")) return } b.mu.Lock() defer b.mu.Unlock() b.updated = true // Delete all.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.6K bytes - Viewed (0)