Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 44 for WithTimeout (0.23 sec)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Implementation of {@code Futures#withTimeout}.
     *
     * <p>Future that delegates to another but will finish early (via a {@link TimeoutException} wrapped
     * in an {@link ExecutionException}) if the specified duration expires. The delegate future is
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. callbacks.go

    	}
    
    	if optimizer, ok := stmt.Dest.(StatementModifier); ok {
    		optimizer.ModifyStatement(stmt)
    	}
    
    	if db.DefaultContextTimeout > 0 {
    		if _, ok := stmt.Context.Deadline(); !ok {
    			stmt.Context, _ = context.WithTimeout(stmt.Context, db.DefaultContextTimeout)
    		}
    	}
    
    	// assign model values
    	if stmt.Model == nil {
    		stmt.Model = stmt.Dest
    	} else if stmt.Dest == nil {
    		stmt.Dest = stmt.Model
    	}
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Aug 26 06:24:29 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. cmd/data-usage.go

    			m := make(map[string]uint64)
    			for _, pool := range z.serverPools {
    				for _, er := range pool.sets {
    					// Load bucket usage prefixes
    					ctx, done := context.WithTimeout(ctx, 2*time.Second)
    					ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil
    					done()
    					if ok {
    						root := cache.find(bucket)
    						if root == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    		},
    		HeaderSize: headerSize,
    	}
    	newCtx := ctx
    	if globalBucketMonitor.IsThrottled(bucket, tgt.ARN) && objInfo.Size < minLargeObjSize {
    		var cancel context.CancelFunc
    		newCtx, cancel = context.WithTimeout(ctx, throttleDeadline)
    		defer cancel()
    	}
    	r := bandwidth.NewMonitoredReader(newCtx, globalBucketMonitor, gr, opts)
    	if isMP {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  5. cmd/prepare-storage.go

    		Host:   endpoint.Host,
    		Path:   pathJoin(healthCheckPathPrefix, healthCheckLivenessPath),
    	}
    
    	httpClient := &http.Client{
    		Transport: globalInternodeTransport,
    	}
    
    	ctx, cancel := context.WithTimeout(GlobalContext, timeout)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodGet, serverURL.String(), nil)
    	if err != nil {
    		return err
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public static <V extends @Nullable Object> ListenableFuture<V> withTimeout(
          ListenableFuture<V> delegate, Duration time, ScheduledExecutorService scheduledExecutor) {
        return withTimeout(delegate, toNanosSaturated(time), TimeUnit.NANOSECONDS, scheduledExecutor);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  7. 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
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 8K bytes
    - Viewed (0)
  8. cmd/data-usage-cache.go

    		// Abandon if more than time.Minute, so we don't hold up scanner.
    		// drive timeout by default is 2 minutes, we do not need to wait longer.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    		r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true})
    		if err != nil {
    			switch err.(type) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  9. cmd/bootstrap-peer-server.go

    					mu.Lock()
    					offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected))
    					mu.Unlock()
    					return
    				}
    
    				ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
    				defer cancel()
    
    				err := clnt.Verify(ctx, srcCfg)
    				mu.Lock()
    				if err != nil {
    					bootstrapTraceMsg(fmt.Sprintf("bootstrapVerify: %v, endpoint: %s", err, clnt))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. api/go1.7.txt

    pkg context, func Background() Context
    pkg context, func TODO() Context
    pkg context, func WithCancel(Context) (Context, CancelFunc)
    pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc)
    pkg context, func WithTimeout(Context, time.Duration) (Context, CancelFunc)
    pkg context, func WithValue(Context, interface{}, interface{}) Context
    pkg context, type CancelFunc func()
    pkg context, type Context interface { Deadline, Done, Err, Value }
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
Back to top