Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for closeBitrotWriters (0.06 sec)

  1. cmd/bitrot.go

    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    			if br, ok := r.(io.Closer); ok {
    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) []error {
    	errs := make([]error, len(ws))
    	for i, w := range ws {
    		if w == nil {
    			errs[i] = errDiskNotFound
    			continue
    		}
    		if bw, ok := w.(io.Closer); ok {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    			// part to .minio/tmp/uuid/ which needs to be renamed
    			// later to the final location.
    			err = erasure.Heal(ctx, writers, readers, partSize, prefer)
    			closeBitrotReaders(readers)
    			closeErrs := closeBitrotWriters(writers)
    			if err != nil {
    				return result, err
    			}
    
    			// outDatedDisks that had write errors should not be
    			// written to for remaining parts, so we nil it out.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeErrs := closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    		if err == nil {
    			toEncode = ra
    			defer ra.Close()
    		}
    	}
    
    	n, err := erasure.Encode(ctx, toEncode, writers, buffer, writeQuorum)
    	closeErrs := closeBitrotWriters(writers)
    	if err != nil {
    		return pi, toObjectErr(err, bucket, object)
    	}
    	if closeErr := reduceWriteQuorumErrs(ctx, closeErrs, objectOpIgnoredErrs, writeQuorum); closeErr != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
Back to top