- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 198 for isShutdown (0.66 sec)
-
okhttp/src/test/java/okhttp3/SocksProxyTest.kt
private val socksProxy = SocksProxy() @BeforeEach fun setUp(server: MockWebServer) { this.server = server socksProxy.play() } @AfterEach fun tearDown() { socksProxy.shutdown() } @Test fun proxy() { server.enqueue(MockResponse.Builder().body("abc").build()) server.enqueue(MockResponse.Builder().body("def").build()) val client =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ThrottlingOutputEventListener.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 3.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/HttpBuildCacheServer.groovy
this.provider = provider this.webapp = new WebAppContext() // The following code is because of a problem under Windows: the file descriptors are kept open under JDK 11 // even after server shutdown, which prevents from deleting the test directory this.webapp.setInitParameter("org.eclipse.jetty.servlet.Default.useFileMappedBuffer", "false") } TestFile getCacheDir() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/project/antbuilder/FinalizerThread.java
Map.Entry<ClassPath, Cleanup> entry = cleanups.entrySet().iterator().next(); removeCacheEntry(entry.getKey(), entry.getValue(), CLOSE_CLASSLOADER); } LOG.debug("Completed shutdown"); } finally { lock.unlock(); } } public void putCleanup(ClassPath key, Cleanup cleanup) { cleanups.put(key, cleanup); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
}, }) return c } func (c *crdRegistrationController) Run(workers int, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() // make sure the work queue is shutdown which will trigger workers to end defer c.queue.ShutDown() klog.Infof("Starting crd-autoregister controller") defer klog.Infof("Shutting down crd-autoregister controller") // wait for your secondary caches to fill before starting your work
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/ContinuousBuildGateIntegrationTest.groovy
inputFile.text = "changed" pending.waitForAllPendingCalls() pending.releaseAll() and: // command the gate keeper to open the gate and shutdown command.releaseAll() server.expect(server.get("command").send("stop")) then: // waits for build to start and finish buildTriggeredAndSucceeded()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/invocation/GradleLifecycleUnsupportedTypesIntegrationTest.groovy
executorServiceTypeOnCurrentJvm() | Executor | "java.util.concurrent.Executors.newSingleThreadExecutor().tap { shutdown() }" ByteArrayInputStream | InputStream | "new java.io.ByteArrayInputStream([] as byte[])" ByteArrayOutputStream | OutputStream | "new java.io.ByteArrayOutputStream()"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 18:15:52 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go
// including shutting down its storage layer. cancel(errors.New("tearing down")) // If the apiextensions apiserver was started, let's wait for // it to shutdown clearly. if errCh != nil { err, ok := <-errCh if ok && err != nil { klog.Errorf("Failed to shutdown test server clearly: %v", err) } } if len(result.TmpDir) != 0 { os.RemoveAll(result.TmpDir) } } defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 9K bytes - Viewed (1) -
pilot/pkg/xds/discovery_test.go
return false } } func TestSendPushesManyPushes(t *testing.T) { stopCh := make(chan struct{}) defer close(stopCh) semaphore := make(chan struct{}, 2) queue := NewPushQueue() defer queue.ShutDown() proxies := createProxies(5) pushes := make(map[string]int) pushesMu := &sync.Mutex{} for _, proxy := range proxies { proxy := proxy // Start receive thread go func() { for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
} c := NewController(opts.Client, options) meshServiceController.AddRegistry(c) if opts.ServiceHandler != nil { c.AppendServiceHandler(opts.ServiceHandler) } t.Cleanup(func() { c.client.Shutdown() }) if !opts.SkipRun { t.Cleanup(func() { assert.NoError(t, queue.WaitForClose(c.queue, time.Second*5)) }) } c.stop = stop if cleanupStop { t.Cleanup(func() { close(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0)