Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 391 for ctx_ (0.03 sec)

  1. tests/test_tutorial/test_body_fields/test_tutorial001.py

                        "msg": "Input should be greater than 0",
                        "input": -3.0,
                        "ctx": {"gt": 0.0},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"limit_value": 0},
                        "loc": ["body", "item", "price"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. tests/test_tutorial/test_body_fields/test_tutorial001_py310.py

                        "msg": "Input should be greater than 0",
                        "input": -3.0,
                        "ctx": {"gt": 0.0},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"limit_value": 0},
                        "loc": ["body", "item", "price"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    // otherwise the function will return nil.
    func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error {
    	defer xioutil.SafeClose(out)
    	top := make([]*metaCacheEntry, len(in))
    	nDone := 0
    	ctxDone := ctx.Done()
    
    	// Use simpler forwarder.
    	if len(in) == 1 {
    		for {
    			select {
    			case <-ctxDone:
    				return ctx.Err()
    			case v, ok := <-in[0]:
    				if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  4. cmd/handler-api.go

    		w.Header().Set("X-RateLimit-Limit", strconv.Itoa(cap(pool)))
    		w.Header().Set("X-RateLimit-Remaining", strconv.Itoa(cap(pool)-len(pool)))
    
    		ctx := r.Context()
    		select {
    		case pool <- struct{}{}:
    			defer func() { <-pool }()
    			globalHTTPStats.addRequestsInQueue(-1)
    			if contextCanceled(ctx) {
    				w.WriteHeader(499)
    				return
    			}
    			f.ServeHTTP(w, r)
    		case <-r.Context().Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. cmd/erasure-encode_test.go

    	return "bad-disk"
    }
    
    func (a badDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	return errFaultyDisk
    }
    
    func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	return nil, errFaultyDisk
    }
    
    func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/metrics-realtime.go

    			}
    		}
    
    		metrics[d.Endpoint] = dm
    	}
    	return metrics
    }
    
    func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) {
    	if !globalIsDistErasure {
    		return
    	}
    	all := globalNotificationSys.GetMetrics(ctx, types, opts)
    	for _, remote := range all {
    		m.Merge(&remote)
    	}
    	return m
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. cmd/erasure-sets_test.go

    	}
    }
    
    // TestNewErasure - tests initialization of all input disks
    // and constructs a valid `Erasure` object
    func TestNewErasureSets(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	nDisks := 16 // Maximum disks.
    	var erasureDisks []string
    	for i := 0; i < nDisks; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 12 07:21:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. tests/test_multi_body_errors.py

                        "msg": "Input should be greater than 0",
                        "input": -1.0,
                        "ctx": {"gt": 0},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"limit_value": 0.0},
                        "loc": ["body", 0, "age"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateResponse.java

                    ncpos += 4;
                    ncpos += 4; // Reserved
                    NegotiateContextResponse ctx = createContext(type);
                    if ( ctx != null ) {
                        ctx.decode(buffer, ncpos, dataLen);
                        contexts[ i ] = ctx;
                    }
                    ncpos += dataLen;
                    if ( i != negotiateContextCount - 1 ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 22 10:09:46 UTC 2020
    - 17.6K bytes
    - Viewed (0)
  10. cmd/api-headers.go

    	if strings.Contains(objInfo.ETag, "-") && len(objInfo.Parts) > 0 {
    		w.Header()[xhttp.AmzMpPartsCount] = []string{strconv.Itoa(len(objInfo.Parts))}
    	}
    }
    
    // Write object header
    func setObjectHeaders(ctx context.Context, w http.ResponseWriter, objInfo ObjectInfo, rs *HTTPRangeSpec, opts ObjectOptions) (err error) {
    	// set common headers
    	setCommonHeaders(w)
    
    	// Set last modified time.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
Back to top