Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/object-api-utils.go

    				if err != nil {
    					// Call the cleanup funcs
    					for i := len(cFns) - 1; i >= 0; i-- {
    						cFns[i]()
    					}
    					return nil, err
    				}
    				if decryptSkip > 0 {
    					inputReader = ioutil.NewSkipReader(inputReader, decryptSkip)
    				}
    				oi.Size = decLength
    			}
    			// Decompression reader.
    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  2. internal/ioutil/ioutil.go

    			l = s.skipCount
    		}
    		n, err := s.Reader.Read(p[:l])
    		if err != nil {
    			return 0, err
    		}
    		s.skipCount -= int64(n)
    	}
    	return s.Reader.Read(p)
    }
    
    // NewSkipReader - creates a SkipReader
    func NewSkipReader(r io.Reader, n int64) io.Reader {
    	return &SkipReader{r, n}
    }
    
    var copyBufPool = sync.Pool{
    	New: func() interface{} {
    		b := make([]byte, 32*1024)
    		return &b
    	},
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
Back to top