Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 60 for SHUFFLE (0.51 sec)

  1. staging/src/k8s.io/api/flowcontrol/v1beta1/generated.proto

      // +optional
      optional int32 queues = 1;
    
      // `handSize` is a small positive number that configures the
      // shuffle sharding of requests into queues.  When enqueuing a request
      // at this priority level the request's flow identifier (a string
      // pair) is hashed and the hash value is used to shuffle the list
      // of queues and deal a hand of the size specified here.  The
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2_test.go

    		}
    		buf = xlMetaV2TrimData(buf)
    
    		vers = append(vers, metaCacheEntry{
    			name:     "a",
    			metadata: buf,
    		})
    	}
    
    	// Shuffle...
    	for i := 0; i < 100; i++ {
    		rng := rand.New(rand.NewSource(int64(i)))
    		rng.Shuffle(len(vers), func(i, j int) {
    			vers[i], vers[j] = vers[j], vers[i]
    		})
    		var entries []chan metaCacheEntry
    		for _, v := range vers {
    			v.cached = nil
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  3. cmd/global-heal.go

    		if len(disks) < er.setDriveCount/2 {
    			return fmt.Errorf("not enough drives (found=%d, healing=%d, total=%d) are available to heal `%s`", len(disks), healing, er.setDriveCount, tracker.disk.String())
    		}
    
    		rand.Shuffle(len(disks), func(i, j int) {
    			disks[i], disks[j] = disks[j], disks[i]
    		})
    
    		expectedDisks := len(disks)/2 + 1
    		fallbackDisks := disks[expectedDisks:]
    		disks = disks[:expectedDisks]
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 31 14:48:50 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/flowcontrol/v1/types.go

    	Queues int32 `json:"queues" protobuf:"varint,1,opt,name=queues"`
    
    	// `handSize` is a small positive number that configures the
    	// shuffle sharding of requests into queues.  When enqueuing a request
    	// at this priority level the request's flow identifier (a string
    	// pair) is hashed and the hash value is used to shuffle the list
    	// of queues and deal a hand of the size specified here.  The
    	// request is put into one of the shortest queues in that hand.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. src/crypto/sha256/sha256block_amd64.s

    	VMOVDQU		state1, (1*16)(digestPtr)
    
    done:
    	RET
    
    // shuffle byte order from LE to BE
    DATA flip_mask<>+0x00(SB)/8, $0x0405060700010203
    DATA flip_mask<>+0x08(SB)/8, $0x0c0d0e0f08090a0b
    DATA flip_mask<>+0x10(SB)/8, $0x0405060700010203
    DATA flip_mask<>+0x18(SB)/8, $0x0c0d0e0f08090a0b
    GLOBL flip_mask<>(SB), 8, $32
    
    // shuffle xBxA -> 00BA
    DATA shuff_00BA<>+0x00(SB)/8, $0x0b0a090803020100
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:29:44 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  6. cmd/erasure.go

    			NextCycle: oldCache.Info.NextCycle,
    		},
    		Cache: make(map[string]dataUsageEntry, len(oldCache.Cache)),
    	}
    
    	// Put all buckets into channel.
    	bucketCh := make(chan BucketInfo, len(buckets))
    
    	// Shuffle buckets to ensure total randomness of buckets, being scanned.
    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 16K bytes
    - Viewed (0)
  7. pkg/kubelet/status/status_manager_test.go

    	m.SetPodStatus(pod, status)
    	m.syncBatch(true)
    	verifyActions(t, m, []core.Action{getAction()})
    
    	t.Logf("Nothing stuck in the pipe.")
    	verifyUpdates(t, m, 0)
    }
    
    // shuffle returns a new shuffled list of container statuses.
    func shuffle(statuses []v1.ContainerStatus) []v1.ContainerStatus {
    	numStatuses := len(statuses)
    	randIndexes := rand.Perm(numStatuses)
    	shuffled := make([]v1.ContainerStatus, numStatuses)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  8. src/sort/sort_test.go

    	sizes := []int{100, 1023, 1024, 1025}
    	if testing.Short() {
    		sizes = []int{100, 127, 128, 129}
    	}
    	dists := []string{"sawtooth", "rand", "stagger", "plateau", "shuffle"}
    	modes := []string{"copy", "reverse", "reverse1", "reverse2", "sort", "dither"}
    	var tmp1, tmp2 [1025]int
    	for _, n := range sizes {
    		for m := 1; m < 2*n; m *= 2 {
    			for dist := 0; dist < _NDist; dist++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 19:41:04 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  9. pkg/controller/replicaset/replica_set_test.go

    	}
    
    	err = validateSyncReplicaSet(&fakePodControl, 1, 0, 0)
    	if err != nil {
    		t.Fatal(err)
    	}
    	fakePodControl.Clear()
    }
    
    // shuffle returns a new shuffled list of container controllers.
    func shuffle(controllers []*apps.ReplicaSet) []*apps.ReplicaSet {
    	numControllers := len(controllers)
    	randIndexes := rand.Perm(numControllers)
    	shuffled := make([]*apps.ReplicaSet, numControllers)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  10. src/cmd/go/internal/test/test.go

    	    the Go tree can run a sanity check but not spend time running
    	    exhaustive tests.
    
    	-shuffle off,on,N
    	    Randomize the execution order of tests and benchmarks.
    	    It is off by default. If -shuffle is set to on, then it will seed
    	    the randomizer using the system clock. If -shuffle is set to an
    	    integer N, then N will be used as the seed value. In both cases,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 14:34:32 UTC 2024
    - 71.9K bytes
    - Viewed (0)
Back to top