if (useFilter) {
            verify(filter, times(1)).accept(any());
        }
    }

    @Test
    @DisplayName("close() clears pending element and hasNext() becomes false")
    void closeClearsNext() throws Exception {
        SmbFile parent = newParent();
        List<FileEntry> entries = Collections.singletonList(entry("one", SmbConstants.TYPE_SHARE));

     * @param command the command to send to the process
     * @throws JobNotFoundException if no process is found for the given session ID
     * @throws JobProcessingException if there's an error sending the command
     */
    public void sendCommand(final String sessionId, final String command) {
        final JobProcess jobProcess = runningProcessMap.get(sessionId);
        if (jobProcess == null) {

        }

        // Mock number of links (4 bytes)
        buffer[16] = 0x01;
        buffer[17] = 0x00;
        buffer[18] = 0x00;
        buffer[19] = 0x00;

        // Mock delete pending and directory flags
        buffer[20] = 0x00;
        buffer[21] = 0x00;

        return buffer;
    }

    private byte[] createMockFileInternalInfoBuffer() {

            }
        }
        return target;
    }

    /**
     * Commits any remaining documents in the cache to the index.
     * This method ensures all pending documents are processed.
     */
    @Override
    public void commit() {
        synchronized (docList) {
            if (!docList.isEmpty()) {

        // Test duplicate unregistration
        assertFalse(mockService.unregisterWitness(regId));
    }

    @Test
    void testMockServiceNotifications() {
        // Test notification sending (just logs for mock)
        mockService.sendNotification(WitnessEventType.RESOURCE_CHANGE, "TestResource");

        // Register a witness first

        // array.
        while (mid > -1 && this[mid] != '\n'.code.toByte()) {
          mid--
        }
        mid++

        // Now look for the ending '\n'.
        var end = 1
        while (this[mid + end] != '\n'.code.toByte()) {
          end++
        }
        val publicSuffixLength = mid + end - mid

    /** Available send credits for flow control */
    protected final AtomicInteger sendCredits;
    /** Available receive credits for flow control */
    protected final AtomicInteger receiveCredits;
    /** Queue of pending RDMA work requests */
    protected final BlockingQueue<RdmaWorkRequest> pendingRequests;

    // Connection state
    /** Current connection state */
    protected volatile RdmaConnectionState state;

        });
    }

    /**
     * Sends a test mail using the provided notification settings.
     *
     * @param form the mail form containing notification settings
     * @return HTML response after sending test mail
     */
    @Execute
    @Secured({ ROLE })
    public HtmlResponse sendmail(final MailForm form) {
        validate(form, messages -> {}, () -> asHtml(path_AdminGeneral_AdminGeneralJsp));

     * @return the last access time
     */
    public long getLastAccessTime() {
        return lastAccessTime;
    }

    /**
     * Checks if the cache has pending changes
     * @return true if cache has changes
     */
    public boolean hasChanges() {
        return hasChanges;
    }

    /**
     * Get and increment inconsistency count
     *

        if (!connected) {
            throw new IOException("Witness client not connected");
        }

        try {
            log.debug("Sending witness heartbeat for: {}", request.getRegistrationId());

            // Create and populate the RPC message
            WitnessHeartbeatMessage message = new WitnessHeartbeatMessage();