- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 198 for isShutdown (0.34 sec)
-
pilot/pkg/xds/pushqueue_test.go
t.Parallel() p := NewPushQueue() defer p.ShutDown() p.Enqueue(proxies[0], &model.PushRequest{}) p.Enqueue(proxies[1], &model.PushRequest{}) ExpectDequeue(t, p, proxies[0]) ExpectDequeue(t, p, proxies[1]) }) t.Run("remove too many", func(t *testing.T) { t.Parallel() p := NewPushQueue() defer p.ShutDown() p.Enqueue(proxies[0], &model.PushRequest{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
task: Task, delayNanos: Long = 0L, ) { taskRunner.lock.withLock { if (shutdown) { if (task.cancelable) { taskRunner.logger.taskLog(task, this) { "schedule canceled (queue is shutdown)" } return } taskRunner.logger.taskLog(task, this) { "schedule failed (queue is shutdown)" } throw RejectedExecutionException() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kube/kclient/events.go
e.eventRecorder.Eventf(object, eventtype, reason, messageFmt, args...) } // Shutdown terminates the event recorder. This must be called upon completion of writing events, and events should not be // written once terminated. func (e *EventRecorder) Shutdown() { e.eventBroadcaster.Shutdown()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 22:23:28 UTC 2023 - 1.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* message buffer (16 MiB) will be rejected and trigger a [graceful shutdown][close] of this web * socket. This method returns false in that case, and in any other case where this web socket is * closing, closed, or canceled. * * This method returns immediately. */ fun send(bytes: ByteString): Boolean /** * Attempts to initiate a graceful shutdown of this web socket. Any already-enqueued messages will
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/resources/org/gradle/play/integtest/fixtures/external/basicplayapp/conf/routes.old
# 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 - 310 bytes - Viewed (0) -
docs/ko/docs/advanced/events.md
하나 이상의 이벤트 핸들러 함수를 추가할 수도 있습니다. 그리고 응용 프로그램은 모든 `startup` 이벤트 핸들러가 완료될 때까지 요청을 받지 않습니다. ## `shutdown` 이벤트 응용 프로그램이 종료될 때 실행하려는 함수를 추가하려면 `"shutdown"` 이벤트로 선언합니다: ```Python hl_lines="6" {!../../../docs_src/events/tutorial002.py!} ``` 이 예제에서 `shutdown` 이벤트 핸들러 함수는 `"Application shutdown"`이라는 텍스트가 적힌 `log.txt` 파일을 추가할 것입니다. !!! info "정보"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 22:35:55 UTC 2024 - 2.2K bytes - Viewed (0) -
docs/zh/docs/advanced/events.md
本例中,`startup` 事件处理器函数为项目数据库(只是**字典**)提供了一些初始值。 **FastAPI** 支持多个事件处理器函数。 只有所有 `startup` 事件处理器运行完毕,**FastAPI** 应用才开始接收请求。 ## `shutdown` 事件 使用 `shutdown` 事件声明 `app` 关闭时运行的函数: ```Python hl_lines="6" {!../../../docs_src/events/tutorial002.py!} ``` 此处,`shutdown` 事件处理器函数在 `log.txt` 中写入一行文本 `Application shutdown`。 !!! info "说明" `open()` 函数中,`mode="a"` 指的是**追加**。因此这行文本会添加在文件已有内容之后,不会覆盖之前的内容。 !!! tip "提示"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
natsserver "github.com/nats-io/nats-server/v2/test" ) func TestNatsConnPlain(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14222 s := natsserver.RunServer(&opts) defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.3K 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/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.6K bytes - Viewed (0)