- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 462 for timed_out (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
} override fun timeout(): Timeout = timeout } /** * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source] in * the current part. If this returns 0 the current part is exhausted; otherwise it has at least * one byte left to read. */ private fun currentPartBytesRemaining(maxResult: Long): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.1K bytes - Viewed (0) -
docs_src/nosql_databases/tutorial001.py
cluster = Cluster( "couchbase://couchbasehost:8091?fetch_mutation_tokens=1&operation_timeout=30&n1ql_timeout=300" ) authenticator = PasswordAuthenticator("username", "password") cluster.authenticate(authenticator) bucket: Bucket = cluster.open_bucket("bucket_name", lockmode=LOCKMODE_WAIT) bucket.timeout = 30 bucket.n1ql_timeout = 300 return bucket class User(BaseModel): username: str
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat May 14 11:59:59 GMT 2022 - 1.3K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/SlackClient.java
this.session = session; this.notifyAll(); } /** Waits for an OAuth session for this client to be set. */ public synchronized void awaitAccessToken(Timeout timeout) throws InterruptedIOException { while (session == null) { timeout.waitUntilNotified(this); } } /** Starts a real time messaging session. */ public void startRtm() throws IOException { String accessToken;
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 12 03:31:36 GMT 2019 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
* * @param timeoutTarget target * @param timeout timeout * @param permanent permanent * @return {@link TimeoutTask} */ public synchronized TimeoutTask addTimeoutTarget(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) { final TimeoutTask task = new TimeoutTask(timeoutTarget, timeout, permanent); timeoutTaskList.addLast(task); start();
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
} @Override public final <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException { return delegate.invokeAll(wrapTasks(tasks), timeout, unit); } @Override public final <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 5.5K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/GradleBuildConfigurationDefaults.kt
os: Os = Os.LINUX, arch: Arch = Arch.AMD64, extraParameters: String = "", timeout: Int = 90, daemon: Boolean = true, buildJvm: Jvm = BuildToolBuildJvm, extraSteps: BuildSteps.() -> Unit = {} ) { buildType.applyDefaultSettings(os, timeout = timeout, buildJvm = buildJvm) buildType.killProcessStep(KILL_LEAKED_PROCESSES_FROM_PREVIOUS_BUILDS, os)
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbConstants.java
static final int DEFAULT_MAX_MPX_COUNT = 10; static final int DEFAULT_RESPONSE_TIMEOUT = 30000; static final int DEFAULT_SO_TIMEOUT = 35000; static final int DEFAULT_RCV_BUF_SIZE = 60416; static final int DEFAULT_SND_BUF_SIZE = 16644; static final int DEFAULT_SSN_LIMIT = 250; static final int DEFAULT_CONN_TIMEOUT = 35000; static final InetAddress LADDR = Config.getLocalHost();
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 8.4K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
args: strings.Split("--timeout 20ms virtual-service bar.default", " "), wantException: true, expectedOutput: "Error: timeout expired before resource networking.istio.io/v1alpha3/VirtualService/default/bar became effective on all sidecars\n", }, { execClientConfig: cannedResponseMap, args: strings.Split("--timeout 2s virtualservice foo.default", " "), wantException: false,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
@Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { recordedTasks = tasks; recordedTimeout = timeout; recordedTimeUnit = unit; try { return tasks.iterator().next().call(); } catch (Exception e) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Fri Jun 02 12:45:23 GMT 2023 - 4.5K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} } // DeadlineWorker implements the deadline/timeout resiliency pattern. type DeadlineWorker struct { timeout time.Duration } // NewDeadlineWorker constructs a new DeadlineWorker with the given timeout. // To return values, use the WithDeadline helper instead. func NewDeadlineWorker(timeout time.Duration) *DeadlineWorker { dw := &DeadlineWorker{ timeout: timeout, } return dw }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0)