/*
EHS is a library for adding web server support to a C++ application
Copyright (C) 2001, 2002 Zac Hansen
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; version 2
of the License only.
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.
or see http://www.gnu.org/licenses/gpl.html
Zac Hansen ( xaxxon@slackworks.com )
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
/*
* Solaris 2.6 troubles
*/
#ifdef sun
#ifndef BSD_COMP
#define BSD_COMP 1
#endif
#ifndef _XPG4_2
#define _XPG4_2 1
#endif
#ifndef __EXTENSIONS__
#define __EXTENSIONS__ 1
#endif
#ifndef __PRAGMA_REDEFINE_EXTNAME
#define __PRAGMA_REDEFINE_EXTNAME 1
#endif
#endif // sun
#include "socket.h"
#ifndef _WIN32
#include <assert.h>
#include <stdio.h>
#include <sys/ioctl.h>
#endif
#ifndef MSG_NOSIGNAL
#define MSG_NOSIGNAL 0 // no support
#endif // MSG_NOSIGNAL
#include <sstream>
using namespace std;
Socket::Socket ( int inAcceptSocket,
sockaddr_in * ipoInternetSocketAddress )
{
nAcceptSocket = inAcceptSocket;
memcpy ( &oInternetSocketAddress,
ipoInternetSocketAddress,
sizeof ( oInternetSocketAddress ) );
}
Socket::~Socket ( )
{
}
NetworkAbstraction::InitResult
Socket::Init ( int inPort ///< port on which to listen
)
{
#ifdef _WIN32
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 2, 2 );
err = WSAStartup( wVersionRequested, &wsaData );
// Found a usable winsock dll?
assert( err == 0 );
/* Confirm that the WinSock DLL supports 2.2.*/
/* Note that if the DLL supports versions greater */
/* than 2.2 in addition to 2.2, it will still return */
/* 2.2 in wVersion since that is the version we */
/* requested. */
if (
LOBYTE( wsaData.wVersion ) != 2
|| HIBYTE( wsaData.wVersion ) != 2
) {
/* Tell the user that we could not find a usable */
/* WinSock DLL. */
WSACleanup( );
#ifdef EHS_DEBUG
cerr << "[EHS_DEBUG] Critical Error: Couldn't find useable Winsock DLL. Must be at least 2.2. Aborting" << endl;
#endif
assert( false );
}
/* The WinSock DLL is acceptable. Proceed. */
#endif // End WIN32-specific network initialization code
// need to create a socket for listening for new connections
#ifdef EHS_DEBUG
if ( nAcceptSocket != 0 ) {
cerr << "[EHS_DEBUG] nAcceptSocket = " << nAcceptSocket << endl;
assert ( nAcceptSocket == 0 );
}
#endif
nAcceptSocket = socket ( AF_INET, SOCK_STREAM, 0 );
if ( nAcceptSocket == -1 ) {
#ifdef EHS_DEBUG
cerr << "[EHS_DEBUG] Error: socket() failed" << endl;
#endif
return INITSOCKET_SOCKETFAILED;
}
#ifdef _WIN32
u_long MyTrueVar = 1;
ioctlsocket ( nAcceptSocket, FIONBIO, &MyTrueVar );
#else
int MyTrueVar = 1;
ioctl ( nAcceptSocket, FIONBIO, &MyTrueVar );
MyTrueVar = 1; // not sure if it was changed in ioctl, so re-set it
setsockopt ( nAcceptSocket, SOL_SOCKET, SO_REUSEADDR, (const void *) &MyTrueVar, sizeof ( int ) );
#endif
// bind the socket to the appropriate port
struct sockaddr_in oSocketInfo;
memset ( &oSocketInfo, 0, sizeof ( oSocketInfo ) );
int nResult = -1;
// IP address is 32 bits, int is 32 bits..
// binds to all interfaces. This maybe should be customizable
int nSinAddr = INADDR_ANY;
oSocketInfo.sin_family = AF_INET;
memcpy ( & ( oSocketInfo.sin_addr ), &nSinAddr, sizeof ( oSocketInfo.sin_addr ) );
oSocketInfo.sin_port = htons ( inPort );
nResult = bind ( nAcceptSocket, (sockaddr *)&oSocketInfo, sizeof ( sockaddr_in ) );
if ( nResult == -1 ) {
#ifdef EHS_DEBUG
cerr << "[EHS_DEBUG] Error: bind() failed" << endl;
#endif
return INITSOCKET_BINDFAILED;
}
// listen
nResult = listen ( nAcceptSocket, 20 );
if ( nResult != 0 ) {
#ifdef EHS_DEBUG
cerr << "[EHS_DEBUG] Error: listen() failed" << endl;
#endif
return INITSOCKET_LISTENFAILED;
}
return INITSOCKET_SUCCESS;
}
int Socket::Read ( void * ipBuffer, int ipBufferLength )
{
//return read ( nAcceptSocket, ipBuffer, ipBufferLength );
return recv ( nAcceptSocket,
#ifdef _WIN32
(char *) ipBuffer,
#else
ipBuffer,
#endif
ipBufferLength, 0 );
}
int Socket::Send ( const void * ipMessage, size_t inLength, int inFlags )
{
return send ( nAcceptSocket,
#ifdef _WIN32
(const char *) ipMessage,
#else
ipMessage,
#endif
inLength, inFlags | MSG_NOSIGNAL );
}
void Socket::Close ( )
{
#ifdef _WIN32
closesocket ( nAcceptSocket );
#else
close ( nAcceptSocket );
#endif
}
NetworkAbstraction * Socket::Accept ( )
{
size_t oInternetSocketAddressLength = sizeof ( oInternetSocketAddress );
int nNewFd = accept ( nAcceptSocket,
(sockaddr *) &oInternetSocketAddress,
#ifdef _WIN32
(int *) &oInternetSocketAddressLength
#else
&oInternetSocketAddressLength
#endif
);
#ifdef EHS_DEBUG
cerr
<< "Got a connection from " << GetAddress() << ":"
<< ntohs(oInternetSocketAddress.sin_port) << endl;
#endif
if ( nNewFd == -1 ) {
return NULL;
}
Socket * poSocket = new Socket ( nNewFd, &oInternetSocketAddress );
#ifdef EHS_DEBUG
cerr
<< "[EHS_DEBUG] Allocated new socket object with fd="
<< nNewFd << " and socket @0x" << hex << poSocket << endl;
#endif
return poSocket;
}
string Socket::GetAddress ( )
{
ostringstream oss;
oss
<< ((ntohl(oInternetSocketAddress.sin_addr.s_addr) >> 24 ) & 0xff) << "."
<< ((ntohl(oInternetSocketAddress.sin_addr.s_addr) >> 16 ) & 0xff) << "."
<< ((ntohl(oInternetSocketAddress.sin_addr.s_addr) >> 8 ) & 0xff) << "."
<< ((ntohl(oInternetSocketAddress.sin_addr.s_addr) >> 0 ) & 0xff) << endl;
return oss.str();
}
int Socket::GetPort ( )
{
return ntohs ( oInternetSocketAddress.sin_port );
}