---

socket_generic.cpp

Go to the documentation of this file.

#ifdef WIN32
#pragma warning (disable:4786)
#endif

#include "socket_generic.h"

// CL_Socket_Generic static operations:

sockaddr_in CL_Socket_Generic::create_sockaddr_in(const CL_IPAddress &address)
{
        sockaddr_in addr_in;
        memset(&addr_in, 0, sizeof(addr_in));
        addr_in.sin_family = AF_INET;
        addr_in.sin_addr.S_un.S_addr = address.get_address();
        addr_in.sin_port = htons(address.get_port());
        return addr_in;
}

CL_IPAddress CL_Socket_Generic::create_ip_address(const sockaddr_in &addr_in)
{
        return CL_IPAddress(addr_in.sin_addr.S_un.S_addr, ntohs(addr_in.sin_port));
}

// CL_Socket_Generic construction:

CL_Socket_Generic::CL_Socket_Generic()
: ref_count(0), sock(-1), read(NULL), write(NULL), exception(NULL)
{
}

CL_Socket_Generic::~CL_Socket_Generic()
{
        delete read;
        delete write;
        delete exception;
}

// CL_Socket_Generic attributes:

// CL_Socket_Generic operations:

void CL_Socket_Generic::add_ref()
{
        ref_count++;
}

void CL_Socket_Generic::release_ref()
{
        ref_count--;
        if (ref_count == 0)
        {
                closesocket(sock);
                delete this;
        }
}

// CL_Socket_Generic overridables:

CL_EventTrigger_Socket *CL_Socket_Generic::create_read_trigger()
{
        return new CL_EventTrigger_Socket(this, CL_EventTrigger_Socket::read);
}

CL_EventTrigger_Socket *CL_Socket_Generic::create_write_trigger()
{
        return new CL_EventTrigger_Socket(this, CL_EventTrigger_Socket::write);
}

CL_EventTrigger_Socket *CL_Socket_Generic::create_exception_trigger()
{
        return new CL_EventTrigger_Socket(this, CL_EventTrigger_Socket::exception);
}

void CL_Socket_Generic::keep_alive()
{
        // performance note: it would be much more efficient if we maintained a global
        // list of all sockets instanciated, and then do one select for them all.
        //
        // I'm too lazy to do that - at least until it becomes a real performance problem.
        // -- mbn 2. marts 2001

        fd_set rfds, wfds, efds;
        FD_ZERO(&rfds);
        FD_ZERO(&wfds);
        FD_ZERO(&efds);

        FD_SET(sock, &rfds);
        FD_SET(sock, &wfds);
        FD_SET(sock, &efds);

        timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 0;

        int result = select(sock+1, &rfds, &wfds, &efds, &tv);
        if (result > 0)
        {
                if (FD_ISSET(sock, &rfds)) sig_read_triggered();
                if (FD_ISSET(sock, &wfds)) sig_write_triggered();
                if (FD_ISSET(sock, &efds)) sig_exception_triggered();
        }
}

// CL_Socket_Generic implementation:

---