- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for NewReaderSize (0.29 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/streaming-signature-v4_test.go
// Test - 4 bytes.NewReader([]byte("1000;chunk-signature=111123333333333333334444211\r\n")), } testCases := []testCase{ // Test - 1 - small bufio reader. { bufio.NewReaderSize(readers[0], 16), errLineTooLong, nil, nil, }, // Test - 2 - unexpected end of the reader. { bufio.NewReader(readers[1]), io.ErrUnexpectedEOF, nil, nil, },
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.7K bytes - Click Count (0) -
cmd/storage-rest-client.go
// The reader will be buffered. // Return with readMsgpReaderPoolPut when done. func msgpNewReader(r io.Reader) *msgp.Reader { p := readMsgpReaderPool.Get() if p.R == nil { p.R = xbufio.NewReaderSize(r, 32<<10) } else { p.R.Reset(r) } return p } // readMsgpReaderPoolPut can be used to reuse a *msgp.Reader. func readMsgpReaderPoolPut(r *msgp.Reader) { if r != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
cmd/object-multipart-handlers.go
in := io.Reader(hashReader) if size > encryptBufferThreshold { // The encryption reads in blocks of 64KB. // We add a buffer on bigger files to reduce the number of syscalls upstream. in = bufio.NewReaderSize(hashReader, encryptBufferSize) } var nonce [12]byte tmp := sha256.Sum256(fmt.Append(nil, uploadID, partID)) copy(nonce[:], tmp[:12]) reader, err = sio.EncryptReader(in, sio.Config{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 07 16:13:09 GMT 2025 - 39.5K bytes - Click Count (1)