- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 390 for timeouts (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/internal/fscc/FsctlPipeWaitRequest.java
* * @param name the pipe name to wait for * @param timeout the timeout value in milliseconds */ public FsctlPipeWaitRequest(final String name, final long timeout) { this.nameBytes = name.getBytes(StandardCharsets.UTF_16LE); this.timeoutSpecified = true; this.timeout = timeout; } /** * {@inheritDoc} *Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
* @param process The process to monitor. * @param timeout The timeout duration in milliseconds. */ public MonitorThread(final Process process, final long timeout) { this.process = process; this.timeout = timeout; } /** * Runs the monitor thread, sleeping for the timeout duration and terminating the process if needed. */Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/persistent/HandleInfo.java
* @param guid the create GUID * @param fileId the 16-byte file ID * @param type the handle type * @param timeout the timeout in milliseconds * @param leaseKey the associated lease key (can be null) */ public HandleInfo(String path, HandleGuid guid, byte[] fileId, HandleType type, long timeout, Smb2LeaseKey leaseKey) { this.path = path; this.createGuid = guid;Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 5.9K bytes - Click Count (0) -
guava/src/com/google/common/collect/Queues.java
throws InterruptedException { return drain(q, buffer, numElements, toNanosSaturated(timeout), NANOSECONDS); } /** * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code * numElements} elements are not available, it will wait for them up to the specified timeout. * * @param q the blocking queue to be drainedCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 18K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java
delegate().putLast(e); } @Override public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offerFirst(e, timeout, unit); } @Override public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offerLast(e, timeout, unit); } @Override public E takeFirst() throws InterruptedException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
assertEquals(method, lastMethodCalled); } 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
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 9.9K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
/** * @since 28.0 */ @Override public final void awaitRunning(Duration timeout) throws TimeoutException { Service.super.awaitRunning(timeout); } /** * @since 15.0 */ @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException { delegate.awaitRunning(timeout, unit); } /** * @since 15.0 */ @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 7.5K bytes - Click Count (0) -
impl/maven-core/src/test/java/org/apache/maven/configuration/internal/CompositeBeanHelperPerformanceTest.java
} public String getDescription() { return description; } public void setTimeout(long timeout) { this.timeout = timeout; } public long getTimeout() { return timeout; } public void setItems(List<String> items) { this.items = items; }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Jul 17 07:40:49 GMT 2025 - 16.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
assertEquals(method, lastMethodCalled); } 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
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 9.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
check(currentPart == this) { "closed" } return source.timeout().intersectWith(timeout) { when (val limit = currentPartBytesRemaining(maxByteCount = byteCount)) { 0L -> -1L // No more bytes in this part. else -> source.read(sink, limit) } } } override fun timeout(): Timeout = timeout } /**
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 02:11:14 GMT 2025 - 7.3K bytes - Click Count (0)