SerialPortHandlerCollection.cpp

Go to the documentation of this file.

#include "SerialPortHandlerCollection.h"
#include "SerialPortHandler.h"
#include "HdlcdServerHandler.h"

SerialPortHandlerCollection::SerialPortHandlerCollection(boost::asio::io_service& a_IOService): m_IOService(a_IOService) {
}

void SerialPortHandlerCollection::Shutdown() {
    // No need to cleanup, this class possesses only weak pointers
}

std::shared_ptr<std::shared_ptr<SerialPortHandler>> SerialPortHandlerCollection::GetSerialPortHandler(const std::string &a_SerialPortName, std::shared_ptr<HdlcdServerHandler> a_HdlcdServerHandler) {
    std::shared_ptr<std::shared_ptr<SerialPortHandler>> l_SerialPortHandler;
    bool l_HasToBeStarted = false;
    {
        // This is some magic here to implement automatic cleanup
        auto& l_SerialPortHandlerWeak(m_SerialPortHandlerMap[a_SerialPortName]);
        l_SerialPortHandler = l_SerialPortHandlerWeak.lock();
        if (!l_SerialPortHandler) {
            auto l_NewSerialPortHandler = std::make_shared<SerialPortHandler>(a_SerialPortName, shared_from_this(), m_IOService);
            std::shared_ptr<std::shared_ptr<SerialPortHandler>> l_NewSerialPortHandlerStopper(new std::shared_ptr<SerialPortHandler>(l_NewSerialPortHandler), [=](std::shared_ptr<SerialPortHandler>* todelete){ (*todelete)->Stop(); delete(todelete); });
            l_SerialPortHandler = l_NewSerialPortHandlerStopper;
            l_SerialPortHandlerWeak = l_SerialPortHandler;
            l_HasToBeStarted = true;
        } // if
    }
    
    l_SerialPortHandler.get()->get()->AddHdlcdServerHandler(a_HdlcdServerHandler);
    if (l_HasToBeStarted) {
        if (l_SerialPortHandler.get()->get()->Start() == false) {
            l_SerialPortHandler.reset();
        } // if
    } // if

    return l_SerialPortHandler;
}

void SerialPortHandlerCollection::DeregisterSerialPortHandler(std::shared_ptr<SerialPortHandler> a_SerialPortHandler) {
    assert(a_SerialPortHandler);
    for (auto it = m_SerialPortHandlerMap.begin(); it != m_SerialPortHandlerMap.end(); ++it) {
        if (auto cph = it->second.lock()) {
            if (*(cph.get()) == a_SerialPortHandler) {
                m_SerialPortHandlerMap.erase(it);
                break;
            } // if
        } // if
    } // for
}