- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 35 for unresponsive (0.39 sec)
-
src/net/http/h2_bundle.go
func (cc *http2ClientConn) closeConn() { t := time.AfterFunc(250*time.Millisecond, cc.forceCloseConn) defer t.Stop() cc.tconn.Close() } // A tls.Conn.Close can hang for a long time if the peer is unresponsive. // Try to shut it down more aggressively. func (cc *http2ClientConn) forceCloseConn() { tc, ok := cc.tconn.(*tls.Conn) if !ok { return } if nc := tc.NetConn(); nc != nil { nc.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
pkg/istio-agent/agent.go
if fi, err := os.Stat(path); err == nil && !fi.Mode().IsRegular() { return true } return false } // Checks whether the socket exists and is responsive. // If it doesn't exist, returns (false, nil) // If it exists and is NOT responsive, tries to delete the socket file. // If it can be deleted, returns (false, nil). // If it cannot be deleted, returns (false, error). // Otherwise, returns (true, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/resources/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/report/uikit.min.css
12px}.uk-table-small .uk-table-link>a{padding:10px 12px}@media (max-width:959px){.uk-table-responsive,.uk-table-responsive tbody,.uk-table-responsive td,.uk-table-responsive th,.uk-table-responsive tr{display:block}.uk-table-responsive thead{display:none}.uk-table-responsive td,.uk-table-responsive th{width:auto!important;max-width:none!important;min-width:0!important;overflow:visible!important;white-space:normal!important}.uk-table-responsive .uk-table-link:not(:first-child)>a,.uk-table-responsive td:not(:first-c...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 257.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** All waiting threads. */ @CheckForNull private volatile Waiter waiters; /** Constructor for use by subclasses. */ protected AbstractFuture() {} // Gets and Timed Gets // // * Be responsive to interruption // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the // waiters field. // * Future completion is defined by when #value becomes non-null/non SetFuture
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** All waiting threads. */ @CheckForNull private volatile Waiter waiters; /** Constructor for use by subclasses. */ protected AbstractFuture() {} // Gets and Timed Gets // // * Be responsive to interruption // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the // waiters field. // * Future completion is defined by when #value becomes non-null/non SetFuture
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
pkg/kubelet/kubelet_getters.go
containerName := containerDir.Name() containerPath := filepath.Join(volumePluginPath, containerName) // Switch to ReadDirNoStat at the subPathIndex level to prevent issues with stat'ing // mount points that may not be responsive subPaths, err := utilpath.ReadDirNoStat(containerPath) if err != nil { return volumes, fmt.Errorf("could not read directory %s: %v", containerPath, err) } for _, subPathDir := range subPaths {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/jvm/toolchains.adoc
==== <1> We declare a `JavaLauncher` property on the task. The property must be marked as a <<incremental_build.adoc#sec:task_input_nested_inputs,`@Nested` input>> to make sure the task is responsive to toolchain changes. <2> We obtain the toolchain spec from the `java` extension to use it as a default. <3> Using the `JavaToolchainService` we get a provider of the `JavaLauncher` that matches the toolchain.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 05:37:54 UTC 2024 - 24.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* }, * MoreExecutors.directExecutor()); * * Runtime.getRuntime().addShutdownHook(new Thread() { * public void run() { * // Give the services 5 seconds to stop to ensure that we are responsive to shutdown * // requests. * try { * manager.stopAsync().awaitStopped(5, TimeUnit.SECONDS); * } catch (TimeoutException timeout) { * // stopping timed out
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 31.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* }, * MoreExecutors.directExecutor()); * * Runtime.getRuntime().addShutdownHook(new Thread() { * public void run() { * // Give the services 5 seconds to stop to ensure that we are responsive to shutdown * // requests. * try { * manager.stopAsync().awaitStopped(5, TimeUnit.SECONDS); * } catch (TimeoutException timeout) { * // stopping timed out
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0) -
pkg/generated/openapi/zz_generated.openapi.go
Ref: ref("k8s.io/apimachinery/pkg/apis/meta/v1.Duration"), }, }, "NodeMonitorGracePeriod": { SchemaProps: spec.SchemaProps{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 3M bytes - Viewed (0)