final TransPeekNamedPipeResponse resp = new TransPeekNamedPipeResponse(th.getConfig());
            th.send(req, resp, RequestParam.NO_RETRY);
            if (resp.getStatus() == TransPeekNamedPipeResponse.STATUS_DISCONNECTED
                    || resp.getStatus() == TransPeekNamedPipeResponse.STATUS_SERVER_END_CLOSED) {
                fd.markClosed();
                return 0;
            }
            return resp.getAvailable();

            long complete = entry.getValue();

            buffer.append(getStatus(complete, total)).append("  ");
        }

        int pad = lastLength - buffer.length();
        lastLength = buffer.length();
        pad(buffer, pad);
        buffer.append('\r');

        print("transferProgressed", buffer.toString());
    }

    private String getStatus(long complete, long total) {
        if (total >= 1024) {

        final StringBuilder resultBuf = new StringBuilder();

        final PingResponse ping = searchEngineClient.ping();
        final int status = ping.getStatus();
        if (systemHelper.isChangedClusterState(status)) {
            if (fessConfig.hasNotification()) {
                final String toStrs = fessConfig.getNotificationTo();
                final String[] toAddresses;

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.smb2.ServerMessageBlock2#isErrorResponseStatus()
     */
    @Override
    protected boolean isErrorResponseStatus() {
        return getStatus() != NtStatus.NT_STATUS_NOTIFY_ENUM_DIR && super.isErrorResponseStatus();
    }

        manager.process(request, response, chain);
        assertEquals(404, response.getStatus());

        // Test with different status code
        manager = new StatusCodeWebApiManager(201);
        response = new TestHttpServletResponse();
        manager.process(request, response, chain);
        assertEquals(201, response.getStatus());
    }

    @Test

        // Test subCommand property
        assertEquals(SmbComTransaction.TRANS2_SET_FILE_INFORMATION, response.getSubCommand());

        // Test status property - getStatus() is public
        assertEquals(0, response.getStatus());

        // Test numEntries property - getNumEntries() is public
        assertEquals(0, response.getNumEntries());

    }

    @Test
    public void test_user_state() {
        final User user = new User();
        assertNull(user.getState());

        user.setState("CA");
        assertEquals("CA", user.getState());
    }

    @Test
    public void test_user_street() {
        final User user = new User();
        assertNull(user.getStreet());

    }

    @Test
    @DisplayName("Test status getter and setter")
    void testStatusGetterSetter() {
        assertEquals(0, response.getStatus());
        response.setStatus(404);
        assertEquals(404, response.getStatus());
    }

    @Test
    @DisplayName("Test numEntries getter and setter")
    void testNumEntriesGetterSetter() {
        assertEquals(0, response.getNumEntries());

        SMBUtil.writeInt2(5, buffer, bufferIndex);

        int bytesRead = response.readParametersWireFormat(buffer, 0, 8);

        assertEquals(8, bytesRead);
        assertEquals(0, getStatus(response));
        assertEquals(100, getConverter(response));
        assertEquals(3, getNumEntries(response));
        assertEquals(5, getTotalAvailableEntries(response));
    }

    @ParameterizedTest

    /**
     * Monitors active registrations and sends heartbeats.
     */
    private void monitorRegistrations() {
        for (WitnessRegistration registration : registrations.values()) {
            if (registration.getState() == WitnessRegistrationState.REGISTERED) {
                // Send periodic heartbeat
                sendHeartbeat(registration);
            }
        }
    }

    /**