mxoemu/Dependencies/Sockets/SocketHandlerEp.cpp

/** \file SocketHandler.cpp
 **	\date  2010-02-13
 **	\author grymse@alhem.net
**/
/*
Copyright (C) 2004-2010  Anders Hedstrom

This library is made available under the terms of the GNU GPL, with
the additional exemption that compiling, linking, and/or using OpenSSL 
is allowed.

If you would like to use this library in a closed-source application,
a separate license agreement is available. For information about 
the closed-source license agreement for the C++ sockets library,
please visit http://www.alhem.net/Sockets/license.html and/or
email license@alhem.net.

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
*/
#include "SocketHandlerEp.h"
#include "Exception.h"
#include "IMutex.h"
#include "Utility.h"

#include <errno.h>


#ifdef SOCKETS_NAMESPACE
namespace SOCKETS_NAMESPACE {
#endif


SocketHandlerEp::SocketHandlerEp(StdLog *p)
:SocketHandler(p)
,m_epoll(-1)
{
#ifdef LINUX
	m_epoll = epoll_create(FD_SETSIZE);
	if (m_epoll == -1)
	{
		throw Exception(StrError(Errno));
	}
#endif
}


SocketHandlerEp::SocketHandlerEp(IMutex& mutex, StdLog *p)
:SocketHandler(mutex, p)
,m_epoll(-1)
{
#ifdef LINUX
	m_epoll = epoll_create(FD_SETSIZE);
	if (m_epoll == -1)
	{
		throw Exception(StrError(Errno));
	}
#endif
}


SocketHandlerEp::SocketHandlerEp(IMutex& mutex, ISocketHandler& parent, StdLog *p)
:SocketHandler(mutex, parent, p)
,m_epoll(-1)
{
#ifdef LINUX
	m_epoll = epoll_create(FD_SETSIZE);
	if (m_epoll == -1)
	{
		throw Exception(StrError(Errno));
	}
#endif
}


SocketHandlerEp::~SocketHandlerEp()
{
#ifdef LINUX
	if (m_epoll != -1)
	{
		close(m_epoll);
	}
#endif
}


ISocketHandler *SocketHandlerEp::Create(StdLog *log)
{
	return new SocketHandlerEp(log);
}


ISocketHandler *SocketHandlerEp::Create(IMutex& mutex, ISocketHandler& parent, StdLog *log)
{
	return new SocketHandlerEp(mutex, parent, log);
}


#ifdef LINUX
void SocketHandlerEp::ISocketHandler_Add(Socket *p,bool bRead,bool bWrite)
{
	struct epoll_event stat;
	SOCKET s = p -> GetSocket();
	stat.data.ptr = p;
	stat.events = (bRead ? EPOLLIN : 0) | (bWrite ? EPOLLOUT : 0);
	if (epoll_ctl(m_epoll, EPOLL_CTL_ADD, s, &stat) == -1)
	{
		LogError(NULL, "epoll_ctl: EPOLL_CTL_ADD", Errno, StrError(Errno));
	}
}


void SocketHandlerEp::ISocketHandler_Mod(Socket *p,bool r,bool w)
{
	struct epoll_event stat;
	SOCKET s = p -> GetSocket();
	stat.data.ptr = p;
	stat.events = (r ? EPOLLIN : 0) | (w ? EPOLLOUT : 0);
	if (epoll_ctl(m_epoll, EPOLL_CTL_MOD, s, &stat) == -1)
	{
//		LogError(NULL, "epoll_ctl: EPOLL_CTL_MOD", Errno, StrError(Errno));
	}
}


void SocketHandlerEp::ISocketHandler_Del(Socket *p)
{
	struct epoll_event stat;
	stat.events = 0;
	stat.data.ptr = p;
	if (epoll_ctl(m_epoll, EPOLL_CTL_DEL, p -> GetSocket(), &stat) == -1)
	{
//		LogError(NULL, "epoll_ctl: EPOLL_CTL_DEL", Errno, StrError(Errno));
	}
}


int SocketHandlerEp::ISocketHandler_Select(struct timeval *tsel)
{
	int n;
	if (m_b_use_mutex)
	{
		m_mutex.Unlock();
		n = epoll_wait(m_epoll, m_events, MAX_EVENTS_EP_WAIT, tsel ? tsel -> tv_sec * 1000 + tsel -> tv_usec / 1000 : -1);
		m_mutex.Lock();
	}
	else
	{
		n = epoll_wait(m_epoll, m_events, MAX_EVENTS_EP_WAIT, tsel ? tsel -> tv_sec * 1000 + tsel -> tv_usec / 1000 : -1);
	}
	if (n == -1)
	{
		LogError(NULL, "epoll_wait", Errno, StrError(Errno));
	}
	else
	if (!n)
	{
	}
	else
	if (n > 0)
	{
		for (int x = 0; x < n; x++)
		{
			Socket *p = static_cast<Socket *>(m_events[x].data.ptr);
			if ((m_events[x].events & EPOLLIN) || (m_events[x].events & EPOLLHUP))
			{
#ifdef HAVE_OPENSSL
				if (p -> IsSSLNegotiate())
				{
					p -> SSLNegotiate();
				}
				else
#endif
				{
					p -> OnRead();
				}
			}
			if (m_events[x].events & EPOLLOUT)
			{
#ifdef HAVE_OPENSSL
				if (p -> IsSSLNegotiate())
				{
					p -> SSLNegotiate();
				}
				else
#endif
				{
					p -> OnWrite();
				}
			}
			if (m_events[x].events & EPOLLERR)
			{
				p -> OnException();
			}
		}
	}
	return n;
}
#endif


#ifdef SOCKETS_NAMESPACE
}
#endif