- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 437 for wait (0.3 seconds)
-
docs/en/docs/async.md
```Python burgers = await get_burgers(2) ``` The key here is the `await`. It tells Python that it has to wait ⏸ for `get_burgers(2)` to finish doing its thing 🕙 before storing the results in `burgers`. With that, Python will know that it can go and do something else 🔀 ⏯ in the meanwhile (like receiving another request).
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 09:56:21 GMT 2025 - 24K bytes - Click Count (0) -
cmd/notification.go
if g != nil { g.retryCount = retryCount } return g } // Wait blocks until all function calls from the Go method have returned, then // returns the slice of errors from all function calls. func (g *NotificationGroup) Wait() []NotificationPeerErr { g.workers.Wait() return g.errs } // Go calls the given function in a new goroutine. //Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
cmd/peer-s3-server.go
return serr } beforeState[index] = madmin.DriveStateMissing afterState[index] = madmin.DriveStateMissing return serr } return nil }, index) } errs := g.Wait() // Initialize heal result info res = madmin.HealResultItem{ Type: madmin.HealItemBucket, Bucket: bucket, DiskCount: len(localDrives),
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.2K bytes - Click Count (0) -
tests/compose.yml
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Mon Aug 04 04:07:30 GMT 2025 - 1.9K bytes - Click Count (0) -
cmd/erasure.go
w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { wait := deleteCleanupSleeper.Timer(ctx) removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir)) wait() return nil }) }) }(disk) } wg.Wait() } // nsScanner will start scanning buckets and send updated totals as they are traversed.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.1K bytes - Click Count (0) -
cmd/mrf.go
} now := time.Now() if now.Sub(u.Queued) < time.Second { // let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan if u.BitrotScan { scan = madmin.HealDeepScan }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
tests/tests_all.sh
cd .. fi # SqlServer for Mac M1 if [[ -z $GITHUB_ACTION && -d tests ]]; then cd tests if [[ $(uname -a) == *" arm64" ]]; then MSSQL_IMAGE=mcr.microsoft.com/azure-sql-edge docker compose up -d --wait go install github.com/microsoft/go-sqlcmd/cmd/sqlcmd@latest || true for query in \ "IF DB_ID('gorm') IS NULL CREATE DATABASE gorm" \
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Mon Jul 21 02:46:58 GMT 2025 - 1.6K bytes - Click Count (0) -
internal/grid/grid_test.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
r.writeCond.Broadcast() } // Unlock the mutex so readers/writers can finish. r.mu.Unlock() r.wg.Wait() r.mu.Lock() r.r = 0 r.w = 0 r.err = nil r.isFull = false } // WriteCloser returns a WriteCloser that writes to the ring buffer. // When the returned WriteCloser is closed, it will wait for all data to be read before returning. func (r *RingBuffer) WriteCloser() io.WriteCloser {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
cmd/erasure-multipart.go
} } // Fallback for older uploads without time in the ID. if modTime.IsZero() { wait := deleteMultipartCleanupSleeper.Timer(ctx) fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{}) if err != nil { return nil } modTime = fi.ModTime wait() } if time.Since(modTime) < globalAPIConfig.getStaleUploadsExpiry() { return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 47.1K bytes - Click Count (0)