- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 417 for timeouts (0.19 sec)
-
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. //
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 11.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} responses := []*discovery.DiscoveryResponse{} xdsOpts := clioptions.CentralControlPlaneOptions{ XDSSAN: makeSan(istioNamespace, kubeClient.Revision()), CertDir: centralOpts.CertDir, Timeout: centralOpts.Timeout, } dialOpts, err := xds.DialOptions(xdsOpts, istioNamespace, tokenServiceAccount, kubeClient) if err != nil { return nil, err } for _, pod := range pods {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 13.6K bytes - Viewed (0) -
internal/http/dial_linux.go
// ~ cat /proc/sys/net/ipv4/tcp_keepalive_intvl (defaults to 75 secs, we reduce it to 15 secs) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15) } // Set tcp user timeout in addition to the keep-alive - tcp-keepalive is not enough to close a socket // with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/SmokeTests.kt
// Smoke tests is usually heavy and the build time is twice on EC2 agents requiresNotEc2Agent() } applyTestDefaults( model, this, ":smoke-test:$task", timeout = 120, extraParameters = listOf( stage.getBuildScanCustomValueParam(), buildScanTagParam("SmokeTests"), "-PtestJavaVersion=${testJava.version.major}",
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Sep 25 07:23:49 UTC 2024 - 1.2K bytes - Viewed (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)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
* cast: * * <pre> * {@code @SuppressWarnings("unchecked") // guaranteed by invokeAll contract} * {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks, timeout, unit);} * </pre> * * @return a list of {@code ListenableFuture} instances representing the tasks, in the same * sequential order as produced by the iterator for the given task list. If the operation did
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sun Jun 20 10:45:35 UTC 2021 - 4.2K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
// GetDefaultExpiration - returns the expiration seconds expected. func GetDefaultExpiration(dsecs string) (time.Duration, error) { timeout := env.Get(config.EnvMinioStsDuration, "") defaultExpiryDuration, err := time.ParseDuration(timeout) if err != nil { defaultExpiryDuration = time.Hour } if timeout == "" && dsecs != "" { expirySecs, err := strconv.ParseInt(dsecs, 10, 64) if err != nil { return 0, auth.ErrInvalidDuration
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 10 20:16:44 UTC 2024 - 16.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource /** Test how HTTP/2 interacts with HTTP features. */ @Timeout(60) @Flaky @Tag("Slow") class HttpOverHttp2Test {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt
fun takeRequest(): RecordedRequest { return delegate.takeRequest().unwrap() } @Throws(InterruptedException::class) fun takeRequest( timeout: Long, unit: TimeUnit, ): RecordedRequest? { return delegate.takeRequest(timeout, unit)?.unwrap() } @JvmName("-deprecated_requestCount") @Deprecated( message = "moved to val",
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 5.9K bytes - Viewed (0) -
.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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Nov 03 21:18:18 UTC 2023 - 1.2K bytes - Viewed (0)