Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newUnsignedV4ChunkedReader (0.15 sec)

  1. cmd/streaming-v4-unsigned.go

    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"net/http"
    	"strings"
    )
    
    // newUnsignedV4ChunkedReader returns a new s3UnsignedChunkedReader that translates the data read from r
    // out of HTTP "chunked" format before returning it.
    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    func newUnsignedV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
    	if trailer {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newUnsignedV4ChunkedReader(r, true)
    		if s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	case authTypeSignedV2, authTypePresignedV2:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream chunked reader with optional trailers.
    		rd, s3Err = newUnsignedV4ChunkedReader(r, true)
    		if s3Err != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return
    		}
    	case authTypeSignedV2, authTypePresignedV2:
    		s3Err = isReqAuthenticatedV2(r)
    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