- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 810 for isShutdown (0.25 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/Dispatcher.kt
abstract fun dispatch(request: RecordedRequest): MockResponse open fun peek(): MockResponse { return MockResponse().apply { this.socketPolicy = SocketPolicy.KEEP_OPEN } } open fun shutdown() {}
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Oct 18 12:55:43 UTC 2020 - 909 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
return len(events) == 0 }() } }() return b.delegateBackend.Run(stopCh) } // Shutdown blocks until stopCh passed to the Run method is closed and all // events added prior to that moment are batched and sent to the delegate backend. func (b *bufferedBackend) Shutdown() { // Wait until the routine spawned in Run method exits. <-b.shutdownCh // Wait until all sending routines exit. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/cmd.go
envoyPrometheusPort int, enableProfiling bool, agent *istioagent.Agent, shutdown context.CancelFunc, ) error { o := options.NewStatusServerOptions(proxyArgs.IsIPv6(), proxyArgs.Type, proxyConfig, agent) o.EnvoyPrometheusPort = envoyPrometheusPort o.EnableProfiling = enableProfiling o.Context = ctx o.Shutdown = shutdown statusServer, err := status.NewServer(*o) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReuseIntegrationTest.groovy
given: // Start a daemon executer.run() daemons.daemon.assertIdle() // Kill the daemon without letting it shutdown cleanly daemons.daemon.kill() // Take over the daemon's port. The daemon may take some time to finally shutdown and release the port. def nonDaemonProcess = new ServerSocket() ConcurrentTestUtil.poll {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 10.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux_arm64.go
{105, "ENOBUFS", "no buffer space available"}, {106, "EISCONN", "transport endpoint is already connected"}, {107, "ENOTCONN", "transport endpoint is not connected"}, {108, "ESHUTDOWN", "cannot send after transport endpoint shutdown"}, {109, "ETOOMANYREFS", "too many references: cannot splice"}, {110, "ETIMEDOUT", "connection timed out"}, {111, "ECONNREFUSED", "connection refused"}, {112, "EHOSTDOWN", "host is down"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 34.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
proceed.countDown() t1.join() assertThat(idle.get()).isTrue() } @Test fun executionRejectedImmediately() { val request = newRequest("http://a/1") executor.shutdown() client.newCall(request).enqueue(callback) callback.await(request.url).assertFailure(InterruptedIOException::class.java) assertThat(listener.recordedEventTypes())
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
// namespace, and a shutdown boolean. If not shutdown then the return // must eventually be followed by a call on completeWork for the // returned namespace (regardless of whether the work item list is // empty). func (e *quotaEvaluator) getWork() (string, []*admissionWaiter, bool) { ns, shutdown := e.queue.Get() if shutdown { return "", []*admissionWaiter{}, shutdown } e.workLock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/ShutdownAwareConsumerConnection.java
super(delegate, modelMapping, adapter); } @Override public void stop() { ((StoppableConnection) getDelegate()).shutdown(new ShutdownParameters() { }); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/classloading/GroovySystemLoader.java
public interface GroovySystemLoader { /** * Invoked when this Groovy system is to be discarded, so that the Groovy system can remove any static state it may have registered in other ClassLoaders. */ void shutdown(); /** * Invoked when another ClassLoader is discarded, so that this Groovy system can remove state for the classes loaded from the ClassLoader */ void discardTypesFrom(ClassLoader classLoader);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 02 16:56:13 UTC 2016 - 1.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/JobExecutor.java
*/ package org.codelibs.fess.job; public abstract class JobExecutor { protected ShutdownListener shutdownListener; public abstract Object execute(String scriptType, String script); public void shutdown() { shutdownListener.onShutdown(); } public void addShutdownListener(final ShutdownListener listener) { shutdownListener = listener; } public interface ShutdownListener {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1K bytes - Viewed (0)