AsyncSerial.h

/*
 * File:   AsyncSerial.h
 * Author: Terraneo Federico
 * Distributed under the Boost Software License, Version 1.0.
 * Created on September 7, 2009, 10:46 AM
 */
 
#ifndef ASYNCSERIAL_H
#define ASYNCSERIAL_H
 
#include <vector>
#include <boost/asio.hpp>
#include <boost/bind/bind.hpp>
#include <boost/thread.hpp>
#include <boost/utility.hpp>
#include <boost/function.hpp>
#include <boost/shared_array.hpp>
 
class AsyncSerialImpl;
 
class AsyncSerial : private boost::noncopyable
{
private:
  std::string mDevname;
 
  boost::asio::serial_port_base::baud_rate mBaudrate;
  boost::asio::serial_port_base::parity mParity;
  boost::asio::serial_port_base::character_size mCsize;
  boost::asio::serial_port_base::flow_control mFlow;
  boost::asio::serial_port_base::stop_bits mStopbit;
public:
  AsyncSerial();
 
  AsyncSerial(const std::string& devname, unsigned int baud_rate,
    boost::asio::serial_port_base::parity opt_parity =
    boost::asio::serial_port_base::parity(
    boost::asio::serial_port_base::parity::none),
    boost::asio::serial_port_base::character_size opt_csize =
    boost::asio::serial_port_base::character_size(8),
    boost::asio::serial_port_base::flow_control opt_flow =
    boost::asio::serial_port_base::flow_control(
    boost::asio::serial_port_base::flow_control::none),
    boost::asio::serial_port_base::stop_bits opt_stop =
    boost::asio::serial_port_base::stop_bits(
    boost::asio::serial_port_base::stop_bits::one));
 
  void open(const std::string& devname, unsigned int baud_rate,
    boost::asio::serial_port_base::parity opt_parity =
    boost::asio::serial_port_base::parity(
    boost::asio::serial_port_base::parity::none),
    boost::asio::serial_port_base::character_size opt_csize =
    boost::asio::serial_port_base::character_size(8),
    boost::asio::serial_port_base::flow_control opt_flow =
    boost::asio::serial_port_base::flow_control(
    boost::asio::serial_port_base::flow_control::none),
    boost::asio::serial_port_base::stop_bits opt_stop =
    boost::asio::serial_port_base::stop_bits(
    boost::asio::serial_port_base::stop_bits::one));
 
  bool isOpen() const;
 
  bool errorStatus() const;
 
  void close();
 
  void write(const char *data, size_t size);
 
  void write(const std::vector<char>& data);
 
  void writeString(const std::string& s);
 
  virtual ~AsyncSerial();
 
  static const int readBufferSize = 512;
private:
  void setQuitStatus(bool e);
 
  bool quitStatus() const;
 
 
  bool isPortAvailable(std::string portName);
 
  void doRead();
 
  void readEnd(const boost::system::error_code& error,
    size_t bytes_transferred);
 
  void doWrite();
 
  void writeEnd(const boost::system::error_code& error);
 
  void doClose();
 
  boost::shared_ptr<AsyncSerialImpl> pimpl;
 
protected:
 
  void setErrorStatus(bool e);
 
  void setReadCallback(const
    boost::function<void(const char*, size_t)>& callback);
 
  void clearReadCallback();
 
  void retry();
 
};
 
class CallbackAsyncSerial : public AsyncSerial
{
public:
  CallbackAsyncSerial();
 
  CallbackAsyncSerial(const std::string& devname, unsigned int baud_rate,
    boost::asio::serial_port_base::parity opt_parity =
    boost::asio::serial_port_base::parity(
    boost::asio::serial_port_base::parity::none),
    boost::asio::serial_port_base::character_size opt_csize =
    boost::asio::serial_port_base::character_size(8),
    boost::asio::serial_port_base::flow_control opt_flow =
    boost::asio::serial_port_base::flow_control(
    boost::asio::serial_port_base::flow_control::none),
    boost::asio::serial_port_base::stop_bits opt_stop =
    boost::asio::serial_port_base::stop_bits(
    boost::asio::serial_port_base::stop_bits::one));
 
  void setCallback(const
    boost::function<void(const char*, size_t)>& callback);
 
  void clearCallback();
 
  virtual ~CallbackAsyncSerial();
};
 
#endif //ASYNCSERIAL_H