- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 262 for shutdowned (0.07 seconds)
-
internal/http/server.go
return srv.Serve(l) } return serve, err } // Shutdown - shuts down HTTP server. func (srv *Server) Shutdown() error { srv.listenerMutex.Lock() if srv.listener == nil { srv.listenerMutex.Unlock() return http.ErrServerClosed } srv.listenerMutex.Unlock() if atomic.AddUint32(&srv.inShutdown, 1) > 1 { // shutdown in progress return http.ErrServerClosed }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (0) -
android/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) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 7.2K bytes - Click Count (0) -
internal/event/target/nats_tls_contrib_test.go
natsserver "github.com/nats-io/nats-server/v2/test" ) func TestNatsConnTLSCustomCA(t *testing.T) { s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls.conf")) defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test",
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Apr 22 22:12:26 GMT 2025 - 2.7K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/aether/ResolverLifecycle.java
this.repositorySystemProvider = requireNonNull(repositorySystemProvider); } @PreDestroy public void shutdown() { repositorySystemProvider.get().shutdown(); }
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 1.6K bytes - Click Count (0) -
docs/ru/docs/advanced/testing-events.md
# Тестирование событий: lifespan и startup - shutdown { #testing-events-lifespan-and-startup-shutdown } Если вам нужно, чтобы `lifespan` выполнялся в ваших тестах, вы можете использовать `TestClient` вместе с оператором `with`: {* ../../docs_src/app_testing/tutorial004_py39.py hl[9:15,18,27:28,30:32,41:43] *}Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 902 bytes - Click Count (0) -
docs/es/docs/advanced/testing-events.md
# Eventos de testing: lifespan y startup - shutdown { #testing-events-lifespan-and-startup-shutdown } Cuando necesitas que `lifespan` se ejecute en tus tests, puedes usar el `TestClient` con un statement `with`: {* ../../docs_src/app_testing/tutorial004_py39.py hl[9:15,18,27:28,30:32,41:43] *} Puedes leer más detalles sobre ["Ejecutar lifespan en tests en el sitio oficial de documentación de Starlette."](https://www.starlette.dev/lifespan/#running-lifespan-in-tests)Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 632 bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/SuggesterRefactoringTest.java
assertEquals("Should return correct index name", indexName, indices.get(0)); // Cleanup client.admin().indices().prepareDelete(indexName).execute().actionGet(); suggester.shutdown(); } /** * Test getIndicesForAlias method with non-existing alias. * Verifies that the method returns an empty list for non-existing alias. */ @Test
Created: Sat Dec 20 13:04:59 GMT 2025 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 13.4K bytes - Click Count (0) -
cmd/signals.go
cancelGlobalContext() if httpServer := newHTTPServerFn(); httpServer != nil { 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 globalBrowserEnabled { if srv := newConsoleServerFn(); srv != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 04 17:02:39 GMT 2024 - 3.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
enterRun.countDown(); try { exitRun.await(); } catch (InterruptedException e) { throw new RuntimeException(e); } } @Override protected void shutDown() { assertTrue(startUpCalled); assertTrue(runCalled); assertFalse(shutDownCalled); shutDownCalled = true; assertEquals(expectedShutdownState, state()); } @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 12.9K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
() -> { service.shutdown(); try { // We'd like to log progress and failures that may arise in the // following code, but unfortunately the behavior of logging // is undefined in shutdown hooks. // This is because the logging code installs a shutdown hook of itsCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 45.2K bytes - Click Count (0)