// Then
        assertEquals(2, bytesWritten);
        assertEquals(SmbComTransaction.TRANS2_GET_DFS_REFERRAL, dst[0]);
        assertEquals((byte) 0x00, dst[1]);
    }

    @Test
    @DisplayName("writeSetupWireFormat should handle different buffer positions")
    void testWriteSetupWireFormatWithOffset() {
        // Given

        // Assert
        assertNotNull(trans);
        assertEquals(0, trans.maxParameterCount);
        assertEquals(0xFFFF, trans.maxDataCount);
        assertEquals(0x00, trans.maxSetupCount);
        assertEquals(2, trans.setupCount);
        assertEquals("\\PIPE\\", trans.name);
    }

    @Test
    @DisplayName("Test writeSetupWireFormat writes correct data")

    assertThat(Buffer().writeUtf8("Слава Україні!").isProbablyUtf8(16L)).isTrue()
    assertThat(Buffer().writeByte(0x80).isProbablyUtf8(16L)).isTrue()
    assertThat(Buffer().writeByte(0x00).isProbablyUtf8(16L)).isFalse()
    assertThat(Buffer().writeByte(0xc0).isProbablyUtf8(16L)).isFalse()
  }

  @Test fun doesNotConsumeBuffer() {
    val buffer = Buffer()
    buffer.writeUtf8("hello ".repeat(1024))

			[out] policy_handle *handle);

	[op(0x07)]
	int SamrOpenDomain([in] policy_handle *handle,
			[in] uint32_t access_mask,
			[in] sid_t *sid,
			[out] policy_handle *domain_handle);

	typedef struct {
		uint32_t idx;
		unicode_string name;
	} SamrSamEntry;

	typedef struct {
		uint32_t count;
		[size_is(count)] SamrSamEntry *entries;
	} SamrSamArray;

	[op(0x0f)]

            System.arraycopy(stringBytes, 0, bufferWithTermination, 0, stringBytes.length);
            bufferWithTermination[stringBytes.length] = 0x00;
            bufferWithTermination[stringBytes.length + 1] = 0x00;

            // When
            int terminationPos = Strings.findUNITermination(bufferWithTermination, 0, bufferWithTermination.length);

            // Then

     * This operation releases resources associated with the handle.
     */
    public static class SamrCloseHandle extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x01;
        }

        /** The return value of the operation */
        public int retval;
        /** The handle to be closed */
        public rpc.policy_handle handle;

        /**

     * This operation releases resources associated with the handle.
     */
    public static class SamrCloseHandle extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x01;
        }

        /** The return value of the operation */
        public int retval;
        /** The handle to be closed */
        public rpc.policy_handle handle;

        /**

    }

    /**
     * LSA close handle message.
     */
    public static class LsarClose extends DcerpcMessage {

        @Override
        public int getOpnum() {
            return 0x00;
        }

        /** Return value from the RPC call. */
        public int retval;
        /** Policy handle to be closed. */
        public rpc.policy_handle handle;

        /**

        dstIndex += 2;

        return dstIndex - start;
    }

    @Override
    int writeBytesWireFormat(final byte[] dst, int dstIndex) {
        final int start = dstIndex;

        dst[dstIndex] = (byte) 0x01; /* BufferFormat */
        dstIndex++;
        writeInt2(count, dst, dstIndex); /* DataLength? */
        dstIndex += 2;
        System.arraycopy(b, off, dst, dstIndex, count);
        dstIndex += count;

        subCommand = NET_SERVER_ENUM2; // not really true be used by upper logic
        name = "\\PIPE\\LANMAN";

        maxParameterCount = 8;
        maxDataCount = 16384;
        maxSetupCount = (byte) 0x00;
        setupCount = 0;
        timeout = 5000;
    }

    @Override
    void reset(final int key, final String lastName) {
        super.reset();
        this.lastName = lastName;
    }

    @Override