- Sort Score
- Num 10 results
- Language All
Results 221 - 230 of 302 for shutDown (0.06 seconds)
-
CHANGELOG/CHANGELOG-1.12.md
### SIG OpenStack - Openstack now supports the node shutdown taint. The taint is added when an instance is shutdown in openstack. ([#67982](https://github.com/kubernetes/kubernetes/pull/67982), [@zetaab](https://github.com/zetaab)) ### SIG Scheduling
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Feb 06 06:04:15 GMT 2020 - 293.8K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.20.md
### Introducing Graceful Node Shutdown (Alpha) The `GracefulNodeShutdown` feature is now in Alpha. This allows kubelet to be aware of node system shutdowns, enabling graceful termination of pods during a system shutdown. This feature can be [enabled through feature gate](https://docs.k8s.io/concepts/architecture/nodes/#graceful-node-shutdown). ### Runtime log sanitation
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Wed Jan 19 21:05:45 GMT 2022 - 409K bytes - Click Count (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
latch.countDown(); } }); } assertTrue(latch.await(10, TimeUnit.SECONDS), "Concurrent operations should complete"); executor.shutdown(); // Circuit breaker should have handled concurrent operations assertTrue(successCount.get() > 0, "Should have some successful operations");
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 23.2K bytes - Click Count (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
executor.execute(() -> { try { drainQueue(); } catch (Throwable e) { e.printStackTrace(); } }); } executor.shutdown(); } private void drainQueue() throws Exception { for (HttpUrl url; (url = queue.take()) != null; ) { if (!fetchedUrls.add(url)) { continue; }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jul 23 00:58:06 GMT 2025 - 5K bytes - Click Count (0) -
src/test/java/jcifs/tests/persistent/PersistentHandleManagerTest.java
manager = new PersistentHandleManager(mockContext); } @AfterEach public void tearDown() throws IOException { if (manager != null) { manager.shutdown(); } // Clean up system property System.clearProperty("jcifs.smb.client.handleStateDirectory"); // Clean up temp directory if (tempDir != null && Files.exists(tempDir)) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 04:51:33 GMT 2025 - 6.6K bytes - Click Count (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
if (logger.isDebugEnabled()) { logger.debug("TimeoutManagerThread stopped."); } thread = null; try { executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) {
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 7.8K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java
latch.countDown(); } }); } // Then assertTrue(latch.await(10, TimeUnit.SECONDS), "All threads should complete"); executor.shutdown(); assertEquals(0, collisions.get(), "There should be no nonce collisions"); assertEquals(threadCount * noncesPerThread, allNonces.size(), "All nonces should be unique"); } @Test
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 44.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
} }); } startLatch.countDown(); // Start all threads boolean completed = endLatch.await(10, TimeUnit.SECONDS); executor.shutdown(); assertTrue(completed, "All threads should complete without deadlock"); assertEquals(threadCount * operationsPerThread, completedOps.get(), "All operations should complete"); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 43.7K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.21.md
- Kubelet Graceful Node Shutdown feature graduates to Beta and enabled by default. ([#99735](https://github.com/kubernetes/kubernetes/pull/99735), [@bobbypage](https://github.com/bobbypage))
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Fri Oct 14 07:03:14 GMT 2022 - 367.3K bytes - Click Count (0) -
cmd/erasure-object-conditional_test.go
func TestPutObjectConditionalWithReadQuorumFailure(t *testing.T) { ctx := context.Background() obj, fsDirs, err := prepareErasure16(ctx) if err != nil { t.Fatal(err) } defer obj.Shutdown(context.Background()) defer removeRoots(fsDirs) z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] bucket := "test-bucket" object := "test-object"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 4.9K bytes - Click Count (0)