Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 465 for timers (0.14 sec)

  1. android/guava-tests/test/com/google/common/base/AndroidIncompatible.java

     *       testlib), but why bother?
     *   <li>Stripping code entirely might help us keep under the method limit someday. Even if it never
     *       comes to that, it may at least help with build and startup times.
     * </ul>
     */
    @Retention(CLASS)
    @Target({ANNOTATION_TYPE, CONSTRUCTOR, FIELD, METHOD, TYPE})
    @GwtCompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 07 15:40:13 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  2. cmd/dynamic-timeouts.go

    type dynamicTimeout struct {
    	timeout       int64
    	minimum       int64
    	entries       int64
    	log           [dynamicTimeoutLogSize]time.Duration
    	mutex         sync.Mutex
    	retryInterval time.Duration
    }
    
    type dynamicTimeoutOpts struct {
    	timeout       time.Duration
    	minimum       time.Duration
    	retryInterval time.Duration
    }
    
    func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. src/test/java/jcifs/netbios/SessionServicePacketTest.java

    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.mockito.ArgumentMatchers.any;
    import static org.mockito.ArgumentMatchers.anyInt;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Stream;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/io/Smb2WriteRequestTest.java

    import static org.junit.jupiter.api.Assertions.assertNotNull;
    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.security.SecureRandom;
    import java.util.Arrays;
    import java.util.Random;
    
    import org.junit.jupiter.api.BeforeEach;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  5. cmd/erasure-healing-common_test.go

    // time occurrence from a list of time.
    func TestCommonTime(t *testing.T) {
    	// List of test cases for common modTime.
    	testCases := []struct {
    		times  []time.Time
    		time   time.Time
    		quorum int
    	}{
    		{
    			// 1. Tests common times when slice has varying time elements.
    			[]time.Time{
    				time.Unix(0, 1).UTC(),
    				time.Unix(0, 2).UTC(),
    				time.Unix(0, 3).UTC(),
    				time.Unix(0, 3).UTC(),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/tree/Smb2TreeConnectRequestTest.java

    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.lang.reflect.Field;
    import java.lang.reflect.Method;
    import java.nio.charset.StandardCharsets;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

            CountDownLatch endLatch = new CountDownLatch(threadCount);
            AtomicInteger releaseCount = new AtomicInteger(0);
            AtomicInteger acquireCount = new AtomicInteger(0);
    
            // Acquire session multiple times
            for (int i = 0; i < threadCount - 1; i++) {
                session.acquire();
            }
    
            // When - Multiple threads try to release/acquire concurrently
            for (int t = 0; t < threadCount; t++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. cmd/metrics-realtime.go

    		}
    		m.Aggregated.Mem.Info = madmin.GetMemInfo(GlobalContext, byHostName)
    	}
    	if types.Contains(madmin.MetricsCPU) {
    		m.Aggregated.CPU = &madmin.CPUMetrics{
    			CollectedAt: UTCNow(),
    		}
    		cm, err := c.Times(false)
    		if err != nil {
    			m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (cpuTimes)", byHostName, err.Error()))
    		} else {
    			// not collecting per-cpu stats, so there will be only one element
    			if len(cm) == 1 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                return null;
              }
            });
    
        assertEquals(incrementByNanos * numberOfThreads, ticker.read());
      }
    
      /** Runs {@code callable} concurrently {@code numberOfThreads} times. */
      @GwtIncompatible // concurrency
      private void runConcurrentTest(int numberOfThreads, Callable<@Nullable Void> callable)
          throws Exception {
        ExecutorService executorService = newFixedThreadPool(numberOfThreads);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  10. docs/distributed/CONFIG.md

    hostnames for us to make sure that we can provide horizontal distribution, however we have come across situations where sometimes this is not feasible and there are no easier alternatives without modifying /etc/hosts on the host system as root user.  Many times in airgapped deployments this is not allowed or requires audits and approvals.
    
    MinIO server configuration file allows users to provide topology that allows for heterogeneous hostnames, allowing MinIO to deployed in pre-existing environments...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jun 25 02:30:18 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top