Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 44 for WithTimeout (0.05 sec)

  1. cmd/utils.go

    		CurvePreferences: crypto.TLSCurveIDs(),
    		TCPOptions:       globalTCPOptions,
    		EnableHTTP2:      false,
    	}
    
    	if clientCert != "" && clientKey != "" {
    		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    		defer cancel()
    		transport, err := s.NewHTTPTransportWithClientCerts(ctx, clientCert, clientKey)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
     *       beware: <i>Your {@code AsyncCallable} should not complete its {@code Future} until it is
     *       safe for the next task to start.</i>
     * </ul>
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  3. cmd/server-main.go

    			return
    		}
    		ip := "127.0.0.1"
    		host, _ := mustSplitHostPort(globalLocalNodeName)
    		if host != "" {
    			if net.ParseIP(host) != nil {
    				ip = host
    			} else {
    				ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
    				defer cancel()
    
    				haddrs, err := globalDNSCache.LookupHost(ctx, host)
    				if err == nil {
    					ip = haddrs[0]
    				}
    			}
    		}
    		ifs, _ := net.Interfaces()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  4. cmd/notification.go

    		if client == nil {
    			continue
    		}
    		ng.Go(ctx, func() error {
    			// Give 15 seconds to each remote call.
    			// Errors are logged but not returned.
    			ctx, cancel := context.WithTimeout(ctx, 15*time.Second)
    			defer cancel()
    			data, err := client.DownloadProfileData(ctx)
    			if err != nil {
    				reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", client.host.String())
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  5. cmd/object_api_suite_test.go

    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    	}
    	{
    		ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
    		defer cancel()
    		token := ""
    		for ctx.Err() == nil {
    			result, err := obj.ListObjectsV2(ctx, "bucket", "testPrefix", token, "", 2, false, "")
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  6. finisher_api.go

    		err error
    	)
    
    	if len(opts) > 0 {
    		opt = opts[0]
    	}
    
    	ctx := tx.Statement.Context
    	if db.DefaultTransactionTimeout > 0 {
    		if _, ok := ctx.Deadline(); !ok {
    			ctx, _ = context.WithTimeout(ctx, db.DefaultTransactionTimeout)
    		}
    	}
    
    	switch beginner := tx.Statement.ConnPool.(type) {
    	case TxBeginner:
    		tx.Statement.ConnPool, err = beginner.BeginTx(ctx, opt)
    	case ConnPoolBeginner:
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Aug 26 06:24:29 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    	healthClient.NoMetrics = true
    
    	// Construct a new health function.
    	restClient.HealthCheckFn = func() bool {
    		ctx, cancel := context.WithTimeout(context.Background(), restClient.HealthCheckTimeout)
    		defer cancel()
    		respBody, err := healthClient.Call(ctx, peerRESTMethodHealth, nil, nil, -1)
    		xhttp.DrainBody(respBody)
    		return !isNetworkError(err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    		if err != nil {
    			return err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    
    	if !opts.Force {
    		results := make(chan itemOrErr[ObjectInfo])
    
    		ctx, cancel := context.WithTimeout(ctx, time.Minute)
    		defer cancel()
    		err := z.Walk(ctx, bucket, "", results, WalkOptions{Limit: 1})
    		if err != nil {
    			s3LogIf(ctx, fmt.Errorf("unable to verify if the bucket %s is empty: %w", bucket, err))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  9. cmd/batch-handlers.go

    	if endpoint == "" {
    		return nil
    	}
    
    	buf, err := json.Marshal(ri)
    	if err != nil {
    		return err
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes.NewReader(buf))
    	if err != nil {
    		return err
    	}
    
    	if token != "" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  10. cmd/peer-rest-server.go

    		}
    		srvCfg, err := getValidConfig(objAPI)
    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    		subSys := vars.Get(peerRESTSubSys)
    		// Apply dynamic values.
    		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    		defer cancel()
    		if subSys == "" {
    			err = applyDynamicConfig(ctx, objAPI, srvCfg)
    		} else {
    			err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
Back to top