Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Seek (0.2 sec)

  1. cmd/dummy-data-generator_test.go

    		d.idx += int64(w)
    		n += w
    	}
    	if d.idx >= d.length {
    		extraBytes := d.idx - d.length
    		n -= int(extraBytes)
    		if n < 0 {
    			n = 0
    		}
    		err = io.EOF
    	}
    	return
    }
    
    func (d *DummyDataGen) Seek(offset int64, whence int) (int64, error) {
    	switch whence {
    	case io.SeekStart:
    		if offset < 0 {
    			return 0, errors.New("Invalid offset")
    		}
    		d.idx = offset
    	case io.SeekCurrent:
    		if d.idx+offset < 0 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  2. internal/ioutil/ioutil_test.go

    	if !errors.Is(err, io.ErrUnexpectedEOF) {
    		t.Errorf("Expected io.ErrUnexpectedEOF, but got %v", err)
    	}
    	if written != 5 {
    		t.Errorf("Expected written to be '5', but got %v", written)
    	}
    
    	f.Seek(0, io.SeekStart)
    	r.Seek(0, io.SeekStart)
    
    	written, err = CopyAligned(f, r, *bufp, r.Size(), f)
    	if !errors.Is(err, nil) {
    		t.Errorf("Expected nil, but got %v", err)
    	}
    	if written != r.Size() {
    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. internal/config/policy/plugin/config.go

    	type opaResult struct {
    		Result bool `json:"result"`
    	}
    
    	respBody := bytes.NewReader(opaRespBytes)
    
    	var result opaResult
    	if err = json.NewDecoder(respBody).Decode(&result); err != nil {
    		respBody.Seek(0, 0)
    		var resultAllow opaResultAllow
    		if err = json.NewDecoder(respBody).Decode(&resultAllow); err != nil {
    			return false, err
    		}
    		return resultAllow.Result.Allow, nil
    	}
    
    	return result.Result, nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.8K bytes
    - Viewed (0)
  4. docs/LICENSE

              violation; or
    
           2. upon express reinstatement by the Licensor.
    
         For the avoidance of doubt, this Section 6(b) does not affect any
         right the Licensor may have to seek remedies for Your violations
         of this Public License.
    
      c. For the avoidance of doubt, the Licensor may also offer the
         Licensed Material under separate terms or conditions or stop
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Viewed (0)
  5. cmd/veeam-sos-api.go

    	r := bytes.NewReader(buf)
    
    	off, length := int64(0), r.Size()
    	if rs != nil {
    		off, length, err = rs.GetOffsetLength(r.Size())
    		if err != nil {
    			return nil, err
    		}
    	}
    	r.Seek(off, io.SeekStart)
    
    	return NewGetObjectReaderFromReader(io.LimitReader(r, length), ObjectInfo{
    		Bucket:      bucket,
    		Name:        object,
    		Size:        r.Size(),
    		IsLatest:    true,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 18:43:58 GMT 2024
    - 8.2K bytes
    - Viewed (2)
  6. cmd/ftp-server-driver.go

    	if err != nil {
    		return 0, nil, err
    	}
    	defer func() {
    		if err != nil && obj != nil {
    			obj.Close()
    		}
    	}()
    
    	_, err = obj.Seek(offset, io.SeekStart)
    	if err != nil {
    		return 0, nil, err
    	}
    
    	info, err := obj.Stat()
    	if err != nil {
    		return 0, nil, err
    	}
    
    	return info.Size - offset, obj, nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  7. internal/s3select/select.go

    	return &ObjectReadSeekCloser{
    		segmentReader: segmentReader,
    		size:          actualSize,
    		offset:        0,
    		reader:        nil,
    	}
    }
    
    // Seek call to implement io.Seeker
    func (rsc *ObjectReadSeekCloser) Seek(offset int64, whence int) (int64, error) {
    	// fmt.Printf("actual: %v offset: %v (%v) whence: %v\n", rsc.size, offset, rsc.offset, whence)
    	switch whence {
    	case io.SeekStart:
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  8. internal/event/config_test.go

    		{reader4, "us-east-1", targetList1, true},
    		{reader3, "", targetList2, false},
    		{reader2, "us-east-1", targetList2, false},
    	}
    
    	for i, testCase := range testCases {
    		if _, err := testCase.reader.Seek(0, 0); err != nil {
    			panic(err)
    		}
    		_, err := ParseConfig(testCase.reader, testCase.region, testCase.targetList)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K bytes
    - Viewed (0)
  9. internal/config/policy/opa/config.go

    	type opaResult struct {
    		Result bool `json:"result"`
    	}
    
    	respBody := bytes.NewReader(opaRespBytes)
    
    	var result opaResult
    	if err = json.NewDecoder(respBody).Decode(&result); err != nil {
    		respBody.Seek(0, 0)
    		var resultAllow opaResultAllow
    		if err = json.NewDecoder(respBody).Decode(&resultAllow); err != nil {
    			return false, err
    		}
    		return resultAllow.Result.Allow, nil
    	}
    
    	return result.Result, nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.2K bytes
    - Viewed (1)
  10. cmd/test-utils_test.go

    	req.Header.Set("x-amz-decoded-content-length", strconv.FormatInt(dataLength, 10))
    	req.Header.Set("content-length", strconv.FormatInt(contentLength, 10))
    
    	// Seek back to beginning.
    	body.Seek(0, 0)
    
    	// Add body
    	req.Body = io.NopCloser(body)
    	req.ContentLength = contentLength
    
    	return req, nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
Back to top