- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 69 for Milliseconds (0.18 sec)
-
internal/grid/muxserver.go
var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID, RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
for index := range buckets { index := index g.Go(func() error { // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) _, _ = sys.objAPI.HealBucket(ctx, buckets[index].Name, madmin.HealOpts{Recreate: true}) meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[index].Name) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
internal/cachevalue/cache_test.go
t3, _ := cache.Get() if t1.Equal(t3) { t.Fatalf("expected time to be un-equal: %s == %s", t1, t3) } } func BenchmarkCache(b *testing.B) { cache := New[time.Time]() cache.InitOnce(1*time.Millisecond, Opts{}, func() (time.Time, error) { return time.Now(), nil }, ) b.ReportAllocs() b.ResetTimer() b.RunParallel(func(pb *testing.PB) { for pb.Next() { cache.Get() } })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:09:09 GMT 2024 - 1.5K bytes - Viewed (0) -
cmd/metrics-v2_test.go
}, { val: 0.31, label: labels[1], }, { val: 0.61, label: labels[3], }, { val: 0.79, label: labels[2], }, } ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
select { case <-ctx.Done(): return ctx.Err() default: // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++ // after 20 retries start logging that servers are not reachable yet if retries >= 20 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/grid/grid_test.go
defer testlogger.T.SetErrorTB(t)() errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } const wantDL = 50 * time.Millisecond // We fake a local and remote server. remoteHost := remote.HostName() // 1: Echo serverCanceled := make(chan time.Duration, 1) register := func(manager *Manager) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/config/scanner/scanner.go
switch speed := env.Get(EnvSpeed, kvs.GetWithDefault(Speed, DefaultKVS)); speed { case "fastest": cfg.Delay, cfg.MaxWait, cfg.Cycle = 0, 0, time.Second case "fast": cfg.Delay, cfg.MaxWait, cfg.Cycle = 1, 100*time.Millisecond, time.Minute case "default": cfg.Delay, cfg.MaxWait, cfg.Cycle = 2, time.Second, time.Minute case "slow": cfg.Delay, cfg.MaxWait, cfg.Cycle = 10, 15*time.Second, time.Minute case "slowest":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0) -
tests/prepared_stmt_test.go
if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok { t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode") } ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond) defer cancel() txCtx := tx.WithContext(ctx) user := *GetUser("prepared_stmt", Config{}) txCtx.Create(&user) var result1 User if err := txCtx.Find(&result1, user.ID).Error; err != nil {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 21 07:55:43 GMT 2024 - 4K bytes - Viewed (0) -
cmd/metacache-set.go
retries := 0 rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) const ( retryDelay = 50 * time.Millisecond retryDelay250 = 250 * time.Millisecond ) for { if contextCanceled(ctx) { return entries, ctx.Err() } // If many failures, check the cache state. if retries > 10 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/background-heal-ops.go
} func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) { // No need to wait run at full speed. if maxIO <= 0 { return } const waitTick = 100 * time.Millisecond tmpMaxWait := maxWait for currentIO() >= maxIO { if tmpMaxWait > 0 { if tmpMaxWait < waitTick { time.Sleep(tmpMaxWait) return } time.Sleep(waitTick) tmpMaxWait -= waitTick
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0)