Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for xmlDecoder (0.12 sec)

  1. cmd/acl-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	aclHeader := r.Header.Get(xhttp.AmzACL)
    	if aclHeader == "" {
    		acl := &accessControlPolicy{}
    		if err = xmlDecoder(r.Body, acl, r.ContentLength); err != nil {
    			if terr, ok := err.(*xml.SyntaxError); ok && terr.Msg == io.EOF.Error() {
    				writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMalformedXML),
    					r.URL)
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/utils.go

    // it is used to ignore custom encoding charset in S3 XML body.
    func nopCharsetConverter(label string, input io.Reader) (io.Reader, error) {
    	return input, nil
    }
    
    // xmlDecoder provide decoded value in xml.
    func xmlDecoder(body io.Reader, v interface{}, size int64) error {
    	var lbody io.Reader
    	if size > 0 {
    		lbody = io.LimitReader(body, size)
    	} else {
    		lbody = body
    	}
    	d := xml.NewDecoder(lbody)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. cmd/handler-utils.go

    	// If the request has no body with content-length set to 0,
    	// we do not have to validate location constraint. Bucket will
    	// be created at default region.
    	locationConstraint := createBucketLocationConfiguration{}
    	err := xmlDecoder(r.Body, &locationConstraint, r.ContentLength)
    	if err != nil && r.ContentLength != 0 {
    		internalLogOnceIf(GlobalContext, err, "location-constraint-xml-parsing")
    		// Treat all other failures as XML parsing errors.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  4. cmd/object-multipart-handlers.go

    	if r.ContentLength <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMissingPart), r.URL)
    		return
    	}
    
    	complMultipartUpload := &CompleteMultipartUpload{}
    	if err = xmlDecoder(r.Body, complMultipartUpload, r.ContentLength); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	if len(complMultipartUpload.Parts) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEntityTooLarge), r.URL)
    		return
    	}
    
    	// Unmarshal list of keys to be deleted.
    	deleteObjectsReq := &DeleteObjectsRequest{}
    	if err := xmlDecoder(r.Body, deleteObjectsReq, maxBodySize); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	objects := make([]ObjectV, len(deleteObjectsReq.Objects))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  6. cmd/object-handlers_test.go

    		apiRouter.ServeHTTP(rec, req)
    		if rec.Code != http.StatusOK {
    			t.Fatalf("Test failed to create HTTP request for copy %d", rec.Code)
    		}
    
    		resp := &CopyObjectPartResponse{}
    		if err = xmlDecoder(rec.Body, resp, rec.Result().ContentLength); err != nil {
    			t.Fatalf("Test failed to decode XML response: <ERROR> %v", err)
    		}
    
    		parts = append(parts, CompletePart{
    			PartNumber: partNumber,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top