Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for writeErrorResponse (0.13 sec)

  1. cmd/dummy-handlers.go

    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	// Allow GetBucketWebsite if policy action is set, since this is a dummy call
    	// we are simply re-purposing the bucketPolicyAction.
    	if s3Error := checkRequestAuthType(ctx, r, policy.GetBucketPolicyAction, bucket, ""); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    	if errCode != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(errCode), r.URL)
    		return
    	}
    
    	if maxUploads < 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidMaxUploads), r.URL)
    		return
    	}
    
    	if keyMarker != "" {
    		// Marker not common with prefix is not implemented.
    		if !HasPrefix(keyMarker, prefix) {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Validate the received bucket policy document
    	if err = bucketLifecycle.Validate(rcfg); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Validate the transition storage ARNs
    	if err = validateTransitionTier(bucketLifecycle); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. cmd/bucket-versioning-handler.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	config, err := globalBucketVersioningSys.Get(bucket)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	configData, err := xml.Marshal(config)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/object-lambda-handlers.go

    	if s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	target, err := globalLambdaTargetList.Lookup(r.Form.Get("lambdaArn"))
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	eventData, err := getLambdaEventData(bucket, object, cred, r)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. cmd/bucket-listobjects-handlers.go

    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	if s3Error := checkRequestAuthType(ctx, r, policy.ListBucketVersionsAction, bucket, ""); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    	var checkObjMeta metaCheckFn
    	if metadata {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  7. cmd/listen-notification-handlers.go

    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    	bucketName := vars["bucket"]
    
    	if bucketName == "" {
    		if s3Error := checkRequestAuthType(ctx, r, policy.ListenNotificationAction, bucketName, ""); s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. cmd/s3-zip-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrBadRequest), r.URL)
    		return
    	}
    
    	zipPath, object, err := splitZipExtensionPath(object)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	opts, err := getOpts(ctx, r, bucket, zipPath)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  9. cmd/object-multipart-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidStorageClass), r.URL)
    			return
    		}
    	}
    
    	encMetadata := map[string]string{}
    
    	if crypto.Requested(r.Header) {
    		if crypto.SSECopy.IsRequested(r.Header) {
    			writeErrorResponse(ctx, w, toAPIError(ctx, errInvalidEncryptionParameters), r.URL)
    			return
    		}
    
    		if crypto.SSEC.IsRequested(r.Header) && crypto.S3.IsRequested(r.Header) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  10. cmd/bucket-replication-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	if globalSiteReplicationSys.isEnabled() && logger.GetReqInfo(ctx).Cred.AccessKey != globalActiveCred.AccessKey {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrReplicationDenyEditError), r.URL)
    		return
    	}
    	if versioned := globalBucketVersioningSys.Enabled(bucket); !versioned {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top