/** Map of path mappings by process type. */
    protected final Map<String, List<PathMapping>> pathMappingMap = new HashMap<>();

    /** Cached list of path mappings. */
    protected volatile List<PathMapping> cachedPathMappingList = null;

    /**
     * Initializes the path mapping helper.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {

     */
    private static class TestNotificationListener implements WitnessClient.WitnessNotificationListener {
        private final CountDownLatch notificationLatch = new CountDownLatch(1);
        private volatile WitnessNotification lastNotification;

        @Override
        public void onWitnessNotification(WitnessNotification notification) {
            this.lastNotification = notification;

    }

    /** Atomic counter for the number of documents processed */
    protected AtomicLong documentSize = new AtomicLong(0);

    /** Total execution time for all operations */
    protected volatile long executeTime = 0;

    /** List of documents waiting to be indexed */
    protected final DocList docList = new DocList();

    /** Maximum size of document requests in bytes */

    /**
     * Atomic counter for tracking the number of accesses made.
     */
    protected AtomicLong accessCount = new AtomicLong(0);

    /**
     * Current status of the crawler.
     */
    protected volatile CrawlerStatus status = CrawlerStatus.INITIALIZING;

    /**
     * Filter for URLs to control which URLs are processed.
     */
    protected UrlFilter urlFilter;

    /**

    private final SmbNamedPipe pipe;
    private final boolean transact;
    private final boolean call;

    private final int openFlags;
    private final int access;
    private volatile boolean open = true;

    private SmbFileHandleImpl handle;
    private SmbPipeOutputStream output;
    private SmbPipeInputStream input;

    private final String uncPath;

    private final CIFSContext ctx;
    private final SmbTreeConnection delegate;
    private SmbTreeImpl tree;
    private volatile boolean treeAcquired;
    private volatile boolean delegateAcquired;

    private SmbTransportInternal exclusiveTransport;
    private boolean nonPooled;

    private final AtomicLong usageCount = new AtomicLong();

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

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

    // Witness RPC interface
    private static final String WITNESS_INTERFACE_UUID = "ccd8c074-d0e5-4a40-92b4-d074faa6ba28";

    private final ReentrantLock signingLock = new ReentrantLock();
    private byte[] signingKey;
    private final String algorithmName;
    private final java.security.Provider provider;
    private volatile boolean closed = false;

    /**
     * Constructs a SMB2 signing digest with the specified session key and dialect
     *
     * @param sessionKey
     *            the session key for signing
     * @param dialect

    protected final AtomicInteger sendCredits;
    protected final AtomicInteger receiveCredits;
    protected final BlockingQueue<RdmaWorkRequest> pendingRequests;
    
    // Connection state
    protected volatile RdmaConnectionState state;
    protected RdmaCredits credits;
    protected int maxFragmentedSize;
    protected int maxReadWriteSize;
    
    public enum RdmaConnectionState {
        DISCONNECTED,

        private final HandleType type;
        private final long timeout;
        private final long createTime;
        private volatile long lastAccessTime;
        private final Smb2LeaseKey leaseKey;  // Associated lease if any
        private volatile boolean reconnecting;
        private transient SmbFile file;  // Not serialized
        
        public HandleInfo(String path, HandleGuid guid, byte[] fileId,