SerialPortHandler.h

Go to the documentation of this file.

#ifndef SERIAL_PORT_HANDLER_H
#define SERIAL_PORT_HANDLER_H

#include <memory>
#include <string>
#include <vector>
#include <list>
#include <boost/asio.hpp>
#include "ISerialPortHandler.h"
#include "SerialPortLock.h"
#include "BaudRate.h"
class SerialPortHandlerCollection;
class HdlcdServerHandler;
class ProtocolState;

class SerialPortHandler: public ISerialPortHandler, public std::enable_shared_from_this<SerialPortHandler> {
public:
    // CTOR and DTOR
    SerialPortHandler(const std::string &a_SerialPortName, std::shared_ptr<SerialPortHandlerCollection> a_SerialPortHandlerCollection, boost::asio::io_service& a_IOService);
    ~SerialPortHandler();
    
    void AddHdlcdServerHandler(std::shared_ptr<HdlcdServerHandler> a_HdlcdServerHandler);
    void DeliverPayloadToHDLC(const std::vector<unsigned char> &a_Payload, bool a_bReliable);
    
    bool Start();
    void Stop();
    
    // Suspend / resume serial port
    void SuspendSerialPort();
    void ResumeSerialPort();
    
    void PropagateSerialPortState();

private:
    // Called by a ProtocolState object
    bool RequiresBufferType(E_BUFFER_TYPE a_eBufferType) const;
    void DeliverBufferToClients(E_BUFFER_TYPE a_eBufferType, const std::vector<unsigned char> &a_Payload, bool a_bReliable, bool a_bInvalid, bool a_bWasSent);
    bool OpenSerialPort();
    void ChangeBaudRate();
    void TransmitHDLCFrame(const std::vector<unsigned char> &a_Payload);
    void QueryForPayload(bool a_bQueryReliable, bool a_bQueryUnreliable);

    // Internal helpers
    void DoRead();
    void DoWrite();
    void ForEachHdlcdServerHandler(std::function<void(std::shared_ptr<HdlcdServerHandler>)> a_Function);
    
    // Members
    bool m_Registered;
    boost::asio::serial_port m_SerialPort;
    boost::asio::io_service &m_IOService;
    std::shared_ptr<ProtocolState> m_ProtocolState;
    std::string m_SerialPortName;
    std::weak_ptr<SerialPortHandlerCollection> m_SerialPortHandlerCollection;
    std::list<std::weak_ptr<HdlcdServerHandler>> m_HdlcdServerHandlerList;
    enum { max_length = 1024 };
    unsigned char m_ReadBuffer[max_length];
    
    std::vector<unsigned char> m_SendBuffer;
    size_t m_SendBufferOffset;
    SerialPortLock m_SerialPortLock;
    BaudRate m_BaudRate;
    
    // Track all subscribed clients
    size_t m_BufferTypeSubscribers[BUFFER_TYPE_ARITHMETIC_ENDMARKER];
};

#endif // SERIAL_PORT_HANDLER_H