syncSerialPort.h

Go to the documentation of this file.

 
#pragma once
 
#include <boost/chrono.hpp>
#include <boost/asio/basic_waitable_timer.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
};