void testDoReceiveFragment_Success() throws Exception {
            DcerpcPipeHandle handle = createMockedDcerpcPipeHandle();

            byte[] buf = new byte[4280]; // Use maxRecv size

            // Mock initial receive with valid PDU header
            when(mockSmbPipeHandleInternal.recv(buf, 0, buf.length)).thenAnswer(invocation -> {
                byte[] buffer = invocation.getArgument(0);

    public String[] groups;

    /** Version number for optimistic locking */
    public String versionNo;

    /**
     * Clears all pagination state and search criteria.
     * Resets the pager to its initial state with default values.
     */
    public void clear() {
        allRecordCount = 0;
        allPageCount = 0;
        existPrePage = false;
        existNextPage = false;
        pageSize = getDefaultPageSize();

        when(addr.getHostName()).thenReturn("mycomputer.foo.com");
        UniAddress ua = new UniAddress(addr);
        // Act: first call should set to SMBSERVER_NAME
        String initial = ua.firstCalledName();
        // verify that subsequent call gives SMBSERVER_NAME
        String next = ua.nextCalledName();
        // Assert

        byte[] data = { 0x01, 0x02, 0x03, 0x04, 0x05 };
        ByteEncodable encodable = new ByteEncodable(data, 0, 3);
        byte[] dest = new byte[5]; // {0,0,0,0,0}
        dest[0] = (byte) 0xFF; // Add some initial data to dest

        int encodedLen = encodable.encode(dest, 1);

        // Verify encoded length
        assertEquals(3, encodedLen, "Encoded length should be equal to the specified length");

import okhttp3.internal.format
import okio.ByteString.Companion.encodeUtf8

object Http2 {
  @JvmField
  val CONNECTION_PREFACE = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n".encodeUtf8()

  /** The initial max frame size, applied independently writing to, or reading from the peer. */
  const val INITIAL_MAX_FRAME_SIZE = 0x4000 // 16384

  const val TYPE_DATA = 0x0
  const val TYPE_HEADERS = 0x1
  const val TYPE_PRIORITY = 0x2

    //                                                                      ==============
    /**
     * Display the main index page for stemmer override dictionary management.
     * Clears the pager and shows the initial search form.
     *
     * @param form The search form containing filter criteria
     * @return HTML response for the stemmer override index page
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })

        // Flags (2 bytes) - should be 0 by default
        assertEquals(0, SMBUtil.readInt2(buffer, 2));

        // Reserved (4 bytes) - The implementation skips writing these bytes,
        // so they will have the initial pattern (0xCCCCCCCC)
        // This is expected behavior as seen in the implementation at line 131
        assertEquals((byte) 0xCC, buffer[4]);
        assertEquals((byte) 0xCC, buffer[5]);

            "homePostalAddress", null, false, false, false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
    protected final ColumnInfo _columnInitials = cci("initials", "initials", null, null, String.class, "initials", null, false, false,
            false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
    protected final ColumnInfo _columnInternationaliSDNNumber =

                                            <th><la:message key="labels.user_initials"/></th>
                                            <td>${f:h(attributes.initials)}<la:hidden
                                                    property="attributes.initials"/></td>
                                        </tr>
                                        <tr>

    protected final String settingsId;

    /** The OpenSearch client. */
    protected final Client client;

    /** The settings index name. */
    protected final String settingsIndexName;

    /** The initial settings. */
    protected final Map<String, Object> initialSettings;

    /** Flag indicating if the settings are initialized. */
    protected boolean initialized = false;

    /** The bad word index name. */