Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for newBitrotReader (0.44 sec)

  1. cmd/bitrot_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = writer.Write([]byte("aaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	if bw, ok := writer.(io.Closer); ok {
    		bw.Close()
    	}
    
    	reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10)
    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 10); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  2. cmd/erasure-decode_test.go

    		for index, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			tillOffset := erasure.ShardFileOffset(test.offset, test.length, test.data)
    
    			bitrotReaders[index] = newBitrotReader(disk, nil, "testbucket", "object", tillOffset, writeAlgorithm, bitrotWriterSum(writers[index]), erasure.ShardSize())
    		}
    
    		writer := bytes.NewBuffer(nil)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  3. cmd/erasure-heal_test.go

    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    		// setup stale disks for the test case
    		staleDisks := make([]StorageAPI, len(disks))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  4. cmd/bitrot.go

    	if algo == HighwayHash256S {
    		return newStreamingBitrotWriter(disk, origvolume, volume, filePath, length, algo, shardSize)
    	}
    	return newWholeBitrotWriter(disk, volume, filePath, algo, shardSize)
    }
    
    func newBitrotReader(disk StorageAPI, data []byte, bucket string, filePath string, tillOffset int64, algo BitrotAlgorithm, sum []byte, shardSize int64) io.ReaderAt {
    	if algo == HighwayHash256S {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    		partsMetadata[i] = cleanFileInfo(latestMeta)
    	}
    
    	// source data dir shall be empty in case of XLV1
    	// differentiate it with dstDataDir for readability
    	// srcDataDir is the one used with newBitrotReader()
    	// to read existing content.
    	srcDataDir := latestMeta.DataDir
    	dstDataDir := latestMeta.DataDir
    	if latestMeta.XLV1 {
    		dstDataDir = migrateDataDir
    	}
    
    	var inlineBuffers []*bytes.Buffer
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    				continue
    			}
    			checksumInfo := metaArr[index].Erasure.GetChecksumInfo(partNumber)
    			partPath := pathJoin(object, metaArr[index].DataDir, fmt.Sprintf("part.%d", partNumber))
    			readers[index] = newBitrotReader(disk, metaArr[index].Data, bucket, partPath, tillOffset,
    				checksumInfo.Algorithm, checksumInfo.Hash, erasure.ShardSize())
    
    			// Prefer local disks
    			prefer[index] = disk.Hostname() == ""
    		}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
Back to top