Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for startMRFPersistence (0.14 sec)

  1. cmd/mrf.go

    		err := localDrive.CreateFile(context.Background(), "", minioMetaBucket, pathJoin(healMRFDir, "list.bin"), -1, r)
    		r.Close()
    		if err == nil {
    			break
    		}
    	}
    }
    
    func (m *mrfState) startMRFPersistence() {
    	loadMRF := func(rc io.ReadCloser, opCh chan PartialOperation) error {
    		defer rc.Close()
    		var data [4]byte
    		n, err := rc.Read(data[:])
    		if err != nil {
    			return err
    		}
    		if n != len(data) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top