Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for newSource (0.16 sec)

  1. okhttp/src/jvmTest/kotlin/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: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 75.7K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    func getRandomRange(minN, maxN int, seed int64) int {
    	// special value -1 means no explicit seeding.
    	if seed == -1 {
    		return rand.New(rand.NewSource(time.Now().UnixNano())).Intn(maxN-minN) + minN
    	}
    	return rand.New(rand.NewSource(seed)).Intn(maxN-minN) + minN
    }
    
    // Randomizes the order of bytes in the byte array
    // using Knuth Fisher-Yates shuffle algorithm.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    	if retryAttempts <= 0 {
    		retryAttempts = batchReplJobDefaultRetries
    	}
    	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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  4. src/bytes/bytes_test.go

    			}
    		}
    	}
    	// Shuffle the runes so that they are not in descending order.
    	// The sort is deterministic since this is used for benchmarks,
    	// which need to be repeatable.
    	rr := rand.New(rand.NewSource(1))
    	rr.Shuffle(len(rs), func(i, j int) {
    		rs[i], rs[j] = rs[j], rs[i]
    	})
    	uchars := string(rs)
    
    	return func(b *testing.B, n int) {
    		buf := bmbuf[0:n]
    		o := copy(buf, uchars)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Jul 28 18:13:58 UTC 2025
    - 62.9K bytes
    - Viewed (0)
  5. cmd/iam.go

    	globalServerConfigMu.RLock()
    	s := globalServerConfig
    	globalServerConfigMu.RUnlock()
    
    	sys.Lock()
    	sys.iamRefreshInterval = iamRefreshInterval
    	sys.Unlock()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	var (
    		openidInit bool
    		ldapInit   bool
    		authNInit  bool
    		authZInit  bool
    	)
    
    	stsTLSConfig, err := xtls.Lookup(s[config.IdentityTLSSubSys][config.Default])
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K 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) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    	// so various tasks will be useful
    	bootstrapTrace("initAutoHeal", func() {
    		initAutoHeal(GlobalContext, 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top