Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for askDisks (0.25 sec)

  1. cmd/metacache-set_gen.go

    				return
    			}
    		case "Limit":
    			z.Limit, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Limit")
    				return
    			}
    		case "AskDisks":
    			z.AskDisks, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "AskDisks")
    				return
    			}
    		case "InclDeleted":
    			z.InclDeleted, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "InclDeleted")
    				return
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:23:12 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  2. cmd/metacache-bucket_test.go

    		bm.findCache(listPathOptions{
    			ID:           mustGetUUID(),
    			Bucket:       "",
    			BaseDir:      pathNames[i%paths],
    			Prefix:       "",
    			FilterPrefix: "",
    			Marker:       "",
    			Limit:        0,
    			AskDisks:     "strict",
    			Recursive:    false,
    			Separator:    slashSeparator,
    			Create:       true,
    		})
    	}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bm.findCache(listPathOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 25 23:29:45 GMT 2022
    - 1.8K bytes
    - Viewed (0)
  3. cmd/object-api-interface_gen.go

    			z.LatestOnly, bts, err = msgp.ReadBoolBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "LatestOnly")
    				return
    			}
    		case "AskDisks":
    			z.AskDisks, bts, err = msgp.ReadStringBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "AskDisks")
    				return
    			}
    		case "VersionsSort":
    			{
    				var zb0002 uint8
    				zb0002, bts, err = msgp.ReadUint8Bytes(bts)
    				if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    	disks, infos, _ := er.getOnlineDisksWithHealingAndInfo(true)
    	askDisks := getListQuorum(o.AskDisks, er.setDriveCount)
    	if askDisks == -1 {
    		newDisks := getQuorumDisks(disks, infos, (len(disks)+1)/2)
    		if newDisks != nil {
    			// If we found disks signature in quorum, we proceed to list
    			// from a single drive, shuffling of the drives is subsequently.
    			disks = newDisks
    			askDisks = 1
    		} else {
    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)
  5. cmd/erasure-server-pool.go

    						askDisks = getListQuorum("strict", set.setDriveCount)
    					}
    				}
    
    				// Special case: ask all disks if the drive count is 4
    				if set.setDriveCount == 4 || askDisks > len(disks) {
    					askDisks = len(disks) // use all available drives
    				}
    
    				var fallbackDisks []StorageAPI
    				if askDisks > 0 && len(disks) > askDisks {
    					rand.Shuffle(len(disks), func(i, j int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  6. cmd/object-api-interface.go

    	Marker       string                   // set to skip until this object
    	LatestOnly   bool                     // returns only latest versions for all matching objects
    	AskDisks     string                   // dictates how many disks are being listed
    	VersionsSort WalkVersionsSortOrder    // sort order for versions of the same object; default: Ascending order in ModTime
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    		if err := api.Walk(ctx, r.Source.Bucket, r.Source.Prefix, walkCh, WalkOptions{
    			Marker:   lastObject,
    			Filter:   selectObj,
    			AskDisks: walkQuorum,
    		}); err != nil {
    			cancel()
    			// Do not need to retry if we can't list objects on source.
    			return err
    		}
    
    		prevObj := ""
    
    		skipReplicate := false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top