CvsiUDPsocket Class Reference

#include <vsisocket.h>

Public Member Functions
	CvsiUDPsocket ()
	~CvsiUDPsocket ()
int	Initialize (vsiIPaddress *LocalAddress)
int	Close ()
int	IsOpen ()
int	Send (vsiIPaddress *Target, char *Buffer, int Size)
int	Receive (vsiIPaddress *Source, char *Buffer, int *Size)
Private Attributes
int	m_Socket

---

Detailed Description

Definition at line 39 of file vsisocket.h.

---

Constructor & Destructor Documentation

CvsiUDPsocket::CvsiUDPsocket

(

)

Definition at line 71 of file vsisocket.cpp.

{
    m_Socket = VSI_INVALID_SOCKET;
}

CvsiUDPsocket::~CvsiUDPsocket

(

)

Definition at line 76 of file vsisocket.cpp.

{
    if(m_Socket != VSI_INVALID_SOCKET)
    {
        Close();
    }
}

---

Member Function Documentation

int CvsiUDPsocket::Close

(

void

)

Definition at line 135 of file vsisocket.cpp.

{
    if(m_Socket != VSI_INVALID_SOCKET)
    {
        close(m_Socket);
        m_Socket = VSI_INVALID_SOCKET;
        return (0);
    }
    return VSI_ERROR_SOCKET_NOT_OPEN;
}

int CvsiUDPsocket::Initialize

(

vsiIPaddress *

LocalAddress

)

Definition at line 96 of file vsisocket.cpp.

{
    int sock;
    struct sockaddr_in myaddress;

    if(m_Socket != VSI_INVALID_SOCKET)
    {
        Close();
    }

    // create UDP socket
    sock = socket (AF_INET, SOCK_DGRAM, 0);
    if(sock < 0 )
    {
        return VSI_ERROR_SOCKET_CREATION;
    }

    // Initialize local address
    myaddress.sin_family = AF_INET;
    myaddress.sin_port = LocalAddress->Port;

    if(LocalAddress->Host == VSI_SOCKET_UNDEFINED_IP_ADDRESS)
        myaddress.sin_addr.s_addr = INADDR_ANY;
    else
        myaddress.sin_addr.s_addr = LocalAddress->Host;

    // bind socket to local IP address
    if( bind (sock,(sockaddr *) &myaddress,sizeof(myaddress)) < 0)
    {
        close (sock);
        return VSI_ERROR_SOCKET_BIND;
    }

    m_Socket = sock;
    return (0);
}

int CvsiUDPsocket::IsOpen

(

)

Definition at line 86 of file vsisocket.cpp.

{
    if(m_Socket == VSI_INVALID_SOCKET)
        return false;
    else
        return true;
}

int CvsiUDPsocket::Receive	(	vsiIPaddress *	Source,
		char *	Buffer,
		int *	Size
	)

Definition at line 197 of file vsisocket.cpp.

{
    struct sockaddr_in orig;
    unsigned int origsize = sizeof(orig);

    if(m_Socket == VSI_INVALID_SOCKET)
    {
        return VSI_ERROR_SOCKET_NOT_OPEN;
    }

    int nb = recvfrom ( m_Socket, Buffer, *nBytes, MSG_WAITALL,
                (sockaddr*) &orig, &origsize);

    if(nb < 0)
    {
        Rioperror("CvsiUDPsocket::Receive()");
        return VSI_ERROR_SOCKET_RECV;
    }
    // Update source address structure
    Source->Host = orig.sin_addr.s_addr;
    Source->Port = orig.sin_port;

    *nBytes = nb;

    return (0);
}

int CvsiUDPsocket::Send	(	vsiIPaddress *	Target,
		char *	Buffer,
		int	Size
	)

Definition at line 148 of file vsisocket.cpp.

{
    struct sockaddr_in dest;

    if(m_Socket == VSI_INVALID_SOCKET)
    {
        return VSI_ERROR_SOCKET_NOT_OPEN;
    }

    // Initialize destination address structure
    dest.sin_family = AF_INET;
    dest.sin_addr.s_addr = Target->Host;
    dest.sin_port = Target->Port;

    int nb;

    // loop necessary for error ECONREFUSED which is ignored
    // (see comment bellow)
    while(1)
    {
        nb  = sendto ( m_Socket, Buffer, nBytes, MSG_WAITALL,
            (sockaddr*) &dest, sizeof (dest));
        // Check if there was an error
        if(nb < 0)
        {
            /* can get ECONREFUSED on any socket operation from
            the same socket which sent a packet which caused
            an ICMP error from some host - ignore these
            (which were for a previous sent packet)
            and resend this packet */
            if(errno != ECONNREFUSED)
            {
                return VSI_ERROR_SOCKET_SEND;
            }
        }
        else
        {
            if(nb != nBytes)
            {
                return VSI_ERROR_SOCKET_SEND_INCOMPLETE;
            }
            return (0);
        }
    }
}

---

Field Documentation

int CvsiUDPsocket::m_Socket [private]

Definition at line 50 of file vsisocket.h.

---

The documentation for this class was generated from the following files:

• vsisocket.h
• vsisocket.cpp