- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for AfterFunc (0.04 sec)
-
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 36.1K bytes - Viewed (0) -
cmd/server-main.go
go startSFTPServer(globalServerCtxt.SFTP) }) } }() go func() { if globalEnableSyncBoot { 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 remove 'MINIO_SYNC_BOOT=on' to not freeze the APIs")) })
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4)