bufB - Code Search

cmd/bucket-replication-metrics_gen_test.go

	v := ActiveWorkerStat{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodeActiveWorkerStat Msgsize() is inaccurate")
	}

	vn := ActiveWorkerStat{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Tue Feb 06 06:00:45 UTC 2024

- 17.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/dcerpc/ndr/NdrHyperTest.java

        NdrHyper hyper = new NdrHyper(original);
        // Create buffer with extra space for alignment
        NdrBuffer buf = new NdrBuffer(new byte[16], 0);
        hyper.encode(buf);
        // Reset buffer position for decoding
        buf.reset();
        NdrHyper decoded = new NdrHyper(0);
        decoded.decode(buf);
        assertEquals(original, decoded.value, "Decoded value should match encoded value");
    }

    /**

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 4.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication-utils_gen_test.go

	v := MRFReplicateEntry{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodeMRFReplicateEntry Msgsize() is inaccurate")
	}

	vn := MRFReplicateEntry{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Mon Aug 22 23:53:06 UTC 2022

- 23K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-job-common-types_gen_test.go

	v := BatchJobKV{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodeBatchJobKV Msgsize() is inaccurate")
	}

	vn := BatchJobKV{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Sat Dec 02 10:51:33 UTC 2023

- 11.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-rotate_gen_test.go

	v := BatchJobKeyRotateEncryption{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodeBatchJobKeyRotateEncryption Msgsize() is inaccurate")
	}

	vn := BatchJobKeyRotateEncryption{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {

Registered: Sun Sep 07 19:28:11 UTC 2025

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

- 11.8K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool-decom_gen_test.go

	v := PoolDecommissionInfo{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodePoolDecommissionInfo Msgsize() is inaccurate")
	}

	vn := PoolDecommissionInfo{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Wed Jan 12 02:48:43 UTC 2022

- 11K bytes

- Viewed (0)

github.com/minio/minio

cmd/xl-storage-format-v2_gen_test.go

	v := xlMetaDataDirDecoder{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodexlMetaDataDirDecoder Msgsize() is inaccurate")
	}

	vn := xlMetaDataDirDecoder{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Thu Nov 18 20:15:22 UTC 2021

- 11.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/dcerpc/DcerpcBind.java

    public void encode_in(final NdrBuffer buf) throws NdrException {
        buf.enc_ndr_short(this.max_xmit);
        buf.enc_ndr_short(this.max_recv);
        buf.enc_ndr_long(0); /* assoc. group */
        buf.enc_ndr_small(1); /* num context items */
        buf.enc_ndr_small(0); /* reserved */
        buf.enc_ndr_short(0); /* reserved2 */
        buf.enc_ndr_short(0); /* context id */
        buf.enc_ndr_small(1); /* number of items */

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 3.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/DcerpcBind.java

    public void encode_in(final NdrBuffer buf) throws NdrException {
        buf.enc_ndr_short(max_xmit);
        buf.enc_ndr_short(max_recv);
        buf.enc_ndr_long(0); /* assoc. group */
        buf.enc_ndr_small(1); /* num context items */
        buf.enc_ndr_small(0); /* reserved */
        buf.enc_ndr_short(0); /* reserved2 */
        buf.enc_ndr_short(0); /* context id */
        buf.enc_ndr_small(1); /* number of items */

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 3.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/smb1/AndXServerMessageBlockTest.java

            }
        };

        byte[] buf = new byte[128];
        // After header at 0..32
        buf[33] = 4; // wordCount
        buf[34] = (byte) 0xFF; // andxCommand
        // andxOffset (ignored when 0xFF)
        buf[36] = 0;
        buf[37] = 0;
        // byteCount at index start + 1 + wordCount*2 = 33 + 1 + 8 = 42
        ServerMessageBlock.writeInt2(20, buf, 42);

        int len = block.decode(buf, 0);

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 12.5K bytes

- Viewed (0)

Search Options