syncSerialPort.h

Go to the documentation of this file.

#pragma once

#include <boost/chrono.hpp>
#include <boost/asio/waitable_timer_service.hpp>
#include "serialPort.h"

struct InputOutputObject
{
    boost::asio::io_service mIo;

    explicit InputOutputObject() : mIo() {};
};

typedef boost::asio::basic_waitable_timer<boost::chrono::steady_clock> steady_timer; 

class SyncSerialPort: private InputOutputObject, public SerialPort
{
public:
    SyncSerialPort(const char* port, int baud_rate, boost::asio::serial_port_base::flow_control::type flow, TypeRec type = nocanonical);

    SyncSerialPort();

    virtual ~SyncSerialPort();

#ifdef TESTING
    virtual bool send(const char* buffer, int size);
    virtual size_t readWithTimeout(char* buff, size_t max_length, int timeout_ms);
#else

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

    size_t readWithTimeout(char* buff, size_t max_length, int timeout_ms);
#endif

private:
    void read_callback(bool& data_available, std::size_t& bytes_read, const boost::system::error_code& error, std::size_t bytes_transferred);

    void wait_callback(const boost::system::error_code& error);

private:
    steady_timer m_timer;
    std::mutex receiveLock;

#ifdef TESTING
public:
    FRIEND_TEST(SerialPort_test, Open_Close_Short_Sync_Serial_Port_Non_Canonical_OK);
    FRIEND_TEST(SerialPort_test, Open_Close_Long_Sync_Serial_Port_Canonical_OK);
    FRIEND_TEST(SerialPort_test, Open_Sync_Serial_Port_ERROR);
    FRIEND_TEST(SerialPort_test, Receive_Sync_Serial_Port_OK);
    FRIEND_TEST(SerialPort_test, Receive_Sync_Serial_Port_ERROR);
    FRIEND_TEST(SerialPort_test, Send_Sync_Serial_Port_OK);
    FRIEND_TEST(SerialPort_test, Send_Sync_Serial_Port_ERROR);
#endif
};