Method getObjectHandler

objectnode/api_handler_object.go:45–313

Get object API reference: https://docs.aws.amazon.com/AmazonS3/latest/API/API_GetObject.html

(w http.ResponseWriter, r *http.Request)

// Get object
// API reference: https://docs.aws.amazon.com/AmazonS3/latest/API/API_GetObject.html
func (o *ObjectNode) getObjectHandler(w http.ResponseWriter, r *http.Request) {
	var (
		err       error
		errorCode *ErrorCode
	)

	span := trace.SpanFromContextSafe(r.Context())
	defer func() {
		o.errorResponse(w, r, err, errorCode)
	}()

	param := ParseRequestParam(r)
	if param.Bucket() == "" {
		errorCode = InvalidBucketName
		return
	}
	if param.Object() == "" {
		errorCode = InvalidKey
		return
	}
	var vol *Volume
	if vol, err = o.getVol(param.Bucket()); err != nil {
		log.LogErrorf("getObjectHandler: load volume fail: requestID(%v) volume(%v) path(%v) err(%v)",
			GetRequestID(r), param.Bucket(), param.Object(), err)
		return
	}

	// QPS and Concurrency Limit
	rateLimit := o.AcquireRateLimiter()
	if err = rateLimit.AcquireLimitResource(vol.owner, param.apiName); err != nil {
		return
	}
	defer rateLimit.ReleaseLimitResource(vol.owner, param.apiName)

	// parse http range option
	var (
		revRange    bool
		isRangeRead bool
		rangeLower  uint64
		rangeUpper  uint64
		partSize    uint64
		partCount   uint64
	)
	rangeOpt := strings.TrimSpace(r.Header.Get(Range))
	if len(rangeOpt) > 0 {
		if !rangeRegexp.MatchString(rangeOpt) {
			log.LogErrorf("getObjectHandler: invalid range header: requestID(%v) volume(%v) path(%v) rangeOpt(%v)",
				GetRequestID(r), param.Bucket(), param.Object(), rangeOpt)
			errorCode = InvalidRange
			return
		}
		hyphenIndex := strings.Index(rangeOpt, "-")
		if hyphenIndex < 0 {
			log.LogErrorf("getObjectHandler: invalid range header: requestID(%v) volume(%v) path(%v) rangeOpt(%v)",
				GetRequestID(r), param.Bucket(), param.Object(), rangeOpt)
			errorCode = InvalidRange
			return
		}