- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 810 for isShutdown (0.14 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
} open fun enqueueResponse(response: MockResponse) { responseQueue.add(response) } open fun clear() { responseQueue.clear() } override fun shutdown() { responseQueue.add(DEAD_LETTER) } open fun setFailFast(failFast: Boolean) { val failFastResponse = if (failFast) { MockResponse(code = HttpURLConnection.HTTP_NOT_FOUND)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/graceful_shutdown_test.go
t.Errorf("unexpected response proto: %v, expected: %v", resp.Proto, expectedProto) } } // this function starts the graceful shutdown go func() { <-startServerShutdown // signal from the backend after receiving all (25) requests backendServer.Config.Shutdown(context.Background()) }() wg := sync.WaitGroup{} wg.Add(25) for i := 0; i < 25; i++ { go sendRequest(&wg) } wg.Wait()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
} select { case m.incoming <- Event{action, obj}: return true, nil default: return false, nil } } // Shutdown disconnects all watchers (but any queued events will still be distributed). // You must not call Action or Watch* after calling Shutdown. This call blocks // until all events have been distributed through the outbound channels. Note
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
} } private val backend = TaskRunner.RealBackend(threadFactory) private val taskRunner = TaskRunner(backend) private val queue = taskRunner.newQueue() @AfterEach fun tearDown() { backend.shutdown() } @Test fun test() { val t1 = System.nanoTime() / 1e6 val delays = mutableListOf(TimeUnit.MILLISECONDS.toNanos(1000), -1L) queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(750)) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/union_test.go
f.events = append(f.events, events...) return true } func (f *fakeBackend) Run(stopCh <-chan struct{}) error { return nil } func (f *fakeBackend) Shutdown() { // Nothing to do here. } func (f *fakeBackend) String() string { return "" } func TestUnion(t *testing.T) { backends := []Backend{ new(fakeBackend), new(fakeBackend),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 20 09:51:25 UTC 2022 - 2.6K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
func (p *PushQueue) Pending() int { p.cond.L.Lock() defer p.cond.L.Unlock() return len(p.queue) } // ShutDown will cause queue to ignore all new items added to it. As soon as the // worker goroutines have drained the existing items in the queue, they will be // instructed to exit. func (p *PushQueue) ShutDown() { p.cond.L.Lock() defer p.cond.L.Unlock() p.shuttingDown = true p.cond.Broadcast()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
server2.start() server2.start() server2.shutdown() } @Test fun shutdownTwice() { val server2 = MockWebServer() server2.start() server2.shutdown() try { server2.start() fail<Unit>() } catch (expected: IllegalStateException) { // Expected. } server2.shutdown() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
pkg/registry/core/pod/rest/subresources.go
// New returns an empty podProxyOptions object. func (r *ProxyREST) New() runtime.Object { return &api.PodProxyOptions{} } // Destroy cleans up resources on shutdown. func (r *ProxyREST) Destroy() { // Given that underlying store is shared with REST, // we don't destroy it here explicitly. } // ConnectMethods returns the list of HTTP methods that can be proxied
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
}) // When the test is done, terminate the client. This ensures all informers are closed. // This usually doesn't matter, but can be useful when mutating global state with test.SetForTest, etc. defer c.Shutdown() // Normally: t.Cleanup(c.Shutdown) // Build our controller controller := NewController(c) // Ensure our queue finished processing events defer func() { // Normally: assert.NoError(t, ...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
docs/de/docs/advanced/testing-events.md
# Events testen: Hochfahren – Herunterfahren Wenn Sie in Ihren Tests Ihre Event-Handler (`startup` und `shutdown`) ausführen wollen, können Sie den `TestClient` mit einer `with`-Anweisung verwenden: ```Python hl_lines="9-12 20-24" {!../../../docs_src/app_testing/tutorial003.py!}
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 30 20:17:40 UTC 2024 - 291 bytes - Viewed (0)