addDriverSlow()

FL_NO_INLINE FL_COLD bool fl::ChannelManager::addDriverSlow ( int priority, const fl::shared_ptr< IChannelDriver > & driver, const fl::string * engineName, AddDriverSlowReason reason )

private

Handle validation failures and the uncommon replacement flow outside the normal driver-registration path.

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

                                             {
    if (reason == AddDriverSlowReason::NULL_DRIVER) {
        FL_WARN("ChannelManager::addDriver() - Null driver provided");
        return false;
    }
    if (reason == AddDriverSlowReason::EMPTY_NAME) {
        FL_WARN("ChannelManager::addDriver() - Engine has empty name (driver->getName() returned empty string)");
        return false;
    }
 
    for (const auto& entry : mDrivers) {
        if (entry.name == *engineName) {
            // True-duplicate fast path: same shared_ptr at same priority is
            // a no-op (legacy clockless controllers may pre-bind the same
            // driver singleton from many template instantiations). Skip the
            // replace flow entirely so we don't waitForReady() or emit a
            // spurious "Replacing" warning.
            if (entry.driver == driver && entry.priority == priority) {
                FL_DBG("ChannelManager::addDriver() - '" << engineName->c_str() << "' already registered at priority " << priority << " (idempotent no-op)");
                return false;
            }
            FL_WARN("ChannelManager::addDriver() - Replacing existing driver '" << engineName->c_str() << "'");
 
            FL_DBG("ChannelManager: Waiting for all drivers to become READY before replacement");
            waitForReady();
 
            // Re-scan after waiting: task pumping in waitForReady() can run
            // callbacks, so do not retain an index or iterator across it.
            for (size_t i = 0; i < mDrivers.size(); ++i) {
                if (mDrivers[i].name != *engineName) {
                    continue;
                }
                FL_DBG("ChannelManager: Removing old driver '" << engineName->c_str() << "' (shared_ptr may delete)");
                if (mDrivers[i].driver) {
                    mDrivers[i].driver->setPollNeededCallback(IChannelDriver::PollNeededCallback());
                }
                mDrivers.erase(mDrivers.begin() + i);
                break;
            }
            return true;
        }
    }
    return true;
}

References EMPTY_NAME, FL_COLD, FL_DBG, fl::FL_NO_EXCEPT, FL_NO_INLINE, FL_WARN, mDrivers, NULL_DRIVER, and waitForReady().

Referenced by addDriver().

Here is the call graph for this function:

Here is the caller graph for this function: