Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for AskDisks (0.05 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
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:23:12 UTC 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{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 25 23:29:45 UTC 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.7K 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    				prefixWalkCh := make(chan itemOrErr[ObjectInfo], 100)
    				if err := api.Walk(ctx, r.Source.Bucket, prefix, prefixWalkCh, WalkOptions{
    					Marker:   lastObject,
    					Filter:   selectObj,
    					AskDisks: walkQuorum,
    				}); err != nil {
    					cancelCause(err)
    					xioutil.SafeClose(walkCh)
    					return
    				}
    				for obj := range prefixWalkCh {
    					walkCh <- obj
    				}
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
Back to top