Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 67 for setitimer (0.16 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/eventclock/fake.go

    		if !ok || limit != nil && t.After(*limit) {
    			break
    		}
    		fec.SetTime(t)
    	}
    }
    
    // SetTime sets the time and runs to completion all events that should
    // be started by the given time --- including any further events they
    // schedule
    func (fec *Fake) SetTime(t time.Time) {
    	fec.FakePassiveClock.SetTime(t)
    	for {
    		foundSome := false
    		func() {
    			fec.waitersLock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 7.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram_test.go

    		ddt := time.Duration(rand.Intn(ddtRangeCentiPeriods)-ddtOffsetCentiPeriods) * steppingPeriod / 100
    		t1 = t1.Add(ddt)
    		diff := t1.Sub(t0)
    		if diff > dt {
    			dt = diff
    		}
    		clk.SetTime(t1)
    		tro.Set(1)
    		expectedCount := int64(dt / samplingPeriod)
    		actualCount, err := getHistogramCount(registry, histogramName)
    		if err != nil && !(err == errMetricNotFound && expectedCount == 0) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 13 16:03:06 UTC 2022
    - 8.7K bytes
    - Viewed (0)
  3. pkg/kubelet/util/pod_startup_latency_tracker_test.go

    		// first image starts pulling at 10s
    		fakeClock.SetTime(frozenTime.Add(time.Second * 10))
    		tracker.RecordImageStartedPulling(podInitializing.UID)
    		// second image starts pulling at 11s
    		fakeClock.SetTime(frozenTime.Add(time.Second * 11))
    		tracker.RecordImageStartedPulling(podInitializing.UID)
    		// third image starts pulling at 14s
    		fakeClock.SetTime(frozenTime.Add(time.Second * 14))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 06:09:49 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  4. platforms/core-runtime/base-services/src/test/groovy/org/gradle/util/internal/GFileUtilsTest.groovy

            child.text == "data"
        }
    
        def "uses fallback for touching empty files"() {
            given:
            def fileAttributeView = Stub(BasicFileAttributeView) {
                setTimes(_, _, _) >> { throw new FileSystemException("file: Operation not permitted") }
            }
            def path = Stub(java.nio.file.Path) {
                getFileSystem() >> Stub(FileSystem) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 10:50:51 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. subprojects/core/src/main/java/org/gradle/api/internal/file/archive/ZipCopyAction.java

            private void visitFile(FileCopyDetails fileDetails) {
                try {
                    ZipArchiveEntry archiveEntry = new ZipArchiveEntry(fileDetails.getRelativePath().getPathString());
                    archiveEntry.setTime(getArchiveTimeFor(fileDetails));
                    archiveEntry.setUnixMode(UnixStat.FILE_FLAG | fileDetails.getPermissions().toUnixNumeric());
                    zipOutStr.putArchiveEntry(archiveEntry);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Nov 08 14:16:53 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. subprojects/core/src/testFixtures/groovy/org/gradle/util/JarUtils.groovy

            def jarOut = new JarOutputStream(out)
            try {
                contents.each { file, fileContents ->
                    def zipEntry = new ZipEntry(file)
                    zipEntry.setTime(0)
                    jarOut.putNextEntry(zipEntry)
                    jarOut << fileContents
                }
            } finally {
                jarOut.close()
            }
            return out.toByteArray()
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Aug 07 19:17:11 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/convert/CalendarConversionUtil.java

                return (Calendar) o;
            }
            final java.util.Date date = DateConversionUtil.toDate(o, pattern);
            if (date != null) {
                final Calendar cal = Calendar.getInstance();
                cal.setTime(date);
                return cal;
            }
            return null;
        }
    
        /**
         * ローカルの{@link TimeZone}と{@link Locale}をもつ{@link Calendar}に変換します。
         *
         * @param calendar
    Registered: Wed Jun 12 12:50:12 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. src/cmd/distpack/archive.go

    			if err != nil {
    				log.Fatalf("archive remove: %v", err)
    			}
    			if match {
    				return false
    			}
    		}
    		return true
    	})
    }
    
    // SetTime sets the modification time of all files in the archive to t.
    func (a *Archive) SetTime(t time.Time) {
    	for i := range a.Files {
    		a.Files[i].Time = t
    	}
    }
    
    // RenameGoMod renames the go.mod files in the archive to _go.mod,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 11 17:37:52 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  9. pkg/kubelet/token/token_manager_test.go

    		name string
    		exp  time.Duration
    		f    func(t *testing.T, s *suite)
    	}{
    		{
    			name: "rotate hour token expires in the last 12 minutes",
    			exp:  time.Hour,
    			f: func(t *testing.T, s *suite) {
    				s.clock.SetTime(s.clock.Now().Add(50 * time.Minute))
    				if _, err := s.mgr.GetServiceAccountToken("a", "b", getTokenRequest()); err != nil {
    					t.Fatalf("unexpected error: %v", err)
    				}
    				if s.tg.count != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 04 00:16:47 UTC 2022
    - 16.2K bytes
    - Viewed (0)
  10. platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java

            }
            return result.getValue();
        }
    
        long backoffPeriodFor(int iteration) {
            return random.nextInt(Math.min(iteration, CAP_FACTOR)) * slotTime;
        }
    
        public CountdownTimer getTimer() {
            return timer;
        }
    
        public S getSignal() {
            return signal;
        }
    
        public interface Signal {
            Signal SLEEP = new Signal() {
                @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 12 08:49:35 UTC 2024
    - 4.8K bytes
    - Viewed (0)
Back to top