- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 810 for isShutdown (0.21 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
return delegate.dispatch(request.unwrap()).wrap() } override fun peek(): mockwebserver3.MockResponse { return delegate.peek().wrap() } override fun shutdown() { delegate.shutdown() } } } internal fun MockResponse.wrap(): mockwebserver3.MockResponse { val result = mockwebserver3.MockResponse.Builder() val copyFromWebSocketListener = webSocketListener
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
mockwebserver-junit5/src/main/kotlin/mockwebserver3/junit5/internal/MockWebServerExtension.kt
fun shutdownAll() { try { val toClear = servers.values.toList() servers.clear() for (server in toClear) { server.shutdown() } } catch (e: IOException) { logger.log(Level.WARNING, "MockWebServer shutdown failed", e) } } } @Suppress("NewApi") @IgnoreJRERequirement override fun supportsParameter( parameterContext: ParameterContext,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 11 12:12:36 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/windows/service/service.go
case svc.Interrogate: s <- c.CurrentStatus case svc.Stop, svc.Shutdown: klog.Infof("Service stopping") // We need to translate this request into a signal that can be handled by the signal handler // handling shutdowns normally (currently apiserver/pkg/server/signal.go). // If we do not do this, our main threads won't be notified of the upcoming shutdown.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 24 11:25:33 UTC 2022 - 3.3K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
@Test fun shutdownWithoutStart() { val server = MockWebServer() server.shutdown() } @Test fun closeViaClosable() { val server: Closeable = MockWebServer() server.close() } @Test fun shutdownWithoutEnqueue() { val server = MockWebServer() server.start() server.shutdown() } @Test fun portImplicitlyStarts() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
} else { logger.Error(nil, "kubeClient is nil", "controller", tc.name) klog.FlushAndExit(klog.ExitFlushTimeout, 1) } defer tc.broadcaster.Shutdown() defer tc.nodeUpdateQueue.ShutDown() defer tc.podUpdateQueue.ShutDown() // wait for the cache to be synced if !cache.WaitForNamedCacheSync(tc.name, ctx.Done(), tc.podListerSynced, tc.nodeListerSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
tests/test_tutorial/test_events/test_tutorial002.py
response = client.get("/items/") assert response.status_code == 200, response.text assert response.json() == [{"name": "Foo"}] with open("log.txt") as log: assert "Application shutdown" in log.read() def test_openapi_schema(app: FastAPI): with TestClient(app) as client: response = client.get("/openapi.json") assert response.status_code == 200, response.text
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Oct 18 12:36:40 UTC 2023 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/waitgroup.go
// which prevent unsafe Add. Add(delta int) error // Done decrements the WaitGroup counter. Done() } // WithWaitGroup adds all non long-running requests to wait group, which is used for graceful shutdown. func WithWaitGroup(handler http.Handler, longRunning apirequest.LongRunningRequestCheck, wg RequestWaitGroup) http.Handler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 10 21:18:55 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_others.go
limitations under the License. */ package nodeshutdown import ( "k8s.io/kubernetes/pkg/kubelet/lifecycle" ) // NewManager returns a fake node shutdown manager for non linux platforms. func NewManager(conf *Config) (Manager, lifecycle.PodAdmitHandler) { m := managerStub{} return m, m
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 15 03:16:21 UTC 2021 - 864 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY * frame) and an attempt is made to use the connection. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 875 bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/classloading/NoOpGroovySystemLoader.java
*/ package org.gradle.api.internal.classloading; /** * Doesn't need to do anything. */ public class NoOpGroovySystemLoader implements GroovySystemLoader { @Override public void shutdown() { } @Override public void discardTypesFrom(ClassLoader classLoader) { }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 02 16:56:13 UTC 2016 - 904 bytes - Viewed (0)