Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Peek (0.18 sec)

  1. cmd/metacache-stream_test.go

    		}
    		if gotObj.name != want {
    			t.Errorf("entry %d, want %q, got %q", i, want, gotObj.name)
    		}
    	}
    }
    
    func Test_metacacheReader_peek(t *testing.T) {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	for i, want := range loadMetacacheSampleNames {
    		got, err := r.peek()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			t.Fatal(err)
    		}
    		if got.name != want {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  3. cmd/metacache-stream.go

    	if r.creator == nil || r.err != nil {
    		return
    	}
    	r.err = r.creator()
    	r.creator = nil
    }
    
    // peek will return the name of the next object.
    // Will return io.EOF if there are no more objects.
    // Should be used sparingly.
    func (r *metacacheReader) peek() (metaCacheEntry, error) {
    	r.checkInit()
    	if r.err != nil {
    		return metaCacheEntry{}, r.err
    	}
    	if r.current.name != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  4. cmd/s3-zip-handlers.go

    	archiveTypeMetadataKey = ReservedMetadataPrefixLower + "archive-type" // "x-minio-internal-archive-type"
    	archiveInfoMetadataKey = ReservedMetadataPrefixLower + "archive-info" // "x-minio-internal-archive-info"
    
    	// Peek into a zip archive
    	xMinIOExtract = "x-minio-extract"
    )
    
    // splitZipExtensionPath splits the S3 path to the zip file and the path inside the zip:
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  5. cmd/erasure-metadata.go

    	if offset == 0 {
    		// Special case - if offset is 0, then partIndex and partOffset are always 0.
    		return 0, 0, nil
    	}
    	partOffset = offset
    	// Seek until object offset maps to a particular part offset.
    	for i, part := range fi.Parts {
    		partIndex = i
    		// Offset is smaller than size we have reached the proper part offset.
    		if partOffset < part.Size {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  6. cmd/metacache-set.go

    		}
    		if contextCanceled(ctx) {
    			return ctx.Err()
    		}
    		for i, r := range readers {
    			if errs[i] != nil {
    				hasErr++
    				continue
    			}
    			entry, err := r.peek()
    			switch err {
    			case io.EOF:
    				atEOF++
    				continue
    			case nil:
    			default:
    				switch err.Error() {
    				case errFileNotFound.Error():
    					atEOF++
    					fnf++
    					continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  7. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Viewed (0)
  8. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  9. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K bytes
    - Viewed (0)
  10. cmd/server-main.go

    		for _, list := range cfV1.Pools {
    			pools = append(pools, poolArgs{
    				args:          list,
    				setDriveCount: setDriveCount,
    			})
    		}
    	case "v2":
    		cf := config.ServerConfig{}
    		cfReader.Seek(0, io.SeekStart)
    		if err = yaml.Unmarshal(rd, &cf); err != nil {
    			return err
    		}
    
    		pools = make([]poolArgs, 0, len(cf.Pools))
    		for _, list := range cf.Pools {
    			driveCount := list.SetDriveCount
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
Back to top