Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 186 for Cancelled (0.05 sec)

  1. internal/grid/README.md

    Context timeouts are propagated, and a default timeout of 1 minute is added if none is specified.
    
    There is no cancellation propagation for single payload requests.
    When the context is canceled, the request will return at once with an appropriate error. 
    However, the remote call will not see the cancellation - as can be seen from the 'missing' context on the handler.
    The result will be discarded.
    
    ### Typed handlers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/handler-api.go

    				if unlock, ok := val.(chan struct{}); ok && unlock != nil {
    					// Wait until unfrozen.
    					select {
    					case <-unlock:
    					case <-r.Context().Done():
    						// if client canceled we don't need to wait here forever.
    						return
    					}
    				}
    			}
    		}
    
    		globalHTTPStats.addRequestsInQueue(1)
    		pool := globalAPIConfig.getRequestsPool()
    		if pool == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. cmd/site-replication-utils.go

    		}
    	}
    }
    
    // returns overall resync status from individual bucket resync status map
    func siteResyncStatus(currSt ResyncStatusType, m map[string]ResyncStatusType) ResyncStatusType {
    	// avoid overwriting canceled resync status
    	if currSt != ResyncStarted {
    		return currSt
    	}
    	totBuckets := len(m)
    	var cmpCount, failCount int
    	for _, st := range m {
    		switch st {
    		case ResyncCompleted:
    			cmpCount++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    			retErr = err
    		}
    
    		if retErr != nil {
    			healingLogIf(ctx, fmt.Errorf("listing failed with: %v on bucket: %v", retErr, bucket))
    			continue
    		}
    
    		select {
    		// If context is canceled don't mark as done...
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			tracker.bucketDone(bucket)
    			healingLogIf(ctx, tracker.update(ctx))
    		}
    	}
    	if retErr != nil {
    		return retErr
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  5. api/go1.7.txt

    pkg context, type Context interface, Done() <-chan struct
    pkg context, type Context interface, Err() error
    pkg context, type Context interface, Value(interface{}) interface{}
    pkg context, var Canceled error
    pkg context, var DeadlineExceeded error
    pkg crypto/tls, const RenegotiateFreelyAsClient = 2
    pkg crypto/tls, const RenegotiateFreelyAsClient RenegotiationSupport
    pkg crypto/tls, const RenegotiateNever = 0
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  6. cmd/bucket-replication-utils.go

    type ResyncStatusType int
    
    const (
    	// NoResync - no resync in progress
    	NoResync ResyncStatusType = iota
    	// ResyncPending - resync pending
    	ResyncPending
    	// ResyncCanceled - resync canceled
    	ResyncCanceled
    	// ResyncStarted -  resync in progress
    	ResyncStarted
    	// ResyncCompleted -  resync finished
    	ResyncCompleted
    	// ResyncFailed -  resync failed
    	ResyncFailed
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  7. internal/dsync/drwmutex.go

    				lockRefreshed++
    			} else {
    				lockNotFound++
    			}
    			if lockRefreshed >= quorum || lockNotFound > len(restClnts)-quorum {
    				done = true
    			}
    		case <-ctx.Done():
    			// Refreshing is canceled
    			return false, ctx.Err()
    		}
    		if done {
    			break
    		}
    	}
    
    	// We may have some unused results in ch, release them async.
    	go func() {
    		wg.Wait()
    		xioutil.SafeClose(ch)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  8. cmd/metacache-walk.go

    				}
    				if opts.Recursive {
    					// Scan folder we found. Should be in correct sort order where we are.
    					err := scanDir(pop)
    					if err != nil && !IsErrIgnored(err, context.Canceled) {
    						internalLogIf(ctx, err)
    					}
    				}
    				dirStack = dirStack[:len(dirStack)-1]
    			}
    
    			// All objects will be returned as directories, there has been no object check yet.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        if (!newRouteSelector.hasNext()) throw IOException("exhausted all routes")
        val newRouteSelection = newRouteSelector.next()
        routeSelection = newRouteSelection
    
        if (isCanceled()) throw IOException("Canceled")
    
        return planConnectToRoute(newRouteSelection.next(), newRouteSelection.routes)
      }
    
      /**
       * Returns a plan to reuse a pooled connection, or null if the pool doesn't have a connection for
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  10. docs/metrics/prometheus/list.md

    | `minio_s3_requests_5xx_errors_total`          | Total number S3 requests with (5xx) errors.              |
    | `minio_s3_requests_canceled_total`            | Total number S3 requests canceled by the client.         |
    | `minio_s3_requests_errors_total`              | Total number S3 requests with (4xx and 5xx) errors.      |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
Back to top