Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/http/transports.go

    // communicating with client cert authentication.
    func (s ConnSettings) NewHTTPTransportWithClientCerts(ctx context.Context, clientCert, clientKey string) (*http.Transport, error) {
    	transport := s.NewHTTPTransportWithTimeout(1 * time.Minute)
    	if clientCert != "" && clientKey != "" {
    		c, err := certs.NewManager(ctx, clientCert, clientKey, tls.LoadX509KeyPair)
    		if err != nil {
    			return nil, err
    		}
    		if c != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-drive.go

    	m.Set(drivePercUtil, ioStats.percUtil, labels...)
    }
    
    // loadDriveMetrics - `MetricsLoaderFn` for node drive metrics.
    func loadDriveMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	driveMetrics, err := c.driveMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    	for _, disk := range driveMetrics.storageInfo.Disks {
    		labels := []string{
    			driveL, disk.DrivePath,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  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. 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)
  8. 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)
  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