- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 457 for ontimeout (0.06 sec)
-
cmd/namespace-lock.go
// Lock - block until write lock is taken or timeout has occurred. func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) { lockSource := getSource(2) start := UTCNow() newCtx, cancel := context.WithCancel(ctx) if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{ Timeout: timeout.Timeout(), RetryInterval: timeout.RetryInterval(), }) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 9.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
return this; } /** * Sets the timeout for this job execution. * * @param timeout the timeout in seconds (-1 for no timeout) * @return this ExecJob instance for method chaining */ public ExecJob timeout(final int timeout) { this.timeout = timeout; return this; } /** * Sets whether to use local Fesen instance.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 14.2K bytes - Viewed (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 } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 7.3K bytes - Viewed (0) -
src/test/java/jcifs/smb/SimpleMemoryManagementTest.java
import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Timeout; import org.mockito.Mockito; import jcifs.CIFSContext; import jcifs.Configuration; import jcifs.Credentials; /** * Simple memory management tests to validate basic resource cleanup functionality */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 5.7K bytes - Viewed (0) -
docs/smb3-features/02-persistent-handles-design.md
public static final String NAME = "DH2Q"; // Durable Handle V2 Request private long timeout; private int flags; private HandleGuid createGuid; public DurableHandleV2Request(long timeout, boolean persistent) { super(NAME); this.timeout = timeout; this.flags = persistent ? Smb2HandleCapabilities.SMB2_DHANDLE_FLAG_PERSISTENT : 0;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 31.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NbtSocket.java
if (calledName == null) { this.calledName = address.hostName; } else { this.calledName = new Name(calledName, 0x20, null); } soTimeout = Config.getInt("jcifs.smb1.netbios.soTimeout", DEFAULT_SO_TIMEOUT); connect(); } /** * Returns the NetBIOS address associated with this socket. * * @return the NetBIOS address */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 6.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java
* @param process The process to monitor. * @param timeout The timeout for the process. */ public MonitorThread(final Process process, final long timeout) { this.process = process; this.timeout = timeout; } @Override public void run() { ThreadUtil.sleepQuietly(timeout); if (!finished) { try {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 16K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* all must complete within one timeout period. * * The default value is 0 which imposes no timeout. */ fun callTimeout( timeout: Long, unit: TimeUnit, ) = apply { callTimeout = checkDuration("timeout", timeout, unit) } /** * Sets the default timeout for complete calls. A value of 0 means no timeout, otherwise values
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTreeInternalTest.java
// Arrange when(tree.send(eq(request), eq(RequestParam.NO_TIMEOUT), eq(RequestParam.NO_RETRY))).thenReturn(response); // Act CommonServerMessageBlockResponse out = tree.send(request, RequestParam.NO_TIMEOUT, RequestParam.NO_RETRY); // Assert assertSame(response, out); verify(tree).send(request, RequestParam.NO_TIMEOUT, RequestParam.NO_RETRY); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 5.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseJvmTest.kt
override fun read( sink: Buffer, byteCount: Long, ): Long { check(!closed) return data.read(sink, byteCount) } override fun timeout(): Timeout = Timeout.NONE } return source.buffer().asResponseBody(null, -1) } private fun newResponse( responseBody: ResponseBody, code: Int = 200, fn: Response.Builder.() -> Unit = {},
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 2.8K bytes - Viewed (0)