- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 492 for CLOCK (0.18 sec)
-
pkg/kubelet/util/node_startup_latency_tracker_test.go
package util import ( "strings" "testing" "time" "github.com/stretchr/testify/assert" "k8s.io/component-base/metrics/testutil" "k8s.io/kubernetes/pkg/kubelet/metrics" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) const ( metricsNameNodeStartupPreKubelet = "kubelet_node_startup_pre_kubelet_duration_seconds"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 05:54:25 UTC 2023 - 18K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/continuous/ContinuousBuildActionExecutor.java
private final DeploymentRegistryInternal deploymentRegistry; private final ListenerManager listenerManager; private final BuildStartedTime buildStartedTime; private final Clock clock; private final Stat stat; private final CaseSensitivity caseSensitivity; private final BuildLifecycleAwareVirtualFileSystem virtualFileSystem; private final ExecutorFactory executorFactory;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 17:41:07 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
// The channel from which the subscriber listens events. eventChannel chan *PodLifecycleEvent // Cache for storing the runtime states required for syncing pods. cache kubecontainer.Cache // For testability. clock clock.Clock // GenericPLEG is used to force relist when required. genericPleg podLifecycleEventGeneratorHandler // The maximum number of retries when getting container events from the runtime. eventedPlegMaxStreamRetries int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/health/gc/GarbageCollectionCheckTest.groovy
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.launcher.daemon.server.health.gc import org.gradle.internal.time.Clock import spock.lang.Specification import java.lang.management.GarbageCollectorMXBean import java.lang.management.ManagementFactory import java.lang.management.MemoryType
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.6K bytes - Viewed (0) -
src/time/time.go
// // Operating systems provide both a “wall clock,” which is subject to // changes for clock synchronization, and a “monotonic clock,” which is // not. The general rule is that the wall clock is for telling time and // the monotonic clock is for measuring time. Rather than split the API, // in this package the Time returned by [time.Now] contains both a wall // clock reading and a monotonic clock reading; later time-telling
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 50.7K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
return clockTick; } /** * Blocks until the clock has reached the given tick. The clock advances to the given tick when all test threads * have called {@link #syncAt(int)} or {@link #expectBlocksUntil(int, groovy.lang.Closure)} with the given tick, and * there are least 2 test threads. * * @param tick The expected clock tick */ public void syncAt(int tick) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
// used to implement OnNewLeader(), may lag slightly from the // value observedRecord.HolderIdentity if the transition has // not yet been reported. reportedLeader string // clock is wrapper around time to allow for less flaky testing clock clock.Clock // used to lock the observedRecord observedRecordLock sync.Mutex metrics leaderMetricsAdapter } // Run starts the leader election loop. Run will not return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/incremental/recomp/CurrentCompilationAccess.java
} public ClassSetAnalysisData analyzeOutputFolder(File outputFolder) { Timer clock = Time.startTimer(); ClassSetAnalysisData snapshot = classSetAnalyzer.analyzeOutputFolder(outputFolder); LOG.info("Class dependency analysis for incremental compilation took {}.", clock.getElapsed()); return snapshot; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/jvm/testing-junit-platform/src/main/java/org/gradle/api/internal/tasks/testing/junitplatform/JUnitPlatformTestExecutionListener.java
private final TestResultProcessor resultProcessor; private final Clock clock; private final IdGenerator<?> idGenerator; private TestPlan currentTestPlan; public JUnitPlatformTestExecutionListener(TestResultProcessor resultProcessor, Clock clock, IdGenerator<?> idGenerator) { this.resultProcessor = resultProcessor; this.clock = clock; this.idGenerator = idGenerator; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 06 06:58:25 UTC 2024 - 15K bytes - Viewed (1) -
pkg/quota/v1/install/update_filter.go
switch resource.GroupResource() { case schema.GroupResource{Resource: "pods"}: oldPod := oldObj.(*v1.Pod) newPod := newObj.(*v1.Pod) return core.QuotaV1Pod(oldPod, clock.RealClock{}) && !core.QuotaV1Pod(newPod, clock.RealClock{}) case schema.GroupResource{Resource: "services"}: oldService := oldObj.(*v1.Service) newService := newObj.(*v1.Service)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 08 22:39:55 UTC 2022 - 1.7K bytes - Viewed (0)