socket.h

Go to the documentation of this file.

 
#ifndef ODVA_ETHERNETIP_SOCKET_SOCKET_H
#define ODVA_ETHERNETIP_SOCKET_SOCKET_H
 
#include <string>
#include <boost/asio.hpp>
 
#if BOOST_VERSION >= 107000
#define GET_IO_SERVICE(s) ((boost::asio::io_context&)(s)->get_executor().context())
#else
#define GET_IO_SERVICE(s) ((s)->get_io_service())
#endif
 
#include "odva_ethernetip/serialization/serializable.h"
#include "odva_ethernetip/serialization/buffer_writer.h"
 
using std::string;
using std::size_t;
using boost::asio::buffer;
using boost::asio::const_buffer;
using boost::asio::mutable_buffer;
 
namespace eip {
 
using serialization::Serializable;
using serialization::BufferWriter;
 
namespace socket {
 
class Socket
{
public:
 
  virtual ~Socket() { }
 
  virtual void open(string hostname, string port) = 0;
 
  virtual void close() = 0;
 
  virtual size_t send(const_buffer buf) = 0;
 
  virtual size_t send(const Serializable& msg)
  {
    std::vector<char> buf(msg.getLength());
    BufferWriter writer(buffer(buf));
    msg.serialize(writer);
    return send(buffer(buf));
  }
 
  virtual size_t receive(mutable_buffer buf) = 0;
 
};
 
} // namespace socket
} // namespace eip
#endif  // ODVA_ETHERNETIP_SOCKET_SOCKET_H