socketcand_windows_network_client.cpp

Go to the documentation of this file.

//================================================================================================
//================================================================================================
#include "isobus/hardware_integration/socketcand_windows_network_client.hpp"
 
#include "isobus/isobus/can_stack_logger.hpp"
 
namespace isobus
{
    SocketCANdNetworkInterface::SocketCANdNetworkInterface(std::string deviceName) :
      name(deviceName)
    {
        initialize();
    }
 
    SocketCANdNetworkInterface::SocketCANdNetworkInterface(std::string deviceName, const std::string ipAddress, std::uint16_t port) :
      name(deviceName),
      targetIP(ipAddress),
      targetPort(port)
    {
        initialize();
    }
 
    void SocketCANdNetworkInterface::initialize()
    {
        int result = WSAStartup(MAKEWORD(2, 2), &wsa_data);
        if (result != 0)
        {
            CANStackLogger::critical("[HW]: Cannot initialize WinSock.");
            WSACleanup();
        }
    }
 
    bool SocketCANdNetworkInterface::get_is_valid() const
    {
        return valid;
    }
 
    std::string SocketCANdNetworkInterface::get_device_name() const
    {
        return name;
    }
 
    const std::string SocketCANdNetworkInterface::get_connected_ip_address() const
    {
        return targetIP;
    }
 
    void SocketCANdNetworkInterface::close()
    {
    }
 
    void SocketCANdNetworkInterface::open()
    {
        if (!openCalled)
        {
            openCalled = true;
            mainSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
            beaconSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 
            if (INVALID_SOCKET == mainSocket)
            {
                CANStackLogger::critical("[HW]: Error: cannot create socket, error code: %d", WSAGetLastError());
                WSACleanup();
            }
            else
            {
                memset(&serverDefinition, 0, sizeof(serverDefinition));
                serverDefinition.sin_addr.s_addr = inet_addr(targetIP.c_str());
                serverDefinition.sin_family = AF_INET;
                serverDefinition.sin_port = htons(targetPort);
            }
        }
        else
        {
            CANStackLogger::critical("[HW]: Can't open %s because it is already open or there was a socket error.", name);
        }
    }
 
    bool SocketCANdNetworkInterface::read_frame(isobus::HardwareInterfaceCANFrame &canFrame)
    {
        int result = recv(sock, buf, count, 0);
 
        return result > 0;
    }
 
    bool SocketCANdNetworkInterface::write_frame(const isobus::HardwareInterfaceCANFrame &canFrame)
    {
        bool retVal = false;
 
        return retVal;
    }
} // namespace isobus