MReader - Code Search

cmd/encryption-v1.go

	reader, err := sio.DecryptReader(client, sio.Config{
		Key:            objectEncryptionKey,
		SequenceNumber: seqNumber,
		CipherSuites:   fips.DARECiphers(),
	})
	if err != nil {
		return nil, crypto.ErrInvalidCustomerKey
	}
	return reader, nil
}

// DecryptBlocksRequestR - same as DecryptBlocksRequest but with a
// reader

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Thu Jun 13 06:56:12 UTC 2024

- 37.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-handlers.go

		return
	}

	const mapEntryOverhead = 200

	var (
		reader        io.Reader
		fileSize      int64 = -1
		fileName      string
		fanOutEntries = make([]minio.PutObjectFanOutEntry, 0, 100)
	)

	maxParts := 1000
	// Canonicalize the form values into http.Header.
	formValues := make(http.Header)
	for {
		part, err := mp.NextRawPart()
		if errors.Is(err, io.EOF) {
			break
		}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri Jun 14 13:28:35 UTC 2024

- 61.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/object-api-utils.go

func isCompressible(header http.Header, object string) bool {
	globalCompressConfigMu.Lock()
	cfg := globalCompressConfig
	globalCompressConfigMu.Unlock()

	return !excludeForCompression(header, object, cfg)
}

// Eliminate the non-compressible objects.
func excludeForCompression(header http.Header, object string, cfg compress.Config) bool {
	objStr := object

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Tue Jun 11 03:13:30 UTC 2024

- 36.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/object-handlers.go

		// Validate the SSE-C Key set in the header.
		if _, err = crypto.SSEC.UnsealObjectKey(r.Header, objInfo.UserDefined, bucket, object); err != nil {
			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
			return
		}
		w.Header().Set(xhttp.AmzServerSideEncryptionCustomerAlgorithm, r.Header.Get(xhttp.AmzServerSideEncryptionCustomerAlgorithm))

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri Jun 14 13:28:35 UTC 2024

- 124.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/object-multipart-handlers.go

	var idxCb func() []byte
	if isCompressed {
		wantEncryption := crypto.Requested(r.Header) || isEncrypted
		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
		idxCb = cb
		defer s2c.Close()
		reader = etag.Wrap(s2c, reader)
		length = -1
	}

	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
	if err != nil {

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri Jun 14 13:28:35 UTC 2024

- 38.8K bytes

- Viewed (0)

github.com/minio/minio

cmd/storage-datatypes_gen.go

func (z BaseOptions) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 0
	_ = z
	err = en.Append(0x80)
	if err != nil {
		return
	}
	return
}

// MarshalMsg implements msgp.Marshaler
func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) {
	o = msgp.Require(b, z.Msgsize())
	// map header, size 0
	_ = z
	o = append(o, 0x80)
	return
}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Mon Jun 10 15:51:27 UTC 2024

- 130.6K bytes

- Viewed (0)

github.com/golang/go

src/net/http/server.go

	// aren't encoded in ASCII anyway).
	return false
}

func (w *response) Header() Header {
	if w.cw.header == nil && w.wroteHeader && !w.cw.wroteHeader {
		// Accessing the header between logically writing it
		// and physically writing it means we need to allocate
		// a clone to snapshot the logically written state.
		w.cw.header = w.handlerHeader.Clone()
	}
	w.calledHeader = true
	return w.handlerHeader
}

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Jun 07 17:57:01 UTC 2024

- 123.4K bytes

- Viewed (0)

github.com/golang/go

src/net/http/serve_test.go

func testServerNoHeader(t *testing.T, mode testMode, header string) {
	cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
		w.Header()[header] = nil
		io.WriteString(w, "<html>foo</html>") // non-empty
	}))
	res, err := cst.c.Get(cst.ts.URL)
	if err != nil {
		t.Fatal(err)
	}
	res.Body.Close()
	if got, ok := res.Header[header]; ok {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Jun 07 17:57:01 UTC 2024

- 202K bytes

- Viewed (0)

github.com/golang/go

src/cmd/vendor/github.com/google/pprof/internal/elfexec/elfexec.go

	Type uint32 // Contents of the "type" field.
}

// parseNotes returns the notes from a SHT_NOTE section or PT_NOTE segment.
func parseNotes(reader io.Reader, alignment int, order binary.ByteOrder) ([]elfNote, error) {
	r := bufio.NewReader(reader)

	// padding returns the number of bytes required to pad the given size to an
	// alignment boundary.
	padding := func(size int) int {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri May 31 19:48:28 UTC 2024

- 13.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/utils.go

func dumpRequest(r *http.Request) string {
	header := r.Header.Clone()
	header.Set("Host", r.Host)
	// Replace all '%' to '%%' so that printer format parser
	// to ignore URL encoded values.
	rawURI := strings.ReplaceAll(r.RequestURI, "%", "%%")
	req := struct {
		Method     string      `json:"method"`
		RequestURI string      `json:"reqURI"`
		Header     http.Header `json:"header"`
	}{r.Method, rawURI, header}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Wed Jun 05 22:00:34 UTC 2024

- 31.9K bytes

- Viewed (0)

Search Options