- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 328 for Timeout (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
.teamcity/src/main/kotlin/common/CommonExtensions.kt
artifactRules = rules publishArtifacts = PublishMode.ALWAYS } fun BuildType.applyDefaultSettings( os: Os = Os.LINUX, arch: Arch = Arch.AMD64, buildJvm: Jvm = BuildToolBuildJvm, timeout: Int = 30, artifactRuleOverride: String? = null, ) { val defaultArtifactRules = """ *.psoutput => $HIDDEN_ARTIFACT_DESTINATION *.threaddump => $HIDDEN_ARTIFACT_DESTINATIONCreated: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 13 05:03:56 GMT 2026 - 14.8K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
*/ public void setMaxRetryCount(final int maxRetryCount) { this.maxRetryCount = maxRetryCount; } /** * Sets the connection timeout in milliseconds. * * @param connTimeout The connection timeout. */ public void setConnTimeout(final long connTimeout) { this.connTimeout = connTimeout; } /**Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Nov 23 02:01:26 GMT 2025 - 26.2K bytes - Click Count (0) -
cmd/common-main.go
ctxt.SFTP = ctx.StringSlice("sftp") ctxt.Interface = ctx.String("interface") ctxt.UserTimeout = ctx.Duration("conn-user-timeout") ctxt.SendBufSize = ctx.Int("send-buf-size") ctxt.RecvBufSize = ctx.Int("recv-buf-size") ctxt.IdleTimeout = ctx.Duration("idle-timeout") ctxt.UserTimeout = ctx.Duration("conn-user-timeout") if conf := ctx.String("config"); len(conf) > 0 { err = mergeServerCtxtFromConfigFile(conf, ctxt) } else {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 32.5K bytes - Click Count (3) -
src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java
assertEquals(-1, result); } @Test public void test_setProcessDestroyTimeout() { processHelper.setProcessDestroyTimeout(20); // We can't directly verify the timeout value, but we can ensure the method doesn't throw assertTrue(true); } @Test public void test_sendCommand_jobNotFound() { try {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 16K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
} /** * Checks for expired registrations based on heartbeat timeouts. */ private void checkHeartbeats() { long timeout = context.getConfig().getWitnessHeartbeatTimeout(); for (WitnessRegistration registration : registrations.values()) { if (registration.isExpired(timeout)) { log.warn("Witness registration expired: {}", registration.getRegistrationId());Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 20.8K bytes - Click Count (0) -
src/test/java/jcifs/tests/persistent/HandleReconnectorTest.java
// Create an expired handle HandleInfo expiredHandle = new HandleInfo("/test/file.txt", new HandleGuid(), new byte[16], HandleType.DURABLE_V2, 100, // 100ms timeout null); // Wait for expiration Thread.sleep(150); CompletableFuture<HandleInfo> future = reconnector.reconnectHandle(expiredHandle, new IOException("Network error"));Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 04:51:33 GMT 2025 - 5.6K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/net/NetShareEnumTest.java
assertEquals((byte) 0x00, getFieldValue(netShareEnum, "maxSetupCount")); assertEquals(0, getFieldValue(netShareEnum, "setupCount")); assertEquals(5000, getFieldValue(netShareEnum, "timeout")); // Verify command and subcommand from parent class assertEquals(SmbComTransaction.SMB_COM_TRANSACTION, getFieldValue(netShareEnum, "command"));
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.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 Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
.github/workflows/iam-integrations.yaml
ETCD_ADVERTISE_CLIENT_URLS: "http://0.0.0.0:2379" ports: - "2379:2379" options: >- --health-cmd "etcdctl endpoint health" --health-interval 10s --health-timeout 5s --health-retries 5 openid: image: quay.io/minio/dex ports: - "5556:5556" env: DEX_LDAP_SERVER: "openldap:389" openid2:Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.3K bytes - Click Count (0) -
tensorflow/c/eager/c_api_experimental.cc
"Coordination service is not enabled."); return; } absl::Duration timeout; if (timeout_in_ms > 0) { timeout = absl::Milliseconds(timeout_in_ms); } else { // Block until the key-value is set or the worker shuts down. timeout = absl::InfiniteDuration(); } auto status_or_value = coord_agent->GetKeyValue(key, timeout); status->status = status_or_value.status(); if (!status_or_value.ok()) return;Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Sat Oct 12 05:11:17 GMT 2024 - 35.9K bytes - Click Count (0)