Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for newResource (0.16 sec)

  1. pkg/scheduler/internal/cache/cache_test.go

    func buildNodeInfo(node *v1.Node, pods []*v1.Pod, imageStates map[string]*framework.ImageStateSummary) *framework.NodeInfo {
    	expected := framework.NewNodeInfo()
    	expected.SetNode(node)
    	expected.Allocatable = framework.NewResource(node.Status.Allocatable)
    	expected.Generation++
    	for _, pod := range pods {
    		expected.AddPod(pod)
    	}
    	for _, image := range node.Status.Images {
    		for _, name := range image.Names {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        setUp(parameters.first, parameters.second)
        val creator = cache.edit("k1")!!
        creator.setString(0, "ABC")
        creator.setString(1, "DE")
        assertThat(creator.newSource(0)).isNull()
        assertThat(creator.newSource(1)).isNull()
        creator.commit()
        val snapshot = cache["k1"]!!
        snapshot.assertValue(0, "ABC")
        snapshot.assertValue(1, "DE")
      }
    
      @ParameterizedTest
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  3. src/math/big/int_test.go

    	sqrtsq.Mod(&sqrtsq, mod)
    	return sq.Cmp(&sqrtsq) == 0
    }
    
    func TestModSqrt(t *testing.T) {
    	var elt, mod, modx4, sq, sqrt Int
    	r := rand.New(rand.NewSource(9))
    	for i, s := range primes[1:] { // skip 2, use only odd primes
    		mod.SetString(s, 10)
    		modx4.Lsh(&mod, 2)
    
    		// test a few random elements per prime
    		for x := 1; x < 5; x++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 58.5K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    	if ri.Complete {
    		return nil
    	}
    	globalBatchJobsMetrics.save(job.ID, ri)
    
    	delay := job.Replicate.Flags.Retry.Delay
    	if delay == 0 {
    		delay = batchReplJobDefaultRetryDelay
    	}
    	rnd := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	hasTags := len(r.Flags.Filter.Tags) != 0
    	isMetadata := len(r.Flags.Filter.Metadata) != 0
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 56K bytes
    - Viewed (0)
  5. cmd/iam.go

    	sys.initStore(objAPI, etcdClient)
    	sys.Unlock()
    
    	retryCtx, cancel := context.WithCancel(ctx)
    
    	// Indicate to our routine to exit cleanly upon return.
    	defer cancel()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	// Migrate storage format if needed.
    	for {
    		// Migrate IAM configuration, if necessary.
    		if err := saveIAMFormat(retryCtx, sys.store); err != nil {
    			if configRetriableErrors(err) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  6. pkg/apis/certificates/validation/validation_test.go

    				t.Errorf("unexpected errors: %s", unexpected)
    			}
    		})
    	}
    }
    
    func mustMakeCertificate(t *testing.T, template *x509.Certificate) []byte {
    	gen := mathrand.New(mathrand.NewSource(12345))
    
    	pub, priv, err := ed25519.GenerateKey(gen)
    	if err != nil {
    		t.Fatalf("Error while generating key: %v", err)
    	}
    
    	cert, err := x509.CreateCertificate(gen, template, template, pub, priv)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 03 18:40:49 UTC 2023
    - 61K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    		req.Header.Set(k, v)
    	}
    
    	err = signRequestV4(req, accessKey, secretKey)
    	if err != nil {
    		return nil, err
    	}
    
    	return req, nil
    }
    
    var src = rand.NewSource(time.Now().UnixNano())
    
    func randString(n int) string {
    	b := make([]byte, n)
    	// A src.Int63() generates 63 random bits, enough for letterIdxMax characters!
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    	})
    
    	bootstrapTrace("initHealMRF", func() {
    		go globalMRFState.healRoutine(z)
    	})
    
    	// initialize the object layer.
    	defer setObjectLayer(z)
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	attempt := 1
    	for {
    		var err error
    		bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() {
    			err = z.Init(ctx) // Initializes all pools.
    		})
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
  9. src/testing/testing.go

    				fmt.Fprintln(os.Stderr, `testing: -shuffle should be "off", "on", or a valid integer:`, err)
    				m.exitCode = 2
    				return
    			}
    		}
    		fmt.Println("-test.shuffle", n)
    		rng := rand.New(rand.NewSource(n))
    		rng.Shuffle(len(m.tests), func(i, j int) { m.tests[i], m.tests[j] = m.tests[j], m.tests[i] })
    		rng.Shuffle(len(m.benchmarks), func(i, j int) { m.benchmarks[i], m.benchmarks[j] = m.benchmarks[j], m.benchmarks[i] })
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 76.1K bytes
    - Viewed (0)
Back to top