poll()

IChannelDriver::DriverState fl::ChannelManager::poll

(

)

Poll all registered drivers and return aggregate state.

Returns

Aggregate state (READY if all ready, BUSY if any busy, ERROR if any error)

Note

This is NOT an IChannelDriver override - it's a diagnostic/test helper

Polls all drivers and returns the "worst" state (ERROR > BUSY > READY)

Definition at line 519 of file manager.cpp.hpp.

                                               {
    // Poll all registered drivers and return aggregate state
    // Priority order: ERROR > BUSY > DRAINING > READY
    bool anyBusy = false;
    bool anyDraining = false;
    fl::string firstError;
 
    for (auto& entry : mDrivers) {
        IChannelDriver::DriverState result = entry.driver->poll();
        if (result.state == IChannelDriver::DriverState::BUSY) {
            anyBusy = true;
        } else if (result.state == IChannelDriver::DriverState::DRAINING) {
            anyDraining = true;
        }
        // Capture first error encountered
        if (result.state == IChannelDriver::DriverState::ERROR && firstError.empty()) {
            firstError = result.error;
        }
    }
 
    // Return error if any driver reported error
    if (!firstError.empty()) {
        return IChannelDriver::DriverState(IChannelDriver::DriverState::ERROR, firstError);
    }
 
    if (anyBusy) {
        return IChannelDriver::DriverState(IChannelDriver::DriverState::BUSY);
    }
    if (anyDraining) {
        return IChannelDriver::DriverState(IChannelDriver::DriverState::DRAINING);
    }
    return IChannelDriver::DriverState(IChannelDriver::DriverState::READY);
}

References fl::IChannelDriver::DriverState::BUSY, fl::IChannelDriver::DriverState::DRAINING, fl::basic_string::empty(), fl::IChannelDriver::DriverState::ERROR, mDrivers, and fl::IChannelDriver::DriverState::READY.

Referenced by waitForReady(), and waitForReadyOrDraining().

Here is the call graph for this function:

Here is the caller graph for this function: