socket_channel.cpp

Go to the documentation of this file.

#include <opc/ua/socket_channel.h>
#include <opc/ua/errors.h>


#include <errno.h>
#include <iostream>

#include <stdexcept>
#include <string.h>

#include <sys/types.h>


#ifdef _WIN32
#include <WinSock2.h>
#else
#include <arpa/inet.h>
#include <netinet/tcp.h>
#include <sys/socket.h>
#include <unistd.h>
#endif


OpcUa::SocketChannel::SocketChannel(int sock)
  : Socket(sock)
{
  int flag = 1;
  setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char *) &flag, sizeof(int));

  if (Socket < 0)
    {
      THROW_ERROR(CannotCreateChannelOnInvalidSocket);
    }
}

OpcUa::SocketChannel::~SocketChannel()
{
  Stop();
}

void OpcUa::SocketChannel::Stop()
{
  close(Socket);
}

std::size_t OpcUa::SocketChannel::Receive(char * data, std::size_t size)
{
  int received = recv(Socket, data, size, MSG_WAITALL);

  if (received < 0)
    {
      THROW_OS_ERROR("Failed to receive data from host.");
    }

  if (received == 0)
    {
      THROW_OS_ERROR("Connection was closed by host.");
    }

  return (std::size_t)size;
}

void OpcUa::SocketChannel::Send(const char * message, std::size_t size)
{
  int sent = send(Socket, message, size, 0);

  if (sent != (int)size)
    {
      THROW_OS_ERROR("unable to send data to the host. ");
    }
}