- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 875 for Millisecond (0.16 sec)
-
cmd/namespace-lock_test.go
t.Fatal("failed to acquire lock") } // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch) nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond) }() time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2 // Unlock the 1st lock; ref=1 after this line nsLk.unlock("volume", "path", false)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.1K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
"istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/util/sets" ) func TestGatewayHostnames(t *testing.T) { test.SetForTest(t, &model.MinGatewayTTL, 30*time.Millisecond) ttl := uint32(0) // second gwHost := "test.gw.istio.io" workingDNSServer := newFakeDNSServer(ttl, sets.New(gwHost)) failingDNSServer := newFakeDNSServer(ttl, sets.NewWithLength[string](0))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0) -
src/runtime/race/testdata/chan_test.go
}() go func() { time.Sleep(10 * time.Millisecond) close(c) compl <- true }() <-compl <-compl } func TestRaceChanSendSelectClose(t *testing.T) { compl := make(chan bool, 2) c := make(chan int, 1) c1 := make(chan int) go func() { defer func() { recover() compl <- true }() time.Sleep(10 * time.Millisecond) select { case c <- 1: case <-c1:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 11K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/changedetection/state/FileTimeStampInspector.java
* * Timestamp can be in `seconds` or `milliseconds` precision. In case timestamp is in `seconds` precision, * then it can happen that we might not detect the file change from the timestamp. We detect that by comparing that with the `lastBuildTimestamp`. * In case of millisecond precision we can always detect the file change from the timestamp. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 20 16:22:11 UTC 2021 - 5K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/lockedfile_plan9.go
if err := os.Chmod(name, fi.Mode()|fs.ModeExclusive); err != nil { return nil, err } } } else if !os.IsNotExist(err) { return nil, err } nextSleep := 1 * time.Millisecond const maxSleep = 500 * time.Millisecond for { f, err := os.OpenFile(name, flag, perm|fs.ModeExclusive) if err == nil { return f, nil } if !isLocked(err) { return nil, err } time.Sleep(nextSleep)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 2.5K bytes - Viewed (0) -
pkg/util/iptables/iptables_linux.go
if err := wait.PollImmediate(200*time.Millisecond, 2*time.Second, func() (bool, error) { if err := grabIptablesFileLock(l.lock16); err != nil { return false, nil } return true, nil }); err != nil { return nil, fmt.Errorf("failed to acquire new iptables lock: %v", err) } // Roughly duplicate iptables 1.4.x xtables_lock() function. if err := wait.PollImmediate(200*time.Millisecond, 2*time.Second, func() (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 2.6K bytes - Viewed (0) -
plugin/pkg/admission/imagepolicy/config.go
// decisions are delegated. package imagepolicy import ( "fmt" "time" "k8s.io/klog/v2" ) const ( defaultRetryBackoff = time.Duration(500) * time.Millisecond minRetryBackoff = time.Duration(1) maxRetryBackoff = time.Duration(5) * time.Minute defaultAllowTTL = time.Duration(5) * time.Minute defaultDenyTTL = time.Duration(30) * time.Second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 25 04:07:36 UTC 2022 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2" "k8s.io/klog/v2/ktesting" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) var ( pollPeriod = time.Millisecond minimalNoChange = 20 * time.Millisecond pollTimeout = 5 * time.Second ) func TestConditionalProgressRequester(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0) -
src/time/example_test.go
fmt.Println(1*time.Hour + 2*time.Minute + 300*time.Millisecond) fmt.Println(300 * time.Millisecond) // Output: // 1h2m0.3s // 300ms } func ExampleDuration_Truncate() { d, err := time.ParseDuration("1h15m30.918273645s") if err != nil { panic(err) } trunc := []time.Duration{ time.Nanosecond, time.Microsecond, time.Millisecond, time.Second, 2 * time.Second, time.Minute,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 13 01:05:00 UTC 2024 - 22.4K bytes - Viewed (0) -
src/net/tcpsockopt_plan9.go
return syscall.EPLAN9 } // Set keep alive period. func setKeepAliveIdle(fd *netFD, d time.Duration) error { if d < 0 { return nil } cmd := "keepalive " + itoa.Itoa(int(d/time.Millisecond)) _, e := fd.ctl.WriteAt([]byte(cmd), 0) return e } func setKeepAliveInterval(_ *netFD, d time.Duration) error { if d < 0 { return nil } return syscall.EPLAN9 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 762 bytes - Viewed (0)