Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 492 for CLOCK (0.05 sec)

  1. pkg/kubelet/token/token_manager_test.go

    		},
    	}
    	for _, c := range cases {
    		t.Run(c.name, func(t *testing.T) {
    			clock := testingclock.NewFakeClock(time.Time{}.Add(24 * time.Hour))
    			mgr := NewManager(nil)
    			mgr.clock = clock
    
    			mgr.set("key", &authenticationv1.TokenRequest{
    				Status: authenticationv1.TokenRequestStatus{
    					ExpirationTimestamp: metav1.Time{Time: mgr.clock.Now().Add(c.relativeExp)},
    				},
    			})
    			mgr.cleanup()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 04 00:16:47 UTC 2022
    - 16.2K bytes
    - Viewed (0)
  2. platforms/core-runtime/time/src/test/groovy/org/gradle/internal/time/MonotonicClockTest.groovy

            1 * nanoTime() >> START_NANOS
        }
    
        private Clock clock = new MonotonicClock(timeSource, SYNC_INTERVAL)
    
        def "prevents time from going backwards"() {
            when:
            setNanos 0
    
            then:
            clock.currentTime == START_MILLIS + 0
    
            when:
            setNanos 10
    
            then:
            clock.currentTime == START_MILLIS + 10
    
            when:
            setNanos 8
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 20:20:17 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/LauncherServices.java

                if (!requestMetaData.isInteractive()) {
                    return new NonInteractiveUserInputHandler();
                }
    
                return new DefaultUserInputHandler(outputEventListenerManager.getBroadcaster(), clock, inputReader);
            }
    
            @Provides
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jun 05 13:01:53 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/JUnitTestEventAdapter.java

        private final Clock clock;
        private final Object lock = new Object();
        private final Map<Description, TestDescriptorInternal> executing = new HashMap<Description, TestDescriptorInternal>();
        private final Set<Description> assumptionFailed = new HashSet<Description>();
    
        public JUnitTestEventAdapter(TestResultProcessor resultProcessor, Clock clock, IdGenerator<?> idGenerator) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 18 20:52:40 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  5. platforms/core-runtime/build-profile/src/main/java/org/gradle/profile/ProfileEventAdapter.java

        public ProfileEventAdapter(BuildProfile buildProfile, BuildStartedTime buildStartedTime, Clock clock) {
            this.buildProfile = buildProfile;
            this.buildStartedTime = buildStartedTime;
            this.clock = clock;
        }
    
        // BuildListener
        @Override
        public void beforeSettings(Settings settings) {
            long now = clock.getCurrentTime();
            buildProfile.setBuildStarted(now);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:39 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. platforms/jvm/testing-jvm/src/main/java/org/gradle/api/internal/tasks/testing/detection/DefaultTestExecuter.java

        private final ActorFactory actorFactory;
        private final ForkedTestClasspathFactory testClasspathFactory;
        private final WorkerLeaseService workerLeaseService;
        private final int maxWorkerCount;
        private final Clock clock;
        private final DocumentationRegistry documentationRegistry;
        private final DefaultTestFilter testFilter;
        private TestClassProcessor processor;
    
        public DefaultTestExecuter(
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 18 20:52:40 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  7. platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java

     * in between syncs with the system wall clock.
     * When issuing the first timestamp after the sync interval has expired,
     * The system wall clock will be read, and the current time set to the max of wall clock time or the most recently issued timestamp.
     * All other timestamps are calculated as the wall clock time at last sync + elapsed time since.
     * <p>
     * This clock deals relatively well when the system wall clock shift is adjusted by small amounts.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 20:20:17 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. platforms/core-runtime/time/src/main/java/org/gradle/internal/time/Time.java

         */
        public static Clock clock() {
            return CLOCK;
        }
    
        /**
         * Replacement for System.currentTimeMillis(), based on {@link #clock()}.
         */
        public static long currentTimeMillis() {
            return CLOCK.getCurrentTime();
        }
    
        /**
         * Measures elapsed time.
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 20:20:17 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. pkg/kubelet/util/queue/work_queue.go

    }
    
    type basicWorkQueue struct {
    	clock clock.Clock
    	lock  sync.Mutex
    	queue map[types.UID]time.Time
    }
    
    var _ WorkQueue = &basicWorkQueue{}
    
    // NewBasicWorkQueue returns a new basic WorkQueue with the provided clock
    func NewBasicWorkQueue(clock clock.Clock) WorkQueue {
    	queue := make(map[types.UID]time.Time)
    	return &basicWorkQueue{queue: queue, clock: clock}
    }
    
    func (q *basicWorkQueue) GetWork() []types.UID {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 10:20:09 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  10. pkg/kubelet/util/queue/work_queue_test.go

    	// Dial the time to 1 hour ahead.
    	clock.Step(time.Hour)
    	expected = []types.UID{types.UID("foo3"), types.UID("foo4")}
    	compareResults(t, expected, q.GetWork())
    	compareResults(t, []types.UID{}, q.GetWork())
    }
    
    func TestNewBasicWorkQueue(t *testing.T) {
    	tests := []struct {
    		clock             clock.Clock
    		expectedWorkQueue WorkQueue
    	}{
    		{
    			clock:             clock.RealClock{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top