}
    }

    @BeforeEach
    void setUp() {
        smbComNtTransaction = new ConcreteSmbComNtTransaction();
    }

    @Test
    void testConstructor() {
        // Test if the offsets are initialized correctly by the constructor.
        assertEquals(69, smbComNtTransaction.primarySetupOffset, "primarySetupOffset should be initialized to 69");

	var sl []T
	runtime_arena_arena_Slice(a.a, &sl, cap)
	return sl[:len]
}

// Clone makes a shallow copy of the input value that is no longer bound to any
// arena it may have been allocated from, returning the copy. If it was not
// allocated from an arena, it is returned untouched. This function is useful
// to more easily let an arena-allocated value out-live its arena.

     * Reads a single line from the given {@link BufferedReader}.
     *
     * @param reader
     *            the {@link BufferedReader} (must not be {@literal null})
     * @return a line of text, or {@literal null} if the end of the stream has been reached
     * @see BufferedReader#readLine()
     */
    public static String readLine(final BufferedReader reader) {
        assertArgumentNotNull("reader", reader);

        try {

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package jcifs.internal.smb1.trans2;

import jcifs.Configuration;

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs.internal.smb2.create;

import jcifs.internal.smb2.lease.Smb2LeaseKey;

        CountDownLatch latch = new CountDownLatch(1);
        List<String> receivedLines = new ArrayList<>();
        Consumer<String> callback = line -> {
            receivedLines.add(line);
            if (receivedLines.size() == 5000) {
                latch.countDown();
            }
        };

        InputStreamThread thread = new InputStreamThread(is, StandardCharsets.UTF_8, 100, callback);

    <title>Index of /repositories/snapshots/org/codelibs/fess</title>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>

    <link rel="icon" type="image/png" href="https://oss.sonatype.org/favicon.png">
    <!--[if IE]>
    <link rel="SHORTCUT ICON" href="https://oss.sonatype.org/favicon.ico"/>
    <![endif]-->

            return bytesWritten;
        }

        @Override
        protected int readBytesWireFormat(byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException {
            if (throwOnRead) {
                throw new SMBProtocolDecodingException("Test exception");
            }
            return bytesRead;
        }

        public void setBytesWritten(int bytes) {

    assertThat(reader.nextPart()).isNull()
  }

  /**
   * Read 100 MiB of 'a' chars. This was really slow due to a performance bug in [MultipartReader],
   * and will be really slow if we regress the fix for that.
   */
  @Test
  fun `reading a large part with small byteCount`() {
    val multipartBody =
      MultipartBody
        .Builder("foo")
        .addPart(

@ExtendWith(MockitoExtension.class)
@DisplayName("Type3Message Tests")
class Type3MessageTest {

    @Mock
    private CIFSContext mockContext;

    @BeforeEach
    void setUp() {
        // Basic setup for mock context if needed
    }

    /**
     * Helper method to create properly configured mock context
     */
    private CIFSContext createMockContext() {
        CIFSContext mockCtx = mock(CIFSContext.class);