Search Options

Results per page
Sort
Preferred Languages
Advance

Results 591 - 600 of 786 for iterations (0.13 sec)

  1. internal/dsync/drwmutex.go

    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
    	if lri := env.Get("_MINIO_LOCK_RETRY_INTERVAL", ""); lri != "" {
    		v, err := strconv.Atoi(lri)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    	totalErrsTimeout      atomic.Uint64 // Captures all timeout only errors
    
    	// apiCalls should be placed first so alignment is guaranteed for atomic operations.
    	apiCalls     [storageMetricLast]uint64
    	apiLatencies [storageMetricLast]*lockedLastMinuteLatency
    	diskID       atomic.Pointer[string]
    	storage      *xlStorage
    	health       *diskHealthTracker
    	healthCheck  bool
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/DiscreteDomain.java

    import javax.annotation.CheckForNull;
    
    /**
     * A descriptor for a <i>discrete</i> {@code Comparable} domain such as all {@link Integer}
     * instances. A discrete domain is one that supports the three basic operations: {@link #next},
     * {@link #previous} and {@link #distance}, according to their specifications. The methods {@link
     * #minValue} and {@link #maxValue} should also be overridden for bounded types.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/util/MD4.java

            // buffer remaining input
            if (i < len)
                System.arraycopy(input, offset + i, buffer, bufferNdx, len - i);
        }
    
        /**
         * Completes the hash computation by performing final operations such
         * as padding. At the return of this engineDigest, the MD engine is
         * reset.
         *
         * @return the array of bytes for the resulting hash value.
         */
        public byte[] engineDigest () {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        when(backingMap.putIfAbsent(eq(KEY), isA(AtomicInteger.class))).thenReturn(existing);
    
        // another map.get()
        when(backingMap.get(KEY)).thenReturn(existing);
        // we shouldn't see any more map operations; CHM will now just update the AtomicInteger
    
        assertEquals(12, multiset.add(KEY, 3));
        assertEquals(15, existing.get());
      }
    
      public void testRemove_zeroFromSome() {
        final int INITIAL_COUNT = 14;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/AbstractCache.java

         */
        void recordEviction();
    
        /**
         * Returns a snapshot of this counter's values. Note that this may be an inconsistent view, as
         * it may be interleaved with update operations.
         */
        CacheStats snapshot();
      }
    
      /**
       * A thread-safe {@link StatsCounter} implementation for use by {@link Cache} implementors.
       *
       * @since 10.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 9.1K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbEnumerationUtil.java

                throw new SmbException(u.toString() + " directory must end with '/'");
    
            if ( locator.getType() != SmbConstants.TYPE_SERVER )
                throw new SmbException("The requested list operations is invalid: " + u.toString());
    
            Set<FileEntry> set = new HashSet<>();
    
            if ( tc.getDfs().isTrustedDomain(tc, locator.getServer()) ) {
                /*
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:41:19 UTC 2019
    - 12.5K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

      /**
       * Either writes this request to [sink] or measures its content length. We have one method do
       * double-duty to make sure the counting and content are consistent, particularly when it comes
       * to awkward operations like measuring the encoded length of header strings, or the
       * length-in-digits of an encoded integer.
       */
      @Throws(IOException::class)
      private fun writeOrCountBytes(
        sink: BufferedSink?,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

    /**
     * A helper for concurrency testing. One or more {@code TestThread} instances are instantiated in a
     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/QueuesTest.java

            new LinkedBlockingDeque<Object>(),
            new LinkedBlockingDeque<Object>(10),
            new PriorityBlockingQueue<Object>(10, Ordering.arbitrary()));
      }
    
      /*
       * We need to perform operations in a thread pool, even for simple cases, because the queue might
       * be a SynchronousQueue.
       */
      private ExecutorService threadPool;
    
      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top