Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 36 of 36 for ToAPIErr (0.15 sec)

  1. cmd/admin-heal-ops.go

    				"(use force-start option to stop and start afresh). " +
    				fmt.Sprintf("The heal was started by IP %s at %s, token is %s",
    					h.clientAddress, h.startTime.Format(http.TimeFormat), h.clientToken)
    			return nil, errorCodes.ToAPIErr(ErrHealAlreadyRunning), errMsg
    		}
    	}
    
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	// Check if new heal sequence to be started overlaps with any
    	// existing, running sequence
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  2. cmd/handler-api.go

    			defer func() { <-pool }()
    			globalHTTPStats.addRequestsInQueue(-1)
    			f.ServeHTTP(w, r)
    		case <-deadlineTimer.C:
    			// Send a http timeout message
    			writeErrorResponse(r.Context(), w,
    				errorCodes.ToAPIErr(ErrTooManyRequests),
    				r.URL)
    			globalHTTPStats.addRequestsInQueue(-1)
    			return
    		case <-r.Context().Done():
    			// When the client disconnects before getting the S3 handler
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 10K bytes
    - Viewed (0)
  3. cmd/handler-utils.go

    		resource, err := getResource(r.URL.Path, r.Host, globalDomainNames)
    		if err != nil {
    			defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    
    			apiErr := errorCodes.ToAPIErr(ErrUnsupportedHostHeader)
    			apiErr.Description = fmt.Sprintf("%s: %v", apiErr.Description, err)
    
    			writeErrorResponse(r.Context(), w, apiErr, r.URL)
    			return
    		}
    
    		bucket, _ := path2BucketObject(resource)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  4. cmd/api-router.go

    func getHost(r *http.Request) string {
    	if r.URL.IsAbs() {
    		return r.URL.Host
    	}
    	return r.Host
    }
    
    func notImplementedHandler(w http.ResponseWriter, r *http.Request) {
    	writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    }
    
    type rejectedAPI struct {
    	api     string
    	methods []string
    	queries []string
    	path    string
    }
    
    var rejectedObjAPIs = []rejectedAPI{
    	{
    		api:     "torrent",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  5. cmd/api-errors.go

    			apiErr.Description = fmt.Sprintf("The authorization header is malformed; the region is wrong; expecting '%s'.", globalSite.Region)
    			return apiErr
    		}
    	}
    	return apiErr
    }
    
    func (e errorCodeMap) ToAPIErr(errCode APIErrorCode) APIError {
    	return e.ToAPIErrWithErr(errCode, nil)
    }
    
    // error code to APIError structure, these fields carry respective
    // descriptions for all the error responses.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  6. cmd/admin-router.go

    		if !handlerFlags.Has(noObjLayerFlag) {
    			objectAPI := newObjectLayerFn()
    			if objectAPI == nil || globalNotificationSys == nil {
    				writeErrorResponseJSON(r.Context(), w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    				return
    			}
    		}
    
    		// Apply http tracing "middleware" based on presence of flag.
    		var f2 http.HandlerFunc
    		if handlerFlags.Has(traceAllFlag) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
Back to top