Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for StoreUint32 (0.06 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)
  3. api/go1.txt

    pkg sync/atomic, func LoadUint64(*uint64) uint64
    pkg sync/atomic, func LoadUintptr(*uintptr) uintptr
    pkg sync/atomic, func StoreInt32(*int32, int32)
    pkg sync/atomic, func StoreInt64(*int64, int64)
    pkg sync/atomic, func StorePointer(*unsafe.Pointer, unsafe.Pointer)
    pkg sync/atomic, func StoreUint32(*uint32, uint32)
    pkg sync/atomic, func StoreUint64(*uint64, uint64)
    pkg sync/atomic, func StoreUintptr(*uintptr, uintptr)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top