Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 437 for wait (0.3 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. tests/compose.yml

          # timeout handling
          if [ $$counter -gt 20 ]; then
            echo "Error: Database failed to start within timeout";
            exit 1;
          fi;
          # keep the container running: wait for the database process in the foreground
          wait
    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)
  5. 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)
  6. 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)
  7. 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)
  8. internal/grid/grid_test.go

    				close(reqStarted)
    				// Just wait for it to cancel.
    				for blockResp {
    					select {
    					case <-ctx.Done():
    						close(serverCanceled)
    						return NewRemoteErr(ctx.Err())
    					case resp <- []byte{1}:
    						time.Sleep(10 * time.Millisecond)
    					}
    				}
    				// Just wait for it to cancel.
    				<-ctx.Done()
    				close(serverCanceled)
    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)
  9. 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)
  10. 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)
Back to Top