- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 457 for ontimeout (0.05 sec)
-
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
} @CanIgnoreReturnValue @Override @ParametricNullness public V get(long timeout, TimeUnit unit) throws TimeoutException, InterruptedException, ExecutionException { long timeoutNanos = unit.toNanos(timeout); if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) { return super.get(timeout, unit); } // Waiting 68 years should be enough for any program. return super.get(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/CommonServerMessageBlockRequestTest.java
boolean async = request.isResponseAsync(); int size = request.size(); Integer timeout = request.getOverrideTimeout(); boolean canChain = request.allowChain(nextRequest); // Then assertTrue(async); assertEquals(100, size); assertEquals(3000, timeout); assertTrue(canChain); verify(request).isResponseAsync(); verify(request).size();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
}); } // TODO(cpovirk): promote to Uninterruptibles, and add untimed version private static void joinUninterruptibly(Thread thread, long timeout, TimeUnit unit) { boolean interrupted = false; try { long remainingNanos = unit.toNanos(timeout); long end = System.nanoTime() + remainingNanos; while (true) { try {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 4.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/http/NtlmServlet.java
@Override public void init(final ServletConfig config) throws ServletException { super.init(config); /* Set jcifs.smb1 properties we know we want; soTimeout and cachePolicy to 10min. */ Config.setProperty("jcifs.smb1.smb.client.soTimeout", "300000"); Config.setProperty("jcifs.smb1.netbios.cachePolicy", "600"); final Enumeration e = config.getInitParameterNames(); String name;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.1K bytes - Viewed (0) -
docs/sts/client_grants/__init__.py
ca_certs = os.environ.get('SSL_CERT_FILE') if not ca_certs: ca_certs = certifi.where() self._http = urllib3.PoolManager( timeout=urllib3.Timeout.DEFAULT_TIMEOUT, maxsize=10, cert_reqs='CERT_NONE', ca_certs=ca_certs, retries=urllib3.Retry( total=5, backoff_factor=0.2,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 4.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyTest.kt
abstract class ForwardingSource( val delegate: Source, ) : Source { override fun read( sink: Buffer, byteCount: Long, ): Long = delegate.read(sink, byteCount) override fun timeout() = delegate.timeout() override fun close() = delegate.close()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java
protected int maxDataCount; /** Maximum number of setup words the server should return */ protected byte maxSetupCount; /** Timeout in milliseconds to wait for the transaction to complete */ protected int timeout = 0; /** Number of setup words in this request */ protected int setupCount = 1; private byte subCommand; /** The transaction name for named pipe transactions */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 17.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
return; } /* * If we're about to complete the TimeoutFuture, we want to release our reference to it. * Otherwise, we'll pin it (and its result) in memory until the timeout task is GCed. (The * need to clear our reference to the TimeoutFuture is the reason we use a *static* nested * class with a manual reference back to the "containing" class.) *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2CancelRequestTest.java
// Given Smb2CancelRequest request = new Smb2CancelRequest(mockConfig, 1L, 0L); // When Integer timeout = request.getOverrideTimeout(); // Then assertNull(timeout, "Cancel requests should not override timeout"); } @Test @DisplayName("Test allowChain returns false") void testAllowChain() { // Given
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.8K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/FunctionalTest.kt
os = testCoverage.os, buildJvm = testCoverage.buildJvm, arch = testCoverage.arch, extraParameters = assembledExtraParameters, timeout = testCoverage.testType.timeout, maxParallelForks = testCoverage.testType.maxParallelForks.toString(), extraSteps = extraBuildSteps, preSteps = preBuildSteps, )
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Wed Feb 12 09:12:03 UTC 2025 - 5.6K bytes - Viewed (0)