* including adding URLs to the queue, filtering URLs, managing crawler threads,
 * and handling the overall crawling lifecycle.
 *
 * <p>It implements the Runnable interface to be executed in a separate thread,
 * and the AutoCloseable interface to ensure resources are properly released after use.
 *
 * <p>The crawler uses several services and components, such as UrlQueueService, DataService,

 * Manages connection state, credit flow control, and provides
 * abstract methods for RDMA operations that must be implemented
 * by specific provider implementations.
 */
public abstract class RdmaConnection implements AutoCloseable {

    /**
     * RDMA connection state enumeration
     */
    public enum RdmaConnectionState {
        /** Connection is not established */
        DISCONNECTED,

                log.debug("Failed to close enum", e);
            }
        }
        return n;
    }

    /**
     * {@inheritDoc}
     *
     * @see java.lang.AutoCloseable#close()
     */
    @Override
    public void close() throws CIFSException {
        if (this.next != null) {
            doClose();
        }
    }

    @Override
    public void remove() {

- **Authentication**: NTLM, Kerberos, SPNEGO unified subsystem
- **SLF4J Logging**: Comprehensive logging throughout the codebase
- **Resource Management**: AutoCloseable patterns for file handles and connections
- **Thread Safety**: Components support concurrent access
- **DFS Support**: Distributed File System resolution
- **Streaming Operations**: Efficient directory listings and file operations

/**
 * Mock witness service for integration testing.
 * Simulates a basic witness service that can accept registrations
 * and send notifications.
 */
public class MockWitnessService implements AutoCloseable {
    private static final Logger log = LoggerFactory.getLogger(MockWitnessService.class);

    private ServerSocket serverSocket;
    private final AtomicBoolean running = new AtomicBoolean(false);

            assertNull(smbPipeHandle.unwrap(SmbPipeHandle.class), "Unwrap should return null for an unsupported type.");
        }
    }

    /**
     * Tests the contract for {@link AutoCloseable}.
     */
    @Nested
    public class AutoCloseableContractTest {

        /**
         * Verifies that the handle is automatically closed in a try-with-resources statement.

 *
 * Manages pools of pre-registered memory regions to avoid the overhead
 * of frequent registration/deregistration during RDMA operations.
 */
public class RdmaBufferManager implements AutoCloseable {

    private static final Logger log = LoggerFactory.getLogger(RdmaBufferManager.class);

    private final RdmaProvider provider;
    private final ConcurrentLinkedQueue<RdmaMemoryRegion> availableSendRegions;

/**
 * Client implementation for the SMB Witness RPC protocol (MS-SWN).
 * Provides communication with witness servers for monitoring SMB resource availability.
 */
public class WitnessRpcClient implements AutoCloseable {
    private static final Logger log = LoggerFactory.getLogger(WitnessRpcClient.class);

    private final InetAddress serverAddress;
    private final CIFSContext context;
    private volatile boolean connected = false;

/**
 * Unit tests for RDMA buffer manager
 */
public class RdmaBufferManagerTest {

    @Mock
    private RdmaProvider mockProvider;

    private RdmaBufferManager bufferManager;
    private AutoCloseable mocks;

    @BeforeEach
    public void setUp() throws Exception {
        mocks = MockitoAnnotations.openMocks(this);

        // Set up mock provider to return TCP memory regions

        assertThrows(RuntimeException.class, () -> smbTree.close(), "Should propagate exception when close fails");
    }

    /**
     * Test for AutoCloseable functionality.
     * Verifies that SmbTree can be used in try-with-resources.
     */
    @Test
    void testAutoCloseable() {
        SmbTree autoCloseTree = mock(SmbTree.class);