- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 299 for isShutdown (0.15 sec)
-
src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux_sparc64.go
{55, "ENOBUFS", "no buffer space available"}, {56, "EISCONN", "transport endpoint is already connected"}, {57, "ENOTCONN", "transport endpoint is not connected"}, {58, "ESHUTDOWN", "cannot send after transport endpoint shutdown"}, {59, "ETOOMANYREFS", "too many references: cannot splice"}, {60, "ETIMEDOUT", "connection timed out"}, {61, "ECONNREFUSED", "connection refused"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 19:00:13 UTC 2024 - 38.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux_ppc64.go
{105, "ENOBUFS", "no buffer space available"}, {106, "EISCONN", "transport endpoint is already connected"}, {107, "ENOTCONN", "transport endpoint is not connected"}, {108, "ESHUTDOWN", "cannot send after transport endpoint shutdown"}, {109, "ETOOMANYREFS", "too many references: cannot splice"}, {110, "ETIMEDOUT", "connection timed out"}, {111, "ECONNREFUSED", "connection refused"}, {112, "EHOSTDOWN", "host is down"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 19:00:13 UTC 2024 - 36.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller_test.go
} func (m *mockWorkQueue) Get() (item string, shutdown bool) { <-m.addCalled switch m.count.Load() { case 0: return "", false case 1: return "", true default: panic("too many calls to Get") } } func (m *mockWorkQueue) Add(item string) { m.closeOnce.Do(func() { close(m.addCalled) }) } func (m *mockWorkQueue) ShutDown() {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/registry/core/namespace/storage/storage.go
func (r *REST) GetSingularName() string { return r.store.GetSingularName() } func (r *REST) New() runtime.Object { return r.store.New() } // Destroy cleans up resources on shutdown. func (r *REST) Destroy() { r.store.Destroy() } func (r *REST) NewList() runtime.Object { return r.store.NewList() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 13.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
executor.shutdown(); assertFalse(awaitTerminationUninterruptibly(executor, 1000, MILLISECONDS)); assertFalse(executor.isTerminated()); assertInterrupted(); } public void testTryAwaitTerminationInfiniteTimeout() { ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000)); executor.shutdown();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
// ShutdownSendRetryAfter dictates when to initiate shutdown of the HTTP // Server during the graceful termination of the apiserver. If true, we wait // for non longrunning requests in flight to be drained and then initiate a // shutdown of the HTTP Server. If false, we initiate a shutdown of the HTTP // Server as soon as ShutdownDelayDuration has elapsed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
UpdateLease(serverId string, ip string, endpointPorts []corev1.EndpointPort) error // RemoveEndpoints removes this apiserver's peer endpoint lease. RemoveLease(serverId string) error // Destroy cleans up everything on shutdown. Destroy() // StopReconciling turns any later ReconcileEndpoints call into a noop. StopReconciling() } type peerEndpointLeaseReconciler struct { serverLeases *peerEndpointLeases
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
runBatch(operation); } } catch (Throwable t) { addFailure(t); } finally { shutDown(); } } @Nullable private T waitForNextOperation() { lock.lock(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/server_run_options_test.go
MinRequestTimeout: 1800, JSONPatchMaxCopyBytes: 10 * 1024 * 1024, MaxRequestBodyBytes: 10 * 1024 * 1024, ShutdownDelayDuration: -time.Second, }, expectErr: "--shutdown-delay-duration can not be negative value", }, { name: "Test when HSTSHeaders is valid", testOptions: &ServerRunOptions{ AdvertiseAddress: netutils.ParseIPSloppy("192.168.10.10"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 10.9K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public abstract class mockwebserver3/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lmockwebserver3/RecordedRequest;)Lmockwebserver3/MockResponse; public fun peek ()Lmockwebserver3/MockResponse; public fun shutdown ()V } public final class mockwebserver3/MockResponse { public static final field Companion Lmockwebserver3/MockResponse$Companion; public fun <init> ()V public fun <init> (I)V public fun <init> (ILokhttp3/Headers;)V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0)