Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for offlineLink (0.1 sec)

  1. cmd/erasure-encode_test.go

    	for i := 0; i < dataDown; i++ {
    		disks[i] = OfflineDisk
    	}
    	for i := data; i < data+parityDown; i++ {
    		disks[i] = OfflineDisk
    	}
    
    	b.ResetTimer()
    	b.SetBytes(size)
    	b.ReportAllocs()
    	for i := 0; i < b.N; i++ {
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/erasure.go

    // list all errors that can be ignored in a bucket metadata operation.
    var bucketMetadataOpIgnoredErrs = append(bucketOpIgnoredErrs, errVolumeNotFound)
    
    // OfflineDisk represents an unavailable disk.
    var OfflineDisk StorageAPI // zero value is nil
    
    // erasureObjects - Implements ER object layer.
    type erasureObjects struct {
    	setDriveCount      int
    	defaultParityCount int
    
    	setIndex  int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. cmd/erasure-decode_test.go

    			}
    		}
    
    		for i, r := range bitrotReaders {
    			if r == nil {
    				disks[i] = OfflineDisk
    			}
    		}
    		if err == nil && !test.shouldFail {
    			bitrotReaders = make([]io.ReaderAt, len(disks))
    			for index, disk := range disks {
    				if disk == OfflineDisk {
    					continue
    				}
    				tillOffset := erasure.ShardFileOffset(test.offset, test.length, test.data)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  4. cmd/erasure-healing.go

    			readers := make([]io.ReaderAt, len(latestDisks))
    			prefer := make([]bool, len(latestDisks))
    			checksumAlgo := erasureInfo.GetChecksumInfo(partNumber).Algorithm
    			for i, disk := range latestDisks {
    				if disk == OfflineDisk {
    					continue
    				}
    				checksumInfo := copyPartsMetadata[i].Erasure.GetChecksumInfo(partNumber)
    				partPath := pathJoin(object, srcDataDir, fmt.Sprintf("part.%d", partNumber))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. cmd/erasure-healing-common.go

    	}
    
    	metaErrs := make([]error, len(errs))
    
    	for i, onlineDisk := range onlineDisks {
    		if errs[i] != nil {
    			metaErrs[i] = errs[i]
    			continue
    		}
    		if onlineDisk == OfflineDisk {
    			metaErrs[i] = errDiskNotFound
    			continue
    		}
    
    		meta := partsMetadata[i]
    		corrupted := false
    		if filterByETag {
    			corrupted = meta.Metadata["etag"] != latestMeta.Metadata["etag"]
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    	s.erasureDisksMu.RLock()
    	defer s.erasureDisksMu.RUnlock()
    
    	for i := 0; i < s.setCount; i++ {
    		for j := 0; j < s.setDriveCount; j++ {
    			disk := s.erasureDisks[i][j]
    			if disk == OfflineDisk {
    				continue
    			}
    			if !disk.IsOnline() {
    				continue
    			}
    			diskMap[disk.Endpoint()] = disk
    		}
    	}
    	return diskMap
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top