Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Peek (0.12 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. 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)
  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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K bytes
    - Viewed (0)
  9. 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