Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewSkipReader (0.18 sec)

  1. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  2. internal/ioutil/ioutil_test.go

    		{bytes.NewBuffer([]byte("abc")), 2, "c"},
    		{bytes.NewBuffer([]byte("abc")), 3, ""},
    		{bytes.NewBuffer([]byte("abc")), 4, ""},
    	}
    	for i, testCase := range testCases {
    		r := NewSkipReader(testCase.src, testCase.skipLen)
    		b, err := io.ReadAll(r)
    		if err != nil {
    			t.Errorf("Case %d: Unexpected err %v", i, err)
    		}
    		if string(b) != testCase.expected {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 02 11:02:31 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  3. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  4. cmd/object-handlers_test.go

    		cumulativeSum := int64(0)
    		for _, p := range oi.partLengths {
    			readers = append(readers, NewDummyDataGen(p, cumulativeSum))
    			cumulativeSum += p
    		}
    		refReader := io.LimitReader(ioutilx.NewSkipReader(io.MultiReader(readers...), off), length)
    		if ok, msg := cmpReaders(refReader, rec.Body); !ok {
    			t.Fatalf("(%s) Object: %s Case %d ByteRange: %s --> data mismatch! (msg: %s)", instanceType, oi.objectName, i+1, byteRange, msg)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top