VehicleComm.cpp

Go to the documentation of this file.

//////////////////////////////////////////////////////////////////////////////
/*! \file VehicleComm.cpp
 *  \brief Defines the methods for the VehicleComm class.
 *  \author     $Author: rsharo $
 *  \version $Revision: 1.1 $
 *  \date    $Date: 2003/12/17 22:52:17 $
*////////////////////////////////////////////////////////////////////////////

#include "VehicleComm.h"

#include "ace/Synch.h"
#include "ace/SOCK_Dgram_Mcast.h"
#include "ace/SOCK_Dgram.h"

using SystemDefs::VehicleID_t;

VehicleComm::VehicleComm()
        : m_pMySocket(NULL),
          m_pMyConfig(NULL)
{
}

VehicleComm::VehicleComm(VehicleNetConfig *myConfig)
        : m_pMySocket(NULL),
          m_pMyConfig(NULL)
{
        this->Connect(myConfig);
}

VehicleComm::~VehicleComm()
{
        delete m_pMySocket;
        delete m_pMyConfig;
}

int VehicleComm::Connect(VehicleNetConfig *myConfig)
{
        m_pMyConfig = myConfig;

        if (m_pMySocket!= NULL)
        {
                ACE_DEBUG((LM_INFO, "Reconnecting VehicleComm -- deleting old socket.\n"));
                delete m_pMySocket;
        }

        m_pMySocket=new ACE_SOCK_Dgram_Mcast;

        if (m_pMySocket->subscribe(m_pMyConfig->GetMulticastAddress(), 1, m_pMyConfig->GetMulticastInterface()))
        {
                ACE_ERROR((LM_ERROR, "(%N:%l): %p", "subscribe"));
        }

        {
                u_char arg = m_pMyConfig->MulticastLoopbackEnabled();
                ACE_SOCK * pSocket = static_cast<ACE_SOCK *>(m_pMySocket);
                int status;
                
                status = pSocket->set_option(IPPROTO_IP, IP_MULTICAST_LOOP,
                        &arg, sizeof(arg));
                if (status < 0)
                        ACE_ERROR_RETURN((LM_NOTICE, "(%N:%l): set_option: %p"), -2);
                
                arg = m_pMyConfig->MulticastTimeToLive();
                status = pSocket->set_option(IPPROTO_IP, IP_MULTICAST_TTL,
                        &arg, sizeof(arg));
                if (status < 0)
                        ACE_ERROR_RETURN((LM_INFO, "(%N:%l): set_option: %p"), -2);
        }

        return 0;
}

int VehicleComm::SendMessage(VehicleID_t destID, void *pMessage, unsigned int msgLength)
{
        if (destID == SystemDefs::BROADCAST_ID)
                return this->BroadcastMessage(pMessage, msgLength);

        const ACE_INET_Addr &destAddr = m_pMyConfig->GetVehicleAddress(destID);

        ACE_SOCK_Dgram * pSocket = static_cast<ACE_SOCK_Dgram *>(m_pMySocket);

        int status = pSocket->send(pMessage, msgLength, destAddr);
        if (status < 0)
        {
        ACE_ERROR((LM_ERROR, "(%N:%l): send: %p"));
        }

        return status;
}

int VehicleComm::BroadcastMessage(void *pMessage, unsigned int msgLength)
{
        int status = m_pMySocket->send(pMessage, msgLength);
        if (status < 0)
        {
        ACE_ERROR((LM_ERROR, "(%N:%l): send: %p"));
        }

        return status;
}


int VehicleComm::GetMessage(void *pMessage, unsigned int maxMsgLength)
{
        ACE_INET_Addr whoFromAddr;
        int status = this->GetMessage(pMessage, maxMsgLength, whoFromAddr);

        return status;
}


int VehicleComm::GetMessage(void *pMessage, unsigned int maxMsgLength, VehicleID_t &srcID)
{
        ACE_INET_Addr whoFromAddr;
        int status = this->GetMessage(pMessage, maxMsgLength, whoFromAddr);

        if (status >= 0)
        {
                srcID = m_pMyConfig->VehicleAddressToID(whoFromAddr);
        }

        return status;
}

int VehicleComm::GetMessage(void *pMessage, unsigned int maxMsgLength, ACE_INET_Addr &whoFrom)
{
        int status = m_pMySocket->recv(pMessage, maxMsgLength, whoFrom);
        if (status < 0)
        {
        ACE_ERROR((LM_ERROR, "(%N:%l): recv: %p"));
        }

        return status;
}

---