- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 487 for timeout (0.47 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(), }) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
val connectTimeout: Int by option( "--connect-timeout", help = "Maximum time allowed for connection (seconds)", ).int().default(DEFAULT_TIMEOUT) val readTimeout: Int by option("--read-timeout", help = "Maximum time allowed for reading data (seconds)").int().default(DEFAULT_TIMEOUT) val callTimeout: Int by option( "--call-timeout", help = "Maximum time allowed for the entire call (seconds)",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
long timeout = RESPONSE_TIMEOUT; resp.expiration = System.currentTimeMillis() + timeout; while( resp.hasMoreElements() ) { wait( timeout ); timeout = resp.expiration - System.currentTimeMillis(); if (timeout <= 0) {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
private final AtomicBoolean executed = new AtomicBoolean(false); private final long timeout; public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) { this.p = p; this.ist = ist; this.timeout = timeout; } @Override public void run() { if (!p.isAlive()) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
} public ExecJob logSuffix(final String logSuffix) { this.logSuffix = logSuffix.trim().replaceAll("\\s", "_"); return this; } public ExecJob timeout(final int timeout) { this.timeout = timeout; return this; } public ExecJob useLocalFesen(final boolean useLocalFesen) { this.useLocalFesen = useLocalFesen; return this; }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
return bytesRead } finally { synchronized(this@Relay) { upstreamReader = null ******@****.***All() } } } override fun timeout(): Timeout = timeout @Throws(IOException::class) override fun close() { if (fileOperator == null) return // Already closed. fileOperator = null var fileToClose: RandomAccessFile? = null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
private final Process process; private final long timeout; private boolean finished = false; private boolean teminated = false; public MonitorThread(final Process process, final long timeout) { this.process = process; this.timeout = timeout; } @Override public void run() {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
@Override protected abstract ExecutorService delegate(); @CheckReturnValue @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return delegate().awaitTermination(timeout, unit); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks) throws InterruptedException {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
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() } } @Flaky @Test fun noTimeout() { // Flaky https://github.com/square/okhttp/issues/5304
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K 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
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0)