Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 221 - 230 of 302 for shutDown (0.45 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top