flush - Code Search

cmd/bucket-stats_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 BenchmarkDecodeBucketReplicationStat(b *testing.B) {
	v := BucketReplicationStat{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 20.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool-decom_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 BenchmarkDecodePoolDecommissionInfo(b *testing.B) {
	v := PoolDecommissionInfo{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 11K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-job-common-types_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 BenchmarkDecodeBatchJobKV(b *testing.B) {
	v := BatchJobKV{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 11.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-rotate_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 BenchmarkDecodeBatchJobKeyRotateEncryption(b *testing.B) {
	v := BatchJobKeyRotateEncryption{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 11.8K bytes

- Viewed (0)

github.com/minio/minio

cmd/xl-storage-format-v2_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 BenchmarkDecodexlMetaDataDirDecoder(b *testing.B) {
	v := xlMetaDataDirDecoder{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 11.5K bytes

- Viewed (0)

github.com/golang/go

src/bufio/bufio.go

// Writer implements buffering for an [io.Writer] object.
// If an error occurs writing to a [Writer], no more data will be
// accepted and all subsequent writes, and [Writer.Flush], will return the error.
// After all data has been written, the client should call the
// [Writer.Flush] method to guarantee all data has been forwarded to
// the underlying [io.Writer].
type Writer struct {
	err error
	buf []byte
	n   int
	wr  io.Writer
}

Registered: Tue Dec 30 11:13:12 UTC 2025

- Last Modified: Wed Sep 03 14:04:47 UTC 2025

- 22K bytes

- Viewed (0)

github.com/minio/minio

cmd/xl-storage-format-v1_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 BenchmarkDecodeChecksumInfo(b *testing.B) {
	v := ChecksumInfo{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 13.2K bytes

- Viewed (0)

github.com/apache/maven

impl/maven-core/src/main/java/org/apache/maven/project/DefaultProjectRealmCache.java

        }

        CacheRecord record = new CacheRecord(projectRealm, extensionArtifactFilter);

        cache.put(key, record);

        return record;
    }

    @Override
    public void flush() {
        for (CacheRecord record : cache.values()) {
            ClassRealm realm = record.getRealm();
            try {
                realm.getWorld().disposeRealm(realm.getId());

Registered: Sun Dec 28 03:35:09 UTC 2025

- Last Modified: Fri Jun 06 14:28:57 UTC 2025

- 3.8K 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 BenchmarkDecodeBatchJobPrefix(b *testing.B) {
	v := BatchJobPrefix{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 6.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/local-locker_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 BenchmarkDecodelocalLockMap(b *testing.B) {
	v := localLockMap{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 6.7K bytes

- Viewed (0)

Search Options