Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for StoreUint32 (0.04 sec)

  1. cmd/mrf.go

    	default:
    	}
    }
    
    // Do not accept new MRF operations anymore and start to save
    // 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    			n, err := rr.ReadAt(p.buf[bufIdx], p.offset)
    			if err != nil {
    				switch {
    				case errors.Is(err, errFileNotFound):
    					atomic.StoreInt32(&missingPartsHeal, 1)
    				case errors.Is(err, errFileCorrupt):
    					atomic.StoreInt32(&bitrotHeal, 1)
    				case errors.Is(err, errDiskNotFound):
    					atomic.AddInt32(&disksNotFound, 1)
    				}
    
    				// This will be communicated upstream.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top