- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of about 10,000 for Sand (0.33 sec)
-
internal/crypto/key.go
type ObjectKey [32]byte // GenerateKey generates a unique ObjectKey from a 256 bit external key // and a source of randomness. If random is nil the default PRNG of the // system (crypto/rand) is used. func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) { if random == nil { random = rand.Reader } if len(extKey) != 32 { // safety check
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/auth/credentials.go
accessKey, err = GenerateAccessKey(accessKeyMaxLen, rand.Reader) if err != nil { return "", "", err } secretKey, err = GenerateSecretKey(secretKeyMaxLen, rand.Reader) if err != nil { return "", "", err } return accessKey, secretKey, nil } // GenerateAccessKey returns a new access key generated randomly using // the given io.Reader. If random is nil, crypto/rand.Reader is used.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* is also performed for calls to {@link Object#equals}, {@link Object#hashCode}, and {@link * Object#toString}. * * <p>If the target method call finishes before the limit is reached, the return value or * exception is propagated to the caller exactly as-is. If, on the other hand, the time limit is * reached, the proxy will attempt to abort the call to the target, and will throw an {@link * UncheckedTimeoutException} to the caller. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/license-update.go
import ( "context" "fmt" "math/rand" "time" "github.com/tidwall/gjson" ) const ( licUpdateCycle = 24 * time.Hour * 30 licRenewPath = "/api/cluster/renew-license" ) // initlicenseUpdateJob start the periodic license update job in the background. func initLicenseUpdateJob(ctx context.Context, objAPI ObjectLayer) { go func() { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/erasure.go
getDisks func() []StorageAPI // getLockers returns list of remote and local lockers. getLockers func() ([]dsync.NetLocker, string) // getEndpoints returns list of endpoint belonging this set. // some may be local and some remote. getEndpoints func() []Endpoint // getEndpoints returns list of endpoint strings belonging this set. // some may be local and some remote. getEndpointStrings func() []string // Locker mutex map.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
internal/rest/client.go
} // computes the exponential backoff duration according to // https://www.awsarchitectureblog.com/2015/03/backoff.html func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
// timing randomized back-off algorithm to try again until successful func (lm *LRWMutex) lockLoop(ctx context.Context, id, source string, timeout time.Duration, isWriteLock bool) (locked bool) { r := rand.New(rand.NewSource(time.Now().UnixNano())) retryCtx, cancel := context.WithTimeout(ctx, timeout) defer cancel() for { select { case <-retryCtx.Done(): // Caller context canceled or we timedout,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/callhome.go
if !globalCallhomeConfig.Enabled() { return } go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) // Leader node (that successfully acquires the lock inside runCallhome) // will keep performing the callhome. If the leader goes down for some reason, // the lock will be released and another node will acquire it and take over // because of this loop. for { if !globalCallhomeConfig.Enabled() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
internal/dsync/drwmutex.go
// Indicator if logging is enabled. var dsyncLog bool // Retry unit interval var lockRetryMinInterval time.Duration var lockRetryBackOff func(*rand.Rand, uint) time.Duration func init() { // Check for MINIO_DSYNC_TRACE env variable, if set logging will be enabled for failed REST operations. dsyncLog = env.Get("_MINIO_DSYNC_TRACE", "0") == "1" lockRetryMinInterval = 250 * time.Millisecond
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/math/LongMathTest.java
Random rand = new Random(1); for (int bits = 10; bits < 63; bits++) { for (int i = 0; i < 100; i++) { long p = BigInteger.probablePrime(bits, rand).longValue(); assertTrue(LongMath.isPrime(p)); } } } @GwtIncompatible // isPrime is GWT-incompatible public void testIsPrimeOnRandomComposites() { Random rand = new Random(1);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Mar 04 20:15:57 GMT 2024 - 32.5K bytes - Viewed (0)