Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 492 for CLOCK (0.21 sec)

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