Flush - Code Search

internal/dsync/lock-args_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeLockArgs(b *testing.B) {
	v := LockArgs{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 21 01:09:35 GMT 2023

- 4.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/site-replication-utils_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeSiteResyncStatus(b *testing.B) {
	v := SiteResyncStatus{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Mon Nov 14 15:16:40 GMT 2022

- 2.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/background-newdisks-heal-ops_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodehealingTracker(b *testing.B) {
	v := healingTracker{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri Apr 23 18:58:53 GMT 2021

- 2.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-walk_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeWalkDirOptions(b *testing.B) {
	v := WalkDirOptions{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 21 01:09:35 GMT 2023

- 2.3K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/csv/record.go

	w.Comma = opts.FieldDelimiter
	w.AlwaysQuote = opts.AlwaysQuote
	w.Quote = opts.Quote
	w.QuoteEscape = opts.QuoteEscape
	if err := w.Write(r.csvRecord); err != nil {
		return err
	}
	w.Flush()
	return w.Error()
}

// WriteJSON - encodes to JSON data.
func (r *Record) WriteJSON(writer io.Writer) error {
	var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames))

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Sep 13 00:00:59 GMT 2022

- 4.1K bytes

- Viewed (0)

github.com/minio/minio

internal/http/response-recorder.go

		lrw.writeHeaders(&lrw.headers, code, lrw.ResponseWriter.Header())
		lrw.headersLogged = true
		lrw.ResponseWriter.WriteHeader(code)
	}
}

// Flush - Calls the underlying Flush.
func (lrw *ResponseRecorder) Flush() {
	lrw.ResponseWriter.(http.Flusher).Flush()
}

// Size - returns  the number of bytes written
func (lrw *ResponseRecorder) Size() int {
	return lrw.bytesWritten
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Sat Dec 02 00:13:19 GMT 2023

- 4.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-handlers_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeBatchJobRequest(b *testing.B) {
	v := BatchJobRequest{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Aug 29 18:27:23 GMT 2023

- 4.5K bytes

- Viewed (0)

github.com/minio/minio

internal/config/cache/remote_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeCondCheck(b *testing.B) {
	v := CondCheck{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Wed Nov 22 21:46:17 GMT 2023

- 4.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/storage-rest-common_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodensScannerOptions(b *testing.B) {
	v := nsScannerOptions{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 21 01:09:35 GMT 2023

- 4.6K bytes

- Viewed (0)

github.com/minio/minio

internal/bucket/bandwidth/monitor_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeBucketBandwidthReport(b *testing.B) {
	v := BucketBandwidthReport{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Mon Feb 19 22:54:46 GMT 2024

- 4.5K bytes

- Viewed (0)

Search Options