Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for healingLogEvent (0.08 sec)

  1. cmd/mrf.go

    // the current heal status in one available disk
    func (m *mrfState) shutdown() {
    	atomic.StoreInt32(&m.closing, 1)
    	m.wg.Wait()
    	close(m.opCh)
    	atomic.StoreInt32(&m.closed, 1)
    
    	if len(m.opCh) > 0 {
    		healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh))
    	}
    
    	newReader := func() io.ReadCloser {
    		r, w := io.Pipe()
    		go func() {
    			// Initialize MRF meta header.
    			var data [4]byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/logging.go

    	logger.LogIf(ctx, "internal", err, errKind...)
    }
    
    func healingLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "healing", err, errKind...)
    }
    
    func healingLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "healing", msg, args...)
    }
    
    func healingLogOnceIf(ctx context.Context, err error, errKind ...interface{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top