- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 290 for time_at (0.08 seconds)
-
.github/workflows/mint/minio-erasure.yaml
MINIO_ROOT_PASSWORD: "minio123" MINIO_KMS_SECRET_KEY: "my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw=" healthcheck: test: ["CMD", "mc", "ready", "local"] interval: 5s timeout: 5s retries: 5 # starts 4 docker containers running minio server instances. # using nginx reverse proxy, load balancing, you can access # it through port 9000. services: minio1: <<: *minio-common
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Nov 03 21:18:18 GMT 2023 - 1.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension /** Test how HTTP/2 interacts with HTTP features. */ @Timeout(60) @Flaky @Tag("Slow") @Burst class HttpOverHttp2Test( val protocol: Protocol = burstValues(Protocol.H2_PRIOR_KNOWLEDGE, Protocol.HTTP_2),Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 67.4K bytes - Click Count (0) -
cmd/xl-storage-disk-id-check.go
dctx, dcancel := context.WithCancel(ctx) started := time.Now() go func() { timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout()) select { case <-dctx.Done(): if !timeout.Stop() { <-timeout.C } case <-timeout.C: spent := time.Since(started) goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
clientListener.assertFailure( SocketTimeoutException::class.java, "timeout", "Read timed out", ) assertThat(webSocket.close(1000, null)).isFalse() } /** * There's no read timeout when reading the first byte of a new frame. But as soon as we start * reading a frame we enable the read timeout. In this test we have the server returning the first * byte of a frame but no more frames.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// This class can make no hard guarantees. The methods in this class are inherently flaky, but // we try hard to make them robust in practice. We could additionally try to add in a system // load timeout multiplier. Or we could try to use a CPU time bound instead of wall clock time // bound. But these ideas are harder to implement. We do not try to detect or handle a // user-specified -XX:+DisableExplicitGC. //Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 11.5K bytes - Click Count (0) -
.teamcity/src/main/kotlin/configurations/SmokeTests.kt
requiresNotEc2Agent() } applyTestDefaults( model, this, ":smoke-test:$task", timeout = if (flakyTestStrategy == FlakyTestStrategy.ONLY) 30 else 120, extraParameters = listOf( stage.getBuildScanCustomValueParam(), buildScanTagParam("SmokeTests"),
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Dec 22 07:15:16 GMT 2025 - 1.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension @Suppress("UsePropertyAccessSyntax") @Timeout(6) @Tag("slow") @Burst class SocketChannelTest { @JvmField @RegisterExtension val platform = PlatformRule() @JvmField @RegisterExtensionCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
BlockingQueue<T> q, Collection<? super T> buffer, int numElements, long timeout, TimeUnit unit, boolean interruptibly) throws InterruptedException { return interruptibly ? Queues.drain(q, buffer, numElements, timeout, unit) : Queues.drainUninterruptibly(q, buffer, numElements, timeout, unit); } public void testMultipleProducers() throws Exception {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
Http2ExchangeCodec(client, this, chain, http2Connection) } else { javaNetSocket.soTimeout = chain.readTimeoutMillis() okHttpSocket.source.timeout().timeout(chain.readTimeoutMillis.toLong(), MILLISECONDS) okHttpSocket.sink.timeout().timeout(chain.writeTimeoutMillis.toLong(), MILLISECONDS) Http1ExchangeCodec(client, this, okHttpSocket) } } internal fun useAsSocket() {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
* given time. * * @param timeout how long to wait before giving up, in units of [unit] * @param unit a [TimeUnit] determining how to interpret the [timeout] parameter * @return the head of the request queue */ @Throws(InterruptedException::class) public fun takeRequest( timeout: Long, unit: TimeUnit, ): RecordedRequest? = requestQueue.poll(timeout, unit) /**
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 02 20:36:00 GMT 2025 - 40.3K bytes - Click Count (0)