Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for Walker (0.17 sec)

  1. internal/bucket/bandwidth/reader.go

    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    	need := len(buf)         // number of bytes requested by caller
    	hdr := r.opts.HeaderSize // remaining header bytes
    	var tokens int           // number of tokens to request
    
    	if hdr > 0 { // available tokens go towards header first
    		if hdr < b { // all of header can be accommodated
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  2. internal/hash/reader.go

    //
    // NewReader may try merge the given size, MD5 and SHA256 values
    // into src - if src is a Reader - to avoid computing the same
    // checksums multiple times.
    // NewReader enforces S3 compatibility strictly by ensuring caller
    // does not send more content than specified size.
    func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.8K bytes
    - Viewed (0)
Back to top