asyncSerialPort.h

Go to the documentation of this file.

#pragma once

#include <list>
#include "serialPort.h"

class AsyncSerialPort: public SerialPort
{
private:
    typedef boost::function<void(const char* s, int n)> F_READ;

public:
    AsyncSerialPort(boost::asio::io_service& io, const char* port, int baud_rate, boost::asio::serial_port_base::flow_control::type flow, const F_READ& f = NULL, TypeRec type = nocanonical);

    explicit AsyncSerialPort(boost::asio::io_service& io);

    ~AsyncSerialPort();

    bool open(boost::system::error_code& ec);

    void setReadCallback(const F_READ& f);

    bool send(const char* buffer, int size);

public:
    void handle_send_to(const boost::system::error_code& error);

    void handle_receive_from(const boost::system::error_code& error, size_t bytes_recvd);

protected:
    typedef std::list<VC_DATA> VC_PAQ;

    boost::asio::io_service::strand m_strand;

    F_READ m_fRead;

    enum
     {
         max_length = 1024
     };

    char m_data[max_length];

    VC_PAQ m_vcDataSend;

#ifdef TESTING
public:
    FRIEND_TEST(SerialPort_test, Open_Close_Short_Async_Serial_Port_Non_Canonical_OK);
    FRIEND_TEST(SerialPort_test, Open_Close_Long_Async_Serial_Port_Canonical_OK);
    FRIEND_TEST(SerialPort_test, Open_Async_Serial_Port_ERROR);
    FRIEND_TEST(SerialPort_test, Send_Async_Serial_Port_ERROR);
    FRIEND_TEST(SerialPort_test, Receive_Async_Serial_Port_OK);
#endif
};