Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 378 for cancels (0.07 sec)

  1. docs/en/docs/async.md

    Still, in both situations, chances are that **FastAPI** will [still be faster](index.md#performance){.internal-link target=_blank} than (or at least comparable to) your previous framework.
    
    ### Dependencies
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    	}
    }
    
    // globalExpiryState is the per-node instance which manages all ILM expiry tasks.
    var globalExpiryState *expiryState
    
    // newExpiryState creates an expiryState with buffered channels allocated for
    // each ILM expiry task type.
    func newExpiryState(ctx context.Context, objAPI ObjectLayer, n int) *expiryState {
    	es := &expiryState{
    		ctx:    ctx,
    		objAPI: objAPI,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. docs/metrics/prometheus/grafana/replication/minio-replication-cluster.json

        {
          "icon": "external link",
          "includeVars": true,
          "keepTime": true,
          "tags": [
            "minio"
          ],
          "type": "dashboards"
        }
      ],
      "liveNow": false,
      "panels": [
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
              "color": {
                "mode": "palette-classic"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:15:39 UTC 2024
    - 71.1K bytes
    - Viewed (0)
  4. doc/go1.17_spec.html

    received value (or values) are assigned.
    </li>
    
    <li>
    The statement list of the selected case is executed.
    </li>
    </ol>
    
    <p>
    Since communication on <code>nil</code> channels can never proceed,
    a select with only <code>nil</code> channels and no default case blocks forever.
    </p>
    
    <pre>
    var a []int
    var c, c1, c2, c3, c4 chan int
    var i1, i2 int
    select {
    case i1 = &lt;-c1:
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  5. doc/go_mem.html

    The <i>k</i>th receive on a channel with capacity <i>C</i> is synchronized before the completion of the <i>k</i>+<i>C</i>th send from that channel completes.
    </p>
    
    <p>
    This rule generalizes the previous rule to buffered channels.
    It allows a counting semaphore to be modeled by a buffered channel:
    the number of items in the channel corresponds to the number of active uses,
    the capacity of the channel corresponds to the maximum number of simultaneous uses,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. okhttp-android/src/main/baseline-prof.txt

    PLkotlinx/coroutines/JobCancellationException;->fillInStackTrace()Ljava/lang/Throwable;
    PLkotlinx/coroutines/JobImpl;->getOnCancelComplete$kotlinx_coroutines_core()Z
    PLkotlinx/coroutines/JobKt;->cancel$default(Lkotlin/coroutines/CoroutineContext;Ljava/util/concurrent/CancellationException;ILjava/lang/Object;)V
    PLkotlinx/coroutines/JobSupport$Finishing;-><init>(Lkotlinx/coroutines/NodeList;ZLjava/lang/Throwable;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    		w.WriteHeader(http.StatusNotFound)
    	case errInvalidAccessKeyID, errAccessKeyDisabled, errNoAuthToken, errMalformedAuth, errAuthentication, errSkewedAuthTime:
    		w.WriteHeader(http.StatusUnauthorized)
    	case context.Canceled, context.DeadlineExceeded:
    		w.WriteHeader(499)
    	default:
    		w.WriteHeader(http.StatusForbidden)
    	}
    	w.Write([]byte(err.Error()))
    }
    
    // DefaultSkewTime - skew time is 15 minutes between minio peers.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  8. cmd/metrics-v2.go

    	return MetricDescription{
    		Namespace: s3MetricNamespace,
    		Subsystem: requestsSubsystem,
    		Name:      canceledTotal,
    		Help:      "Total number of S3 requests that were canceled by the client",
    		Type:      counterMetric,
    	}
    }
    
    func getS3RejectedAuthRequestsTotalMD() MetricDescription {
    	return MetricDescription{
    		Namespace: s3MetricNamespace,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  9. api/go1.5.txt

    pkg mime/quotedprintable, type Writer struct, Binary bool
    pkg net, type Dialer struct, FallbackDelay time.Duration
    pkg net, type OpError struct, Source Addr
    pkg net/http, type Request struct, Cancel <-chan struct
    pkg net/http/fcgi, var ErrConnClosed error
    pkg net/http/fcgi, var ErrRequestAborted error
    pkg net/http/pprof, func Trace(http.ResponseWriter, *http.Request)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
  10. docs/metrics/prometheus/grafana/bucket/minio-bucket.json

        {
          "icon": "external link",
          "includeVars": true,
          "keepTime": true,
          "tags": [
            "minio"
          ],
          "type": "dashboards"
        }
      ],
      "liveNow": false,
      "panels": [
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
              "mappings": [],
              "thresholds": {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 11:11:51 UTC 2024
    - 101.8K bytes
    - Viewed (0)
Back to top