Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for bugLogIf (0.1 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 16:23:16 GMT 2024
    - 6K bytes
    - Click Count (0)
  2. 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
    			}
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
  3. 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...)
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  4. 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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.6K bytes
    - Click Count (0)
Back to Top