- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for startWatch (0.3 sec)
-
pkg/kubelet/config/file_unsupported.go
See the License for the specific language governing permissions and limitations under the License. */ package config import ( "fmt" "k8s.io/klog/v2" ) func (s *sourceFile) startWatch() { klog.ErrorS(nil, "Watching source file is unsupported in this build") } func (s *sourceFile) consumeWatchEvent(e *watchEvent) error { return fmt.Errorf("consuming watch event is unsupported in this build")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 908 bytes - Viewed (0) -
pkg/kubelet/config/file_linux.go
maxRetryPeriod = 20 * time.Second ) type retryableError struct { message string } func (e *retryableError) Error() string { return e.message } func (s *sourceFile) startWatch() { backOff := flowcontrol.NewBackOff(retryPeriod, maxRetryPeriod) backOffID := "watch" go wait.Forever(func() { if backOff.IsInBackOffSinceUpdate(backOffID, time.Now()) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kubelet/config/file.go
} case e := <-s.watchEvents: if err := s.consumeWatchEvent(e); err != nil { klog.ErrorS(err, "Unable to process watch event") } } } }() s.startWatch() } func (s *sourceFile) applyDefaults(pod *api.Pod, source string) error { return applyDefaults(pod, source, true, s.nodeName) } func (s *sourceFile) listConfig() error { path := s.path
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 6.2K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java
class ConsoleMavenTransferListenerTest { private CountDownLatch startLatch; private CountDownLatch endLatch; @Test void testTransferProgressedWithPrintResourceNames() throws Exception { int size = 1000; ExecutorService service = Executors.newFixedThreadPool(size * 2); startLatch = new CountDownLatch(size); endLatch = new CountDownLatch(size);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 5K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/FakeTickerTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 06 14:40:46 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/extensibility/test-kit/src/integTest/groovy/org/gradle/testkit/runner/GradleRunnerResultIntegrationTest.groovy
file("settings.gradle") << "include 'a', 'b', 'c', 'd'" buildFile << """ def startLatch = new java.util.concurrent.CountDownLatch(1) def stopLatch = new java.util.concurrent.CountDownLatch(1) project(":a") { task t { doLast { startLatch.countDown() // allow b to finish stopLatch.await() // wait for d to start }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 22:36:52 UTC 2023 - 4.5K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 06 14:40:46 UTC 2024 - 6.4K bytes - Viewed (0) -
src/os/removeall_test.go
if err != nil { t.Fatalf("Could not get wd: %s", err) } startPath, err := MkdirTemp("", "TestRemoveAllLongPath-") if err != nil { t.Fatalf("Could not create TempDir: %s", err) } defer RemoveAll(startPath) err = Chdir(startPath) if err != nil { t.Fatalf("Could not chdir %s: %s", startPath, err) } // Removing paths with over 4096 chars commonly fails
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:21:29 UTC 2024 - 12.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final CountDownLatch startLatch = new CountDownLatch(1); private final CountDownLatch stopLatch = new CountDownLatch(1); private volatile boolean running = false; @Override public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final CountDownLatch startLatch = new CountDownLatch(1); private final CountDownLatch stopLatch = new CountDownLatch(1); private volatile boolean running = false; @Override public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0)