Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 257 for segondas (0.09 sec)

  1. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

            .build(),
        )
        var result = cachedDns.lookup("google.com")
        assertThat(result).containsExactly(address("157.240.1.18"))
        var recordedRequest = server.takeRequest(0, TimeUnit.SECONDS)
        assertThat(recordedRequest!!.method).isEqualTo("GET")
        assertThat(recordedRequest.path).isEqualTo(
          "/lookup?ct&dns=AAABAAABAAAAAAAABmdvb2dsZQNjb20AAAEAAQ",
        )
        Thread.sleep(2000)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. samples/guide/src/main/java/okhttp3/recipes/CancelCall.java

          System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f);
          call.cancel();
          System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f);
        }, 1, TimeUnit.SECONDS);
    
        System.out.printf("%.2f Executing call.%n", (System.nanoTime() - startNanos) / 1e9f);
        try (Response response = call.execute()) {
          System.out.printf("%.2f Call was expected to fail, but completed: %s%n",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

     * the License.
     */
    
    package com.google.common.util.concurrent.testing;
    
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.concurrent.CancellationException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/InterceptorTest.kt

        assertFailsWith<SocketTimeoutException> {
          call.execute()
        }
        val elapsedNanos = System.nanoTime() - startNanos
        org.junit.jupiter.api.Assertions.assertTrue(
          elapsedNanos < TimeUnit.SECONDS.toNanos(5),
          "Timeout should have taken ~100ms but was " + elapsedNanos / 1e6 + " ms",
        )
      }
    
      @Test
      fun chainWithReadTimeout() {
        val interceptor1 =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

     * the License.
     */
    
    package com.google.common.util.concurrent.testing;
    
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.concurrent.CancellationException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  6. internal/http/dial_linux.go

    			_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_QUICKACK, 1)
    
    			/// Enable keep-alive
    			{
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_KEEPALIVE, 1)
    
    				// The time (in seconds) the connection needs to remain idle before
    				// TCP starts sending keepalive probes
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15)
    
    				// Number of probes.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt

            while (e != null) {
              println(e)
              e = e.cause
            }
          }
        }
        println()
      }
      time = System.currentTimeMillis() - time
      println("Time: ${time.toDouble() / 1000} seconds\n")
    }
    
    fun main() {
      Security.insertProviderAt(OpenSSLProvider(), 1)
      var bootstrapClient = OkHttpClient()
      var names = listOf("google.com", "graph.facebook.com", "sdflkhfsdlkjdf.ee")
      try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. internal/config/drive/help.go

    	// HelpDrive is help for drive
    	HelpDrive = config.HelpKVS{
    		config.HelpKV{
    			Key:         MaxTimeout,
    			Type:        "string",
    			Description: "set per call max_timeout for the drive, defaults to 30 seconds",
    			Optional:    true,
    		},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/ConcurrencyTest.java

        }
    
    
        @After
        @Override
        public void tearDown () throws Exception {
            this.executor.shutdown();
            this.executor.awaitTermination(10, TimeUnit.SECONDS);
            super.tearDown();
        }
    
    
        @Test
        public void testExclusiveLock () throws InterruptedException, MalformedURLException, UnknownHostException {
            String fname = makeRandomName();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:40:50 UTC 2021
    - 17.6K bytes
    - Viewed (0)
  10. cmd/metrics-v3-cache.go

    		TotalTicks:   currentStats.TotalTicks - initialStats.TotalTicks,
    	}
    }
    
    func getDriveIOStatMetrics(ioStats madmin.DiskIOStats, duration time.Duration) (m driveIOStatMetrics) {
    	durationSecs := duration.Seconds()
    
    	m.readsPerSec = float64(ioStats.ReadIOs) / durationSecs
    	m.readsKBPerSec = float64(ioStats.ReadSectors) * float64(sectorSize) / kib / durationSecs
    	if ioStats.ReadIOs > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top