Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewSource (0.21 sec)

  1. 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
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 75.8K bytes
    - Viewed (0)
  2. 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
    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)
  3. 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) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. 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!
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  5. 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.
    		})
    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. src/bufio/bufio_test.go

    					t.Errorf("have=%q", written)
    				}
    			}
    		}
    	}
    }
    
    func TestWriterAppend(t *testing.T) {
    	got := new(bytes.Buffer)
    	var want []byte
    	rn := rand.New(rand.NewSource(0))
    	w := NewWriterSize(got, 64)
    	for i := 0; i < 100; i++ {
    		// Obtain a buffer to append to.
    		b := w.AvailableBuffer()
    		if w.Available() != cap(b) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
Back to top