Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for readChunkLine (0.12 sec)

  1. cmd/streaming-signature-v4_test.go

    			nil,
    			[]byte("1000"),
    			[]byte("111123333333333333334444211"),
    		},
    	}
    	// Valid test cases for each chunk line.
    	for i, tt := range testCases {
    		chunkSize, chunkSignature, err := readChunkLine(tt.reader)
    		if err != tt.expectedErr {
    			t.Errorf("Test %d: Expected %s, got %s", i+1, tt.expectedErr, err)
    		}
    		if !bytes.Equal(chunkSize, tt.chunkSize) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 5.7K bytes
    - Viewed (0)
  2. cmd/streaming-signature-v4.go

    }
    
    // Read a line of bytes (up to \n) from b.
    // Give up if the line exceeds maxLineLength.
    // The returned bytes are owned by the bufio.Reader
    // so they are only valid until the next bufio read.
    func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) {
    	buf, err := b.ReadSlice('\n')
    	if err != nil {
    		// We always know when EOF is coming.
    		// If the caller asked for a line, there should be a line.
    		if err == io.EOF {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    func truncateChunkByHalfSigv4(req *http.Request) (*http.Request, error) {
    	bufReader := bufio.NewReader(req.Body)
    	hexChunkSize, chunkSignature, err := readChunkLine(bufReader)
    	if err != nil {
    		return nil, err
    	}
    
    	newChunkHdr := []byte(fmt.Sprintf("%s"+s3ChunkSignatureStr+"%s\r\n",
    		hexChunkSize, chunkSignature))
    	newChunk, err := io.ReadAll(bufReader)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top