*
     * @param cause the underlying exception
     * @return the message
     */
    protected static String createMessage(final SAXException cause) {
        final StringBuilder buf = new StringBuilder(100);
        buf.append(cause);
        if (cause instanceof SAXParseException) {
            final SAXParseException e = (SAXParseException) cause;
            if (e.getSystemId() != null) {

        super();
    }

    /**
     * Returns the path prefix for SMB URLs.
     * @return The path prefix.
     */
    public String getPathPrefix() {
        final StringBuilder buf = new StringBuilder(100);
        buf.append("smb://");
        if (server != null) {
            buf.append(server);
            if (port > 0) {
                buf.append(':');
                buf.append(port);
            }

            byte[] buffer = new byte[1024];

            assertEquals(0, echoResponse.writeBytesWireFormat(buffer, 0));
            assertEquals(0, echoResponse.writeBytesWireFormat(buffer, 100));
            assertEquals(0, echoResponse.writeBytesWireFormat(buffer, 500));
        }

        @Test
        @DisplayName("Should not modify buffer")
        void testWriteBytesWireFormatNoModification() {

            return 200;
        }

        @Override
        public InputStream getInputStream() throws IOException {
            return new ByteArrayInputStream(new byte[100]); // dummy payload
        }
    }

    @Test
    public void test_TmpFileHasBeenDeletedAfterResponseWasClosed() throws Exception {
        // ## Arrange ##

    }

    public void test_getText_maxSize() throws IOException {
        try (final InputStream in = ResourceUtil.getResourceAsStream("extractor/tar/test.tar")) {
            tarExtractor.setMaxContentSize(100);
            tarExtractor.getText(in, null);
            fail();
        } catch (MaxLengthExceededException e) {
            // pass
        }
        tarExtractor.setMaxContentSize(-1);
    }

    public void testWriteBytesWireFormatAscii() throws Exception {
        // Given
        String oldFileName = "oldFile.txt";
        String newFileName = "newFile.txt";
        byte[] dst = new byte[100];
        smbComRename = new SmbComRename(config, oldFileName, newFileName);

        // Set unicode to false
        Field useUnicodeField = ServerMessageBlock.class.getDeclaredField("useUnicode");

        byte[] buffer = new byte[100];

        int bytesRead = notifyInfo.decode(buffer, 0, 0);

        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("Test decode with non-aligned next entry offset throws exception")
    void testDecodeNonAlignedNextOffset() {
        byte[] buffer = new byte[100];
        // Write non-aligned next entry offset (not divisible by 4)

        lenient().when(mockFileHandle.getInitialSize()).thenReturn(100L); // File already has 100 bytes

        when(mockTreeHandle.send(any(Smb2WriteRequest.class), any())).thenReturn(mockWriteResponse);
        when(mockWriteResponse.getCount()).thenReturn(8);

        // Create output stream in append mode - note the append flag sets initial fp to 100
        outputStream = new SmbFileOutputStream(mockFile, mockTreeHandle, mockFileHandle,

        String sessionId = "age-test";
        keyManager.storeSessionKey(sessionId, testKey, "AES");

        long initialAge = keyManager.getKeyAge(sessionId);
        assertTrue(initialAge >= 0 && initialAge < 100, "Initial age should be small");

        Thread.sleep(200);

        long laterAge = keyManager.getKeyAge(sessionId);
        assertTrue(laterAge >= 200, "Age should increase after delay");
    }

    @Test

            }
        }

        @Test
        @DisplayName("Should handle high concurrency without deadlock")
        void testHighConcurrencyNoDeadlock() throws InterruptedException {
            int threadCount = 100;
            int operationsPerThread = 50;
            ExecutorService executor = Executors.newFixedThreadPool(threadCount);
            CountDownLatch startLatch = new CountDownLatch(1);