stream_reader.h

Go to the documentation of this file.

#ifndef ODVA_ETHERNETIP_SERIALIZATION_STREAM_READER_H
#define ODVA_ETHERNETIP_SERIALIZATION_STREAM_READER_H

#include <stdexcept>
#include <boost/shared_ptr.hpp>
#include <boost/asio.hpp>

#include "odva_ethernetip/serialization/reader.h"

using boost::shared_ptr;
using boost::asio::mutable_buffer;
using boost::asio::buffer_cast;
using boost::asio::buffer_size;
using std::istream;

namespace eip {
namespace serialization {

class StreamReader : public Reader
{
public:

  StreamReader(shared_ptr<istream> isp) : isp_(isp) { }

  void readBytes(void* buf, size_t n)
  {
    isp_->read((char*)buf, n);
  }

  void readBuffer(mutable_buffer buf)
  {
    readBytes(buffer_cast<void*>(buf), buffer_size(buf));
  }

  size_t getByteCount()
  {
    return isp_->tellg();
  }

  virtual void skip(size_t n)
  {
    isp_->seekg(n, std::ios_base::cur);
  }
private:
  shared_ptr<istream> isp_;
};

} // namespace serialization
} // namespace eip
#endif  // ODVA_ETHERNETIP_SERIALIZATION_STREAM_READER_H