Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for forName (0.17 sec)

  1. cmd/bucket-handlers.go

    			apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, multipart.ErrMessageTooLarge)
    			writeErrorResponse(ctx, w, apiErr, r.URL)
    			return
    		}
    		maxParts--
    
    		name := part.FormName()
    		if name == "" {
    			continue
    		}
    
    		fileName = part.FileName()
    
    		// Multiple values for the same key (one map entry, longer slice) are cheaper
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  2. internal/s3select/genmessage.go

    // Continuation Message
    // ====================
    // Header specification
    // --------------------
    // Continuation messages contain two headers, as follows:
    // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png
    //
    // Payload specification
    // ---------------------
    // Continuation messages have no payload.
    func genContinuationMessage() {
    	buf := new(bytes.Buffer)
    
    	buf.WriteByte(13)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 4.4K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	const fin = true
    	var frame ws.Frame
    	if s.ClientSide() {
    		// We do not need to copy the payload, since we own it.
    		payload := p
    
    		frame = ws.NewFrame(op, fin, payload)
    		frame = ws.MaskFrameInPlace(frame)
    	} else {
    		frame = ws.NewFrame(op, fin, p)
    	}
    
    	return ww.writeFrame(w, frame)
    }
    
    // writeFrame writes frame binary representation into w.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  4. internal/http/transports.go

    	// if tlsConfig != nil {
    	// 	trhttp2, _ := http2.ConfigureTransports(tr)
    	// 	if trhttp2 != nil {
    	// 		// ReadIdleTimeout is the timeout after which a health check using ping
    	// 		// frame will be carried out if no frame is received on the
    	// 		// connection. 5 minutes is sufficient time for any idle connection.
    	// 		trhttp2.ReadIdleTimeout = 5 * time.Minute
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 00:50:37 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  5. internal/s3select/message.go

    	"encoding/binary"
    	"fmt"
    	"hash/crc32"
    	"net/http"
    	"strconv"
    	"sync/atomic"
    	"time"
    )
    
    // A message is in the format specified in
    // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-frame-overview.png
    // hence the calculation is made accordingly.
    func totalByteLength(headerLength, payloadLength int) int {
    	return 4 + 4 + 4 + headerLength + payloadLength + 4
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  6. cmd/untar.go

    }{
    	{
    		header: []byte{0x1f, 0x8b, 8},
    		f:      formatGzip,
    	},
    	{
    		// Zstd default header.
    		header: []byte{0x28, 0xb5, 0x2f, 0xfd},
    		f:      formatZstd,
    	},
    	{
    		// Zstd skippable frame header.
    		header: []byte{0x2a, 0x4d, 0x18},
    		f:      formatZstd,
    	},
    	{
    		// LZ4
    		header: []byte{0x4, 0x22, 0x4d, 0x18},
    		f:      formatLZ4,
    	},
    	{
    		// Snappy/S2 stream
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
Back to top