- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 161 for MONITOR (0.12 sec)
-
pilot/pkg/config/memory/controller.go
type Controller struct { monitor Monitor configStore model.ConfigStore hasSynced func() bool // If meshConfig.DiscoverySelectors are specified, the namespacesFilter tracks the namespaces this controller watches. namespacesFilter func(obj interface{}) bool } // NewController return an implementation of ConfigStoreController // This is a client-side monitor that dispatches events as the changes are being
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
if (e == null) throw new NullPointerException(); final Monitor monitor = this.monitor; monitor.enterWhen(notFull); try { insert(e); } finally { monitor.leave(); } } @CanIgnoreReturnValue @Override public @Nullable E poll() { final Monitor monitor = this.monitor; if (monitor.enterIf(notEmpty)) { try { return extract();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
return "stopping({from = " + from + "})"; } }; } private final Monitor monitor = new Monitor(); private final Guard isStartable = new IsStartableGuard(); @WeakOuter private final class IsStartableGuard extends Guard { IsStartableGuard() { super(AbstractService.this.monitor); } @Override public boolean isSatisfied() { return state() == NEW;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
logger.Info("QuotaMonitor created object count evaluator", "resource", resource.GroupResource()) } // track the monitor current[resource] = &monitor{controller: c} added++ } qm.monitors = current for _, monitor := range toRemove { if monitor.stopCh != nil { close(monitor.stopCh) } } logger.V(4).Info("quota synced monitors", "added", added, "kept", kept, "removed", len(toRemove))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2); assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard)); } public void testHasWaitersWithWrongMonitorThrowsIMSE() { Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2); assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard)); } public void testHasWaitersWithWrongMonitorThrowsIMSE() { Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/health/gc/GarbageCollectionMonitorTest.groovy
given: def monitor = new DefaultGarbageCollectionMonitor(GarbageCollectorMonitoringStrategy.UNKNOWN, scheduledExecutorService) when: monitor.getHeapStats() then: noExceptionThrown() } def "non-heap stats defaults to empty given unknown garbage collector"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
@Override protected void runTest() throws Throwable { Monitor monitor = new Monitor(fair); FlagGuard guard = new FlagGuard(monitor); Object[] arguments = (timed ? new Object[] {guard, 0L, TimeUnit.MILLISECONDS} : new Object[] {guard}); try { method.invoke(monitor, arguments); fail("expected IllegalMonitorStateException");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 25.8K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
if (e == null) throw new NullPointerException(); final Monitor monitor = this.monitor; monitor.enterWhen(notFull); try { insert(e); } finally { monitor.leave(); } } @CanIgnoreReturnValue @Override public @Nullable E poll() { final Monitor monitor = this.monitor; if (monitor.enterIf(notEmpty)) { try { return extract();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
cluster/images/etcd-version-monitor/Makefile
cp etcd-version-monitor.go Dockerfile $(TEMP_DIR) # Compile etcd-version-monitor. docker run --rm -it \ -v $(shell pwd)/../../../:/go/src/k8s.io/kubernetes \ -v $(TEMP_DIR):/build \ -e GOARCH=$(ARCH) \ golang:$(GOLANG_VERSION) \ /bin/bash -c "CGO_ENABLED=0 go build -o /build/etcd-version-monitor k8s.io/kubernetes/cluster/images/etcd-version-monitor" docker build -t $(IMAGE) $(TEMP_DIR)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 11 07:06:46 UTC 2023 - 1.5K bytes - Viewed (0)