Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for waiters (0.68 sec)

  1. cmd/erasure-object.go

    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    	writers := make([]io.Writer, len(onlineDisks))
    	for i, disk := range onlineDisks {
    		if disk == nil {
    			continue
    		}
    		writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, tmpPartPath, erasure.ShardFileSize(data.Size()), DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    // tests are adjusted to use GetObjectNInfo this function can be removed.
    func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) {
    	var header http.Header
    	if etag != "" {
    		header.Set("ETag", etag)
    	}
    	Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    		return
    	}
    
    	// Set Parts Count Header
    	if opts.PartNumber > 0 && len(objInfo.Parts) > 0 {
    		setPartsCountHeaders(w, objInfo)
    	}
    
    	setHeadGetRespHeaders(w, r.Form)
    
    	var iw io.Writer = w
    
    	statusCodeWritten := false
    	httpWriter := xioutil.WriteOnClose(iw)
    	if rs != nil || opts.PartNumber > 0 {
    		statusCodeWritten = true
    		w.WriteHeader(http.StatusPartialContent)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top