- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for GracefulStop (0.15 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/ShutdownCoordinator.java
this.client = client; } @Override public void daemonStarted(DaemonConnectDetails daemon) { daemons.add(daemon); } @Override public void stop() { client.gracefulStop(daemons); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonStopClient.java
this.stopDispatcher = new StopDispatcher(); } /** * Requests that the given daemons stop when idle. Does not block and returns before the daemons have all stopped. */ public void gracefulStop(Collection<DaemonConnectDetails> daemons) { for (DaemonConnectDetails daemon : daemons) { DaemonClientConnection connection = connector.maybeConnect(daemon); if (connection == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonStopClientTest.groovy
def "requests daemons stop gracefully"() { def daemon1 = Stub(DaemonConnectDetails) def daemon2 = Stub(DaemonConnectDetails) when: client.gracefulStop([daemon1, daemon2]) then: 1 * connector.maybeConnect(daemon1) >>> connection _ * connection.daemon >> daemon1 1 * connection.dispatch({it instanceof StopWhenIdle})
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/client_test.go
drapbv1alpha3.RegisterNodeServer(s, fakeGRPCServer) default: return "", nil, fmt.Errorf("unsupported version: %s", version) } go func() { go s.Serve(listener) <-closeCh s.GracefulStop() }() return addr, teardown, nil } func TestGRPCConnIsReused(t *testing.T) { addr, teardown, err := setupFakeGRPCServer(v1alpha3Version) if err != nil { t.Fatal(err) } defer teardown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/adsc/delta_test.go
discovery.RegisterAggregatedDiscoveryServiceServer(xds, new(mockDeltaXdsServer)) go func() { err = xds.Serve(l) if err != nil { log.Error(err) } }() defer xds.GracefulStop() if err != nil { t.Errorf("Could not start serving ads server %v", err) return } tt.inClient = NewDeltaWithBackoffPolicy(tt.inClient.cfg.Address, tt.inClient.cfg, nil, handlers...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
if s.secureGrpcServer != nil { s.secureGrpcServer.Stop() } close(stopped) } }() s.grpcServer.GracefulStop() if s.secureGrpcServer != nil { s.secureGrpcServer.GracefulStop() } close(stopped) }() t := time.NewTimer(s.shutdownDuration) select { case <-t.C: s.grpcServer.Stop() if s.secureGrpcServer != nil { s.secureGrpcServer.Stop() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/adsc/adsc_test.go
discovery.RegisterAggregatedDiscoveryServiceServer(xds, new(testAdscRunServer)) go func() { err = xds.Serve(l) if err != nil { log.Println(err) } }() defer xds.GracefulStop() if err != nil { t.Errorf("Could not start serving ads server %v", err) return } if err := tt.inAdsc.Dial(); err != nil { t.Errorf("Dial error: %v", err) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 15.4K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
listener, err := net.Listen("tcp", ":0") if err != nil { t.Errorf("failed to allocate unused port %v", err) } go appServer.Serve(listener) defer appServer.GracefulStop() appPort := listener.Addr().(*net.TCPAddr).Port // Starts the pilot agent status server. server := NewTestServer(t, Options{ KubeAppProbers: fmt.Sprintf(` { "/app-health/foo/livez": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager_test.go
timeout := *pluginClientTimeout * 2 fakeDRADriverGRPCServer.timeout = &timeout } drapbv1.RegisterNodeServer(s, fakeDRADriverGRPCServer) go func() { go s.Serve(l) <-stopCh s.GracefulStop() }() return fakeDRAServerInfo{ server: fakeDRADriverGRPCServer, socketName: socketName, teardownFn: teardown, }, nil } func TestNewManagerImpl(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:29 UTC 2024 - 42K bytes - Viewed (0)