- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 810 for isShutdown (0.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
serializer = ExecutionSequencer.create(); firstFuture = SettableFuture.create(); firstCallable = new TestCallable(firstFuture); } @Override public void tearDown() throws Exception { executor.shutdown(); } public void testCallableStartsAfterFirstFutureCompletes() { @SuppressWarnings({"unused", "nullness"}) Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
platforms/core-runtime/logging/src/integTest/resources/org/gradle/internal/logging/LoggingIntegrationTest/multiThreaded/build.gradle
textOut.style(UserInput).text(iteration).style(Normal) textOut.println() } } } executor.shutdown() executor.awaitTermination(30, TimeUnit.SECONDS) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux_mips64le.go
{139, "EISNAM", "is a named type file"}, {140, "EREMOTEIO", "remote I/O error"}, {141, "EINIT", "unknown error 141"}, {142, "EREMDEV", "unknown error 142"}, {143, "ESHUTDOWN", "cannot send after transport endpoint shutdown"}, {144, "ETOOMANYREFS", "too many references: cannot splice"}, {145, "ETIMEDOUT", "connection timed out"}, {146, "ECONNREFUSED", "connection refused"}, {147, "EHOSTDOWN", "host is down"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 19:00:13 UTC 2024 - 34.7K bytes - Viewed (0) -
src/runtime/trace.go
throw("trace: reading after shutdown") } // Free all the empty buffers. for trace.empty != nil { buf := trace.empty trace.empty = buf.link sysFree(unsafe.Pointer(buf), unsafe.Sizeof(*buf), &memstats.other_sys) } // Clear trace.shutdown and other flags. trace.headerWritten = false trace.shutdown.Store(false) } unlock(&trace.lock) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherCleanupTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
.assertSuccessful() .assertCode(200) println("server1.requestCount ${server1.requestCount}") assertThat(server1.requestCount).isEqualTo(1) // Shutdown the proxy server if (cleanShutdown) { server1.shutdown() } // Now redirect with DNS to proxyServer2 // Then redirect socket connection to server2 dns["myproxy"] = listOf(proxyServer2)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue May 14 17:48:07 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
filter "istio.io/istio/pkg/kube/namespace" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/retry" ) func TestNamespaceController(t *testing.T) { client := kube.NewFakeClient() t.Cleanup(client.Shutdown) watcher := keycertbundle.NewWatcher() caBundle := []byte("caBundle") watcher.SetAndNotify(nil, nil, caBundle) meshWatcher := mesh.NewTestWatcher(&meshconfig.MeshConfig{}) stop := test.NewStop(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/LazyConsumerActionExecutor.java
builder.setCancellationToken(new DefaultCancellationTokenSource().token()); builder.setParameters(connectionParameters); builder.setEntryPoint("Request daemon shutdown when idle"); run(new ConsumerAction<Void>() { @Override public ConsumerOperationParameters getParameters() { return builder.build(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination_test.go
if test.signal == nil || test.signal != signalGot { t.Errorf("expected request context to have server shutdown signal: %p, but got: %p", test.signal, signalGot) } default: if signalGot != nil { t.Errorf("expected request context to not have server shutdown signal: %p, but got: %p", test.signal, signalGot) } } if test.wg == nil { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/truncate/truncate.go
return newEvent } func (b *backend) Run(stopCh <-chan struct{}) error { return b.delegateBackend.Run(stopCh) } func (b *backend) Shutdown() { b.delegateBackend.Shutdown() } func (b *backend) calcSize(e *auditinternal.Event) (int64, error) { s := &sizer{} if err := b.e.Encode(e, s); err != nil { return 0, err } return s.Size, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 29 00:03:53 UTC 2022 - 4.7K bytes - Viewed (0)