- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 492 for CLOCK (0.21 sec)
-
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/slf4j/OutputEventListenerBackedLogger.java
import org.gradle.internal.time.Clock; public class OutputEventListenerBackedLogger extends BuildOperationAwareLogger { private final String name; private final OutputEventListenerBackedLoggerContext context; private final Clock clock; public OutputEventListenerBackedLogger(String name, OutputEventListenerBackedLoggerContext context, Clock clock) { this.name = name;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 2K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/legacy/DefaultBuildScanClock.java
import org.gradle.internal.time.Clock; import javax.inject.Inject; public class DefaultBuildScanClock implements BuildScanClock { private final Clock clock; @Inject public DefaultBuildScanClock(Clock clock) { this.clock = clock; } @Override public long getCurrentTime() { return clock.getCurrentTime(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 15 17:58:47 UTC 2024 - 1.1K bytes - Viewed (0) -
pkg/kubelet/active_deadline.go
recorder record.EventRecorder, clock clock.Clock, ) (*activeDeadlineHandler, error) { // check for all required fields if clock == nil || podStatusProvider == nil || recorder == nil { return nil, fmt.Errorf("required arguments must not be nil: %v, %v, %v", clock, podStatusProvider, recorder) } return &activeDeadlineHandler{ clock: clock, podStatusProvider: podStatusProvider,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting_test.go
} }() clock.Run(nil) expectGotValue(t, gots, aval) goGetAndExpect(t, clock, counter, wr, gots, aval) later := time.Now() bval := &later func() { lock.Lock() defer lock.Unlock() if wr.Set(bval) { t.Error("second Set() returned true") } }() goGetAndExpect(t, clock, counter, wr, gots, aval) counter.Add(1) // account for unblocking the receive on doneCh close(doneCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/services/DefaultStyledTextOutputFactory.java
import org.gradle.internal.time.Clock; public class DefaultStyledTextOutputFactory extends AbstractStyledTextOutputFactory implements StyledTextOutputFactory { private final OutputEventListener outputEventListener; private final Clock clock; public DefaultStyledTextOutputFactory(OutputEventListener outputEventListener, Clock clock) { this.outputEventListener = outputEventListener;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/JUnitTestClassProcessor.java
import org.gradle.internal.id.IdGenerator; import org.gradle.internal.time.Clock; public class JUnitTestClassProcessor extends AbstractJUnitTestClassProcessor { private final IdGenerator<?> idGenerator; private final JUnitSpec spec; private final Clock clock; public JUnitTestClassProcessor(JUnitSpec spec, IdGenerator<?> idGenerator, ActorFactory actorFactory, Clock clock) { super(actorFactory); this.spec = spec;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
}) } // TestableConfig carries the parameters to an implementation that is testable type TestableConfig struct { // Name of the controller Name string // Clock to use in timing deliberate delays Clock clock.PassiveClock // AsFieldManager is the string to use in the metadata for // server-side apply. Normally this is // `ConfigConsumerAsFieldManager`. This is exposed as a parameter
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 8K bytes - Viewed (0) -
platforms/core-runtime/build-profile/src/main/java/org/gradle/profile/ProfileCoordinator.java
import org.gradle.internal.time.Clock; @ServiceScope(Scope.BuildTree.class) public class ProfileCoordinator implements RootBuildLifecycleListener { private final BuildProfile profile; private final ReportGeneratingProfileListener generator; private final Clock clock; public ProfileCoordinator(BuildProfile profile, ReportGeneratingProfileListener generator, Clock clock) { this.profile = profile;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache.go
} // NewLRUExpireCacheWithClock creates an expiring cache with the given size, using the specified clock to obtain the current time. func NewLRUExpireCacheWithClock(maxSize int, clock Clock) *LRUExpireCache { if maxSize <= 0 { panic("maxSize must be > 0") } return &LRUExpireCache{ clock: clock, maxSize: maxSize, entries: map[interface{}]*list.Element{}, } } type cacheEntry struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods.go
// NewPodEvaluator returns an evaluator that can evaluate pods func NewPodEvaluator(f quota.ListerForResourceFunc, clock clock.Clock) quota.Evaluator { listFuncByNamespace := generic.ListResourceUsingListerFunc(f, corev1.SchemeGroupVersion.WithResource("pods")) podEvaluator := &podEvaluator{listFuncByNamespace: listFuncByNamespace, clock: clock} return podEvaluator } // podEvaluator knows how to measure usage of pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 17.4K bytes - Viewed (0)