// If exception thrown, validation is working
            assertTrue(e.getMessage().contains("Invalid negotiate context data length") || e.getMessage().contains("Buffer too small")
                    || e.getMessage().contains("negotiate context"), "Validation detected issue: " + e.getMessage());
        }
    }

    /**
     * Test negotiate context buffer overflow protection.
     */

        // Verify messages
        assertEquals("Top level", topLevel.getMessage());
        assertEquals("Level 1", level1.getMessage());
        assertEquals("Level 2", level2.getMessage());
        assertEquals("Level 3 - Root cause", level3.getMessage());
    }

    /**
     * Test serialization
     */
    public void test_serialization() throws Exception {

        // Verify the exception message indicates name resolution failure
        assertTrue(exception.getMessage().contains("NONEXISTENT") || exception.getMessage().contains("unknown")
                || exception.getMessage().contains("not found"), "Exception message should indicate name resolution failure");
    }

    @Test

        assertTrue(exception.getMessage().contains("FILE_EXISTS"));
        assertTrue(exception.getMessage().contains("File already exists"));
        assertTrue(exception.getMessage().contains("document.pdf already exists"));

        // Without custom message
        exception = new SmbOperationException(SmbOperationException.ErrorCode.DISK_FULL, null);
        assertTrue(exception.getMessage().contains("DISK_FULL"));

     * @return true if TCP fallback is recommended
     */
    public boolean shouldFallbackToTcp(Exception error) {
        // Hardware errors suggest RDMA is not working
        if (error.getMessage() != null) {
            String message = error.getMessage().toLowerCase();
            if (message.contains("hardware") || message.contains("device not found") || message.contains("driver")

                log.debug("Error closing connection: {}", e.getMessage());
            }
        });
        connections.clear();

        nonPooledConnections.forEach(conn -> {
            try {
                conn.disconnect(true, true);
            } catch (Exception e) {
                log.debug("Error closing non-pooled connection: {}", e.getMessage());
            }
        });

                } else {
                    // Final attempt failed
                    if (e.getMessage() != null && (e.getMessage().contains("Connection refused")
                            || e.getMessage().contains("Failed to connect") || e.getMessage().contains("localhost/0:0:0:0:0:0:0:1"))) {
                        // Network connectivity issue in CI - skip test

        } catch (Exception e) {
            log.error("Failed to create multi-channel transport from {} to {}: {}", localAddress, serverAddress, e.getMessage());
            throw new CIFSException("Failed to create multi-channel transport: " + e.getMessage(), e);
        }
    }

    /**
     * Creates a default CIFSContext for multi-channel operations.

            // For now, just return the file object
            return file;
        } catch (Exception e) {
            log.warn("Failed to create SmbFile for {}: {}", filePath, e.getMessage());
            throw new IOException("Failed to create SmbFile: " + e.getMessage(), e);
        }
    }

    /**
     * Get the CIFS context
     *
     * @return CIFS context
     */
    public CIFSContext getContext() {

            // Try to get server message from SMB exception
            return cause.getMessage();
        }
        return null;
    }

    private void logError() {
        if (errorCode.category == ErrorCategory.TRANSIENT) {
            log.debug("Transient SMB error: {} (attempt {}/{})", getMessage(), attemptNumber, retryPolicy.getMaxAttempts());
        } else if (isRetryable()) {