- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 712 for itemout (0.52 sec)
-
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskTimeoutIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 12.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Uninterruptibles.java
/** * Invokes {@code latch.}{@link CountDownLatch#await(long, TimeUnit) await(timeout, unit)} * uninterruptibly. * * @since 28.0 */ @J2ktIncompatible @GwtIncompatible // concurrency public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout) { return awaitUninterruptibly(latch, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 18.7K bytes - Viewed (0) -
src/net/timeout_test.go
c.Close() if delta <= 1 && d.Timeout <= 1 { t.Fatalf("can't reduce Timeout or Deadline") } if delta > 1 { delta /= 2 t.Logf("reducing Deadline delta to %v", delta) } if d.Timeout > 1 { d.Timeout /= 2 t.Logf("reducing Timeout to %v", d.Timeout) } } if d.Deadline.IsZero() || afterDial.Before(d.Deadline) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
Request.Builder() .url(server.url("/")) .build() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") assertThat(call.isCanceled()).isTrue() } } @Test fun timeoutProcessingWithEnqueue() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency @SuppressWarnings("GoodTime") // should accept a java.time.Duration public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { boolean interrupted = false; try { long remainingNanos = unit.toNanos(timeout);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 14.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
} /** * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled * connections. */ private fun detachTimeout(timeout: ForwardingTimeout) { val oldDelegate = timeout.delegate timeout.setDelegate(Timeout.NONE) oldDelegate.clearDeadline()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/proxy/ipvs/util/ipvs_linux_test.go
Flags: uint32(FlagPersistent + FlagHashed), Timeout: 0, Netmask: 0xffffffff, AddressFamily: unix.AF_INET, Address: nil, PEName: "", }, VirtualServer{ Address: netutils.ParseIPSloppy("0.0.0.0"), Protocol: "TCP", Port: 80, Scheduler: "", Flags: ServiceFlags(FlagPersistent), Timeout: 0, }, false, "", }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 27 16:37:50 UTC 2023 - 9.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
FUTURE(Timeout.SMALL, Timeout.MAX), SMALL(Timeout.SMALL), FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL), INFINITE(Timeout.LARGE, Timeout.MAX); final ImmutableList<Timeout> timeouts; TimeoutsToUse(Timeout... timeouts) { this.timeouts = ImmutableList.copyOf(timeouts); } } /** Possible outcomes of calling any of the methods under test. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 25.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
assertEquals(method, lastMethodCalled); } public void assertMethodWithTimeout(String method, long timeout, TimeUnit unit) { assertLastMethodCalled(method + "Timeout"); assertEquals(unit.toMillis(timeout), lastTimeoutInMillis); } @Override public boolean awaitTermination(long timeout, TimeUnit unit) { lastMethodCalled = "awaitTermination"; return false; } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Jan 05 19:41:03 UTC 2023 - 9.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
FUTURE(Timeout.SMALL, Timeout.MAX), SMALL(Timeout.SMALL), FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL), INFINITE(Timeout.LARGE, Timeout.MAX); final ImmutableList<Timeout> timeouts; TimeoutsToUse(Timeout... timeouts) { this.timeouts = ImmutableList.copyOf(timeouts); } } /** Possible outcomes of calling any of the methods under test. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 27.1K bytes - Viewed (0)