- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 205 for isShutdown (0.25 sec)
-
pkg/kubelet/nodeshutdown/systemd/inhibit_linux.go
func (bus *DBusCon) InhibitShutdown() (InhibitLock, error) { obj := bus.SystemBus.Object(logindService, logindObject) what := "shutdown" who := "kubelet" why := "Kubelet needs time to handle node shutdown" mode := "delay" call := obj.Call("org.freedesktop.login1.Manager.Inhibit", 0, what, who, why, mode) if call.Err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 6.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
// which case we should skip right down to shutdown. if (isRunning()) { try { AbstractExecutionThreadService.this.run(); } catch (Throwable t) { restoreInterruptIfIsInterruptedException(t); try { shutDown(); } catch (Exception ignored) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/test/fakes/gce_metadata_server/main.go
log.Println("GCE metadata server started") <-done if err := s1.Shutdown(context.Background()); err != nil { log.Fatalf("GCE Metadata Shutdown Failed: %+v", err) } if err := s2.Shutdown(context.Background()); err != nil { log.Fatalf("GCE Metadata Shutdown Failed: %+v", err) } } func runServer(addr string, attrs map[string]string) *http.Server { r := mux.NewRouter()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 3.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
public void testStop_failed() { final Exception exception = new Exception("deliberate"); TestService service = new TestService() { @Override protected void shutDown() throws Exception { super.shutDown(); throw exception; } }; service.startAsync().awaitRunning(); assertEquals(1, service.startUpCalled); assertEquals(0, service.shutDownCalled);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/resources/org/gradle/play/integtest/fixtures/external/basicplayapp/conf/routes
# Routes # Home page GET / @controllers.Application.index GET /shutdown @controllers.Application.shutdown # Map static resources from the /public folder to the /assets URL path
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 313 bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/ResolverLifecycle.java
this.repositorySystemProvider = requireNonNull(repositorySystemProvider); } @PreDestroy public void shutdown() { repositorySystemProvider.get().shutdown(); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Dec 13 22:19:20 UTC 2023 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
}() } klog.Infof("Started %v workers for %v", c.options.Workers, c.options.Name) // Wait for context cancel. <-ctx.Done() // Forcefully shutdown workqueue. Drop any enqueued items. c.queue.ShutDown() // Workqueue shutdown signals for workers to stop. Wait for all workers to // clean up waitGroup.Wait() // Only way for workers to ever stop is for caller to cancel the context
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/signals.go
if err := httpServer.Shutdown(); err != nil && !errors.Is(err, http.ErrServerClosed) { shutdownLogIf(context.Background(), err) } } if objAPI := newObjectLayerFn(); objAPI != nil { shutdownLogIf(context.Background(), objAPI.Shutdown(context.Background())) } if srv := newConsoleServerFn(); srv != nil { shutdownLogIf(context.Background(), srv.Shutdown()) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 17:57:52 UTC 2024 - 2.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
public void testStop_failed() { final Exception exception = new Exception("deliberate"); TestService service = new TestService() { @Override protected void shutDown() throws Exception { super.shutDown(); throw exception; } }; service.startAsync().awaitRunning(); assertEquals(1, service.startUpCalled); assertEquals(0, service.shutDownCalled);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
src/net/fd_wasip1.go
import ( "syscall" ) func (fd *netFD) closeRead() error { if fd.fakeNetFD != nil { return fd.fakeNetFD.closeRead() } return fd.shutdown(syscall.SHUT_RD) } func (fd *netFD) closeWrite() error { if fd.fakeNetFD != nil { return fd.fakeNetFD.closeWrite() } return fd.shutdown(syscall.SHUT_WR)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 496 bytes - Viewed (0)