Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for nodeIdx (0.1 sec)

  1. cmd/admin-handlers-pools.go

    	// concurrent rebalance-start commands.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    			if proxyEp.Endpoint.Host == ep.Host {
    				if proxyRequestByNodeIndex(ctx, w, r, nodeIdx) {
    					return
    				}
    			}
    		}
    	}
    
    	pools, ok := objectAPI.(*erasureServerPools)
    	if !ok || len(pools.serverPools) == 1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/batch-handlers.go

    		}
    		req := &BatchJobRequest{}
    		if err := req.load(ctx, j.objLayer, result.Item.Name); err != nil {
    			batchLogIf(ctx, err)
    			continue
    		}
    		_, nodeIdx := parseRequestToken(req.ID)
    		if nodeIdx > -1 && GetProxyEndpointLocalIndex(globalProxyEndpoints) != nodeIdx {
    			// This job doesn't belong on this node.
    			continue
    		}
    		if err := j.queueJob(req); err != nil {
    			batchLogIf(ctx, err)
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  3. cmd/event-notification.go

    		uniqueID = fmt.Sprintf("%X", args.Object.ModTime.UnixNano())
    	}
    
    	respElements := map[string]string{
    		"x-amz-request-id": args.RespElements["requestId"],
    		"x-amz-id-2":       args.RespElements["nodeId"],
    		"x-minio-origin-endpoint": func() string {
    			if globalMinioEndpoint != "" {
    				return globalMinioEndpoint
    			}
    			return getAPIEndpoints()[0]
    		}(), // MinIO specific custom elements.
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. cmd/handler-utils.go

    func extractRespElements(w http.ResponseWriter) map[string]string {
    	if w == nil {
    		return map[string]string{}
    	}
    	return map[string]string{
    		"requestId":      w.Header().Get(xhttp.AmzRequestID),
    		"nodeId":         w.Header().Get(xhttp.AmzRequestHostID),
    		"content-length": w.Header().Get(xhttp.ContentLength),
    		// Add more fields here.
    	}
    }
    
    // Trims away `aws-chunked` from the content-encoding header if present.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    	// These are static for all objects extracted.
    	reqParams := extractReqParams(r)
    	respElements := map[string]string{
    		"requestId": w.Header().Get(xhttp.AmzRequestID),
    		"nodeId":    w.Header().Get(xhttp.AmzRequestHostID),
    	}
    	if sc == "" {
    		sc = storageclass.STANDARD
    	}
    
    	putObjectTar := func(reader io.Reader, info os.FileInfo, object string) error {
    		size := info.Size()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
Back to top