SMBUtil.writeInt2(0, buffer, SmbConstants.SMB1_HEADER_LENGTH + 1);

            assertThrows(SMBProtocolDecodingException.class, () -> {
                testBlock.decode(buffer, 0);
            });
        }

        @Test
        @DisplayName("Test decode with retain payload")
        void testDecodeWithRetainPayload() throws SMBProtocolDecodingException {
            testBlock.retainPayload();

        }

        @Test
        @DisplayName("Should decode sync message correctly")
        void testDecodeSync() throws SMBProtocolDecodingException {
            byte[] buffer = createValidSyncMessage();
            testMessage.setBytesRead(10);

            int len = testMessage.decode(buffer, 0);

            assertTrue(len > 0);
            assertFalse(testMessage.isAsync());

// UnmarshalYAML - BatchJobKV extends default unmarshal to extract line, col information.
func (kv *BatchJobKV) UnmarshalYAML(val *yaml.Node) error {
	type jobKV BatchJobKV
	var tmp jobKV
	err := val.Decode(&tmp)
	if err != nil {
		return err
	}
	*kv = BatchJobKV(tmp)
	kv.line, kv.col = val.Line, val.Column
	return nil
}

// Validate returns an error if key is empty
func (kv BatchJobKV) Validate() error {

                    .thenReturn(0); // cancel count

            message.decode(mockBuffer);

            assertEquals(DcerpcConstants.RPC_PT_RESPONSE, message.ptype);
            assertEquals(100, message.alloc_hint);
        }

        @Test
        @DisplayName("decode should handle FAULT ptype correctly")
        void testDecodeFaultPtype() throws NdrException {

        assertNull(response.getInfo());
    }

    @Test
    void testReadDataWireFormat_EmptyBuffer() throws Exception {
        // Test with empty dataCount but decode still processes buffer
        // Note: SmbInfoAllocation.decode() doesn't check len parameter, always reads 20 bytes
        response = new Trans2QueryFSInformationResponse(config, FileSystemInformation.SMB_INFO_ALLOCATION);

 * limitations under the License.
 */
package okhttp3.internal.http2

import assertk.assertThat
import assertk.assertions.isEqualTo
import java.util.Random
import okhttp3.internal.http2.Huffman.decode
import okhttp3.internal.http2.Huffman.encode
import okhttp3.internal.http2.Huffman.encodedLength
import okio.Buffer
import okio.ByteString
import okio.ByteString.Companion.encodeUtf8

	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)
	}
}

    /**
     * Convert the input string to a code point. Accepts regular decimal numerals, hex strings, and
     * some symbolic names meaningful to humans.
     */
    private static int decode(String userFriendly) {
      try {
        return Integer.decode(userFriendly);
      } catch (NumberFormatException ignored) {
        if (userFriendly.matches("(?i)(?:American|English|ASCII)")) {
          // 1-byte UTF-8 sequences - "American" ASCII text

	msgp.Encode(&buf, &v)

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

	vn := BucketReplicationResyncStatus{}
	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)
	}
}

            _dst = _dst.derive(_nodei);
            for (int _i = 0; _i < _nodes; _i++) {
                _dst.enc_ndr_small(node[_i]);
            }
        }

        @Override
        public void decode(NdrBuffer _src) throws NdrException {
            _src.align(4);
            time_low = _src.dec_ndr_long();
            time_mid = (short) _src.dec_ndr_short();
            time_hi_and_version = (short) _src.dec_ndr_short();