- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for afterFunc (0.47 sec)
-
cmd/server-main.go
}) } }() go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) if !globalDisableFreezeOnBoot { defer bootstrapTrace("unfreezeServices", unfreezeServices) t := time.AfterFunc(5*time.Minute, func() { warnings = append(warnings, color.YellowBold("- Initializing the config subsystem is taking longer than 5 minutes. Please set '_MINIO_DISABLE_API_FREEZE_ON_BOOT=true' to not freeze the APIs")) })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (0) -
internal/grid/grid_test.go
// Wait for the server start the request. <-reqStarted // Block until we have exceeded the deadline several times over. nowBlocking := make(chan struct{}) var mu sync.Mutex time.AfterFunc(time.Second, func() { mu.Lock() cancel() close(nowBlocking) mu.Unlock() }) if inCap > 0 { go func() { defer close(st.Requests) if !blockReq { <-nowBlocking
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
} return err.ErrorOrNil() } // Run all controllers until a signal is received func (c *Controller) Run(stop <-chan struct{}) { if c.opts.SyncTimeout != 0 { time.AfterFunc(c.opts.SyncTimeout, func() { if !c.queue.HasSynced() { log.Warnf("kube controller for %s initial sync timed out", c.opts.ClusterID) c.initialSyncTimedout.Store(true) } }) } st := time.Now()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
src/internal/fuzz/worker.go
comm, err := getWorkerComm() if err != nil { return err } srv := &workerServer{ workerComm: comm, fuzzFn: func(e CorpusEntry) (time.Duration, error) { timer := time.AfterFunc(10*time.Second, func() { panic("deadlocked!") // this error message won't be printed }) defer timer.Stop() start := time.Now() err := fn(e) return time.Since(start), err },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
src/runtime/time.go
// number to recognize and squech stale function invocations. // When used from package time, arg is a channel (for After, NewTicker) // or the function to call (for AfterFunc) and seq is unused (0). // // Package time does not know about seq, but if this is a channel timer (t.isChan == true), // this file uses t.seq as a sequence number to recognize and squelch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
var delayNanos = -1L try { delayNanos = task.runOnce() } finally { lock.withLock { afterRun(task, delayNanos) } currentThread.name = oldName } } private fun afterRun( task: Task, delayNanos: Long, ) { lock.assertHeld() val queue = task.queue!! check(queue.activeTask === task)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0)