Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of about 10,000 for Band (0.15 sec)

  1. 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)
  2. 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)
  3. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    and confusion, as the large birds complained that they could not
    taste theirs, and the small ones choked and had to be patted on
    the back.  However, it was over at last, and they sat down again
    in a ring, and begged the Mouse to tell them something more.
    
      `You promised to tell me your history, you know,' said Alice,
    `and why it is you hate--C and D,' she added in a whisper, half
    afraid that it would be offended again.
    
    Plain Text
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Apr 21 02:27:51 GMT 2017
    - 145.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. android/guava/src/com/google/common/io/ReaderInputStream.java

      private void readMoreChars() throws IOException {
        // Possibilities:
        // 1) array has space available on right-hand side (between limit and capacity)
        // 2) array has space available on left-hand side (before position)
        // 3) array has no space available
        //
        // In case 2 we shift the existing chars to the left, and in case 3 we create a bigger
        // array, then they both become case 1.
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 28 20:13:02 GMT 2023
    - 9.3K bytes
    - Viewed (0)
  7. internal/crypto/key_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package crypto
    
    import (
    	"bytes"
    	"crypto/rand"
    	"encoding/hex"
    	"io"
    	"testing"
    
    	"github.com/minio/minio/internal/logger"
    )
    
    var shortRandom = func(limit int64) io.Reader { return io.LimitReader(rand.Reader, limit) }
    
    func recoverTest(i int, shouldPass bool, t *testing.T) {
    	if err := recover(); err == nil && !shouldPass {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Feb 02 00:13:57 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/hash/HashTestUtils.java

       * input bit(i) and output bit(j), two pairs of keys must be found with all bits identical except
       * bit(i). One pair must differ in output bit(j), and one pair must not. This proves that input
       * bit(i) can alter output bit(j).
       */
      static void checkNoFunnels(HashFunction function) {
        Random rand = new Random(0);
        int keyBits = 32;
        int hashBits = function.bits();
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Oct 10 19:45:10 GMT 2022
    - 25.3K bytes
    - Viewed (0)
  9. internal/dsync/utils.go

    package dsync
    
    import (
    	"math/rand"
    	"time"
    )
    
    func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(r *rand.Rand, attempt uint) time.Duration {
    		sleep := min
    		sleep += unit * time.Duration(attempt)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat May 13 15:42:21 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  10. internal/http/dial_dnscache.go

    //
    // You can use returned dial function for `http.Transport.DialContext`.
    //
    // In this function, it uses functions from `rand` package. To make it really random,
    // you MUST call `rand.Seed` and change the value from the default in your application
    func DialContextWithLookupHost(lookupHost LookupHost, baseDialCtx DialContext) DialContext {
    	if lookupHost == nil {
    		lookupHost = net.DefaultResolver.LookupHost
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jul 03 19:30:51 GMT 2023
    - 2.6K bytes
    - Viewed (0)
Back to top