Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for HardLimitReader (0.12 sec)

  1. internal/ioutil/hardlimitreader.go

    // by the standard library.
    package ioutil
    
    import (
    	"errors"
    	"io"
    )
    
    // ErrOverread is returned to the reader when the hard limit of HardLimitReader is exceeded.
    var ErrOverread = errors.New("input provided more bytes than specified")
    
    // HardLimitReader returns a Reader that reads from r
    // but returns an error if the source provides more data than allowed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. internal/hash/reader.go

    		r.checksum = MD5
    		r.contentSHA256 = SHA256
    		if r.size < 0 && size >= 0 {
    			r.src = etag.Wrap(ioutil.HardLimitReader(r.src, size), r.src)
    			r.size = size
    		}
    		if r.actualSize <= 0 && actualSize >= 0 {
    			r.actualSize = actualSize
    		}
    		return r, nil
    	}
    
    	if size >= 0 {
    		r := ioutil.HardLimitReader(src, size)
    		if !disableMD5 {
    			if _, ok := src.(etag.Tagger); !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    	ctx := r.Context()
    
    	objectAPI, creds := validateAdminReq(ctx, w, r, policy.StartBatchJobAction)
    	if objectAPI == nil {
    		return
    	}
    
    	buf, err := io.ReadAll(ioutil.HardLimitReader(r.Body, humanize.MiByte*4))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	user := creds.AccessKey
    	if creds.ParentUser != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    			bytebufferpool.Put(buf)
    		}()
    
    		md5w := md5.New()
    
    		// Maximum allowed fan-out object size.
    		const maxFanOutSize = 16 << 20
    
    		n, err := io.Copy(io.MultiWriter(buf, md5w), ioutil.HardLimitReader(pReader, maxFanOutSize))
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    
    		// Set the correct hex md5sum for the fan-out stream.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
Back to top