summaryrefslogtreecommitdiff
path: root/src/PracticalSocket.cpp
diff options
context:
space:
mode:
authorOthmar Gsenger <otti@anytun.org>2008-11-28 18:45:57 +0000
committerOthmar Gsenger <otti@anytun.org>2008-11-28 18:45:57 +0000
commitac2147483cfcbb6f01123d65e67b7bb363bddc8f (patch)
treed7812a08b15dbc54df6f97b7b64ae913972f309b /src/PracticalSocket.cpp
parentsome more type cleanups and missig NOCRYPT defines (diff)
added some windows support (not working now)
try to build with following Options: NOCRYPT;NODAEMON;NOEXEC;NOPACKED;NOSYSLOG;NOROUTING;NOSIGNALCONTROLLER
Diffstat (limited to 'src/PracticalSocket.cpp')
-rw-r--r--src/PracticalSocket.cpp480
1 files changed, 0 insertions, 480 deletions
diff --git a/src/PracticalSocket.cpp b/src/PracticalSocket.cpp
deleted file mode 100644
index 6f53da6..0000000
--- a/src/PracticalSocket.cpp
+++ /dev/null
@@ -1,480 +0,0 @@
-/*
- * anytun
- *
- * The secure anycast tunneling protocol (satp) defines a protocol used
- * for communication between any combination of unicast and anycast
- * tunnel endpoints. It has less protocol overhead than IPSec in Tunnel
- * mode and allows tunneling of every ETHER TYPE protocol (e.g.
- * ethernet, ip, arp ...). satp directly includes cryptography and
- * message authentication based on the methodes used by SRTP. It is
- * intended to deliver a generic, scaleable and secure solution for
- * tunneling and relaying of packets of any protocol.
- *
- *
- * Copyright (C) 2007-2008 Othmar Gsenger, Erwin Nindl,
- * Christian Pointner <satp@wirdorange.org>
- *
- * This file is part of Anytun.
- *
- * Anytun is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License version 3 as
- * published by the Free Software Foundation.
- *
- * Anytun 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 anytun. If not, see <http://www.gnu.org/licenses/>.
- */
-
-#include "datatypes.h"
-
-// this is from: http://cs.ecs.baylor.edu/~donahoo/practical/CSockets/practical/
-// and this is their header:
-/*
- * C++ sockets on Unix and Windows
- * Copyright (C) 2002
- *
- * 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 "PracticalSocket.h"
-
-#ifdef WIN32
- #include <winsock.h> // For socket(), connect(), send(), and recv()
- typedef int socklen_t;
- typedef char raw_type; // Type used for raw data on this platform
-#else
- #include <sys/types.h> // For data types
- #include <sys/socket.h> // For socket(), connect(), send(), and recv()
- #include <netdb.h> // For gethostbyname()
- #include <arpa/inet.h> // For inet_addr()
- #include <unistd.h> // For close()
- #include <netinet/in.h> // For sockaddr_in
- #include <poll.h>
- typedef void raw_type; // Type used for raw data on this platform
-#endif
-
-#include <cstring> // for strerror_r
-#include <errno.h> // For errno
-
-using namespace std;
-
-#ifdef WIN32
-static bool initialized = false;
-#endif
-
-// SocketException Code
-
-SocketException::SocketException(const string &message, bool inclSysMsg)
- throw() : userMessage(message) {
- if (inclSysMsg) {
- userMessage.append(": ");
- char buf[STERROR_TEXT_MAX];
- buf[0] = 0;
- strerror_r(errno, buf, STERROR_TEXT_MAX);
- userMessage.append(buf);
- }
-}
-
-SocketException::~SocketException() throw() {
-}
-
-const char *SocketException::what() const throw() {
- return userMessage.c_str();
-}
-
-// Function to fill in address structure given an address and port
-static void fillAddr(const string &address, unsigned short port,
- sockaddr_in &addr) {
- memset(&addr, 0, sizeof(addr)); // Zero out address structure
- addr.sin_family = AF_INET; // Internet address
-
- hostent *host; // Resolve name
- if ((host = gethostbyname(address.c_str())) == NULL) {
- // strerror() will not work for gethostbyname() and hstrerror()
- // is supposedly obsolete
- throw SocketException("Failed to resolve name (gethostbyname())");
- }
- addr.sin_addr.s_addr = *((unsigned long *) host->h_addr_list[0]);
-
- addr.sin_port = htons(port); // Assign port in network byte order
-}
-
-// Socket Code
-
-Socket::Socket(int type, int protocol) throw(SocketException) {
- #ifdef WIN32
- if (!initialized) {
- WORD wVersionRequested;
- WSADATA wsaData;
-
- wVersionRequested = MAKEWORD(2, 0); // Request WinSock v2.0
- if (WSAStartup(wVersionRequested, &wsaData) != 0) { // Load WinSock DLL
- throw SocketException("Unable to load WinSock DLL");
- }
- initialized = true;
- }
- #endif
-
- // Make a new socket
- if ((sockDesc = socket(PF_INET, type, protocol)) < 0) {
- throw SocketException("Socket creation failed (socket())", true);
- }
-}
-
-Socket::Socket(int sockDesc) {
- this->sockDesc = sockDesc;
-}
-
-Socket::~Socket() {
- #ifdef WIN32
- ::closesocket(sockDesc);
- #else
- ::close(sockDesc);
- #endif
- sockDesc = -1;
-}
-
-string Socket::getLocalAddress() throw(SocketException) {
- sockaddr_in addr;
- unsigned int addr_len = sizeof(addr);
-
- if (getsockname(sockDesc, (sockaddr *) &addr, (socklen_t *) &addr_len) < 0) {
- throw SocketException("Fetch of local address failed (getsockname())", true);
- }
- return inet_ntoa(addr.sin_addr);
-}
-
-unsigned short Socket::getLocalPort() throw(SocketException) {
- sockaddr_in addr;
- unsigned int addr_len = sizeof(addr);
-
- if (getsockname(sockDesc, (sockaddr *) &addr, (socklen_t *) &addr_len) < 0) {
- throw SocketException("Fetch of local port failed (getsockname())", true);
- }
- return ntohs(addr.sin_port);
-}
-
-void Socket::setLocalPort(unsigned short localPort) throw(SocketException) {
- // Bind the socket to its port
- sockaddr_in localAddr;
- memset(&localAddr, 0, sizeof(localAddr));
- localAddr.sin_family = AF_INET;
- localAddr.sin_addr.s_addr = htonl(INADDR_ANY);
- localAddr.sin_port = htons(localPort);
-
- if (bind(sockDesc, (sockaddr *) &localAddr, sizeof(sockaddr_in)) < 0) {
- throw SocketException("Set of local port failed (bind())", true);
- }
-}
-
-void Socket::setLocalAddressAndPort(const string &localAddress,
- unsigned short localPort) throw(SocketException) {
- // Get the address of the requested host
- sockaddr_in localAddr;
- fillAddr(localAddress, localPort, localAddr);
-
- if (bind(sockDesc, (sockaddr *) &localAddr, sizeof(sockaddr_in)) < 0) {
- throw SocketException("Set of local address and port failed (bind())", true);
- }
-}
-
-void Socket::setSocketOpt(int optionName, const void* optionValue, socklen_t optionLen)
- throw(SocketException)
-{
- if (::setsockopt(sockDesc, SOL_SOCKET, optionName, optionValue, optionLen) < 0) {
- throw SocketException("setSockopt failed", true);
- }
-}
-
-void Socket::cleanUp() throw(SocketException) {
- #ifdef WIN32
- if (WSACleanup() != 0) {
- throw SocketException("WSACleanup() failed");
- }
- #endif
-}
-
-unsigned short Socket::resolveService(const string &service,
- const string &protocol) {
- struct servent *serv; /* Structure containing service information */
-
- if ((serv = getservbyname(service.c_str(), protocol.c_str())) == NULL)
- return atoi(service.c_str()); /* Service is port number */
- else
- return ntohs(serv->s_port); /* Found port (network byte order) by name */
-}
-
-// CommunicatingSocket Code
-
-CommunicatingSocket::CommunicatingSocket(int type, int protocol)
- throw(SocketException) : Socket(type, protocol) {
-}
-
-CommunicatingSocket::CommunicatingSocket(int newConnSD) : Socket(newConnSD) {
-}
-
-void CommunicatingSocket::connect(const string &foreignAddress,
- unsigned short foreignPort) throw(SocketException) {
- // Get the address of the requested host
- sockaddr_in destAddr;
- fillAddr(foreignAddress, foreignPort, destAddr);
-
- // Try to connect to the given port
- if (::connect(sockDesc, (sockaddr *) &destAddr, sizeof(destAddr)) < 0) {
- throw SocketException("Connect failed (connect())", true);
- }
-}
-
-void CommunicatingSocket::send(const void *buffer, int bufferLen)
- throw(SocketException) {
- if (::send(sockDesc, (raw_type *) buffer, bufferLen, 0) < 0) {
- throw SocketException("Send failed (send())", true);
- }
-}
-
-int CommunicatingSocket::recv(void *buffer, int bufferLen)
- throw(SocketException) {
- int rtn;
- if ((rtn = ::recv(sockDesc, (raw_type *) buffer, bufferLen, 0)) < 0) {
- throw SocketException("Received failed (recv())", true);
- }
-
- return rtn;
-}
-
-int CommunicatingSocket::recvNonBlocking(void *buffer, int bufferLen, int timeOut)
- throw(SocketException)
-{
- struct pollfd pfd[1];
- pfd[0].fd = sockDesc;
- pfd[0].events = POLLIN;
- int rtn = poll(pfd,1,timeOut);
- if(rtn > 0) {
- if ((rtn = ::recv(sockDesc, (raw_type *) buffer, bufferLen, 0)) < 0) {
- throw SocketException("non blocking receive failed", true);
- }
- if(!rtn) {
- throw SocketException("connection closed by peer", false);
- }
- }
- return rtn;
-}
-
-string CommunicatingSocket::getForeignAddress()
- throw(SocketException) {
- sockaddr_in addr;
- unsigned int addr_len = sizeof(addr);
-
- if (getpeername(sockDesc, (sockaddr *) &addr,(socklen_t *) &addr_len) < 0) {
- throw SocketException("Fetch of foreign address failed (getpeername())", true);
- }
- return inet_ntoa(addr.sin_addr);
-}
-
-unsigned short CommunicatingSocket::getForeignPort() throw(SocketException) {
- sockaddr_in addr;
- unsigned int addr_len = sizeof(addr);
-
- if (getpeername(sockDesc, (sockaddr *) &addr, (socklen_t *) &addr_len) < 0) {
- throw SocketException("Fetch of foreign port failed (getpeername())", true);
- }
- return ntohs(addr.sin_port);
-}
-
-// TCPSocket Code
-
-TCPSocket::TCPSocket()
- throw(SocketException) : CommunicatingSocket(SOCK_STREAM,
- IPPROTO_TCP) {
-}
-
-TCPSocket::TCPSocket(const string &foreignAddress, unsigned short foreignPort)
- throw(SocketException) : CommunicatingSocket(SOCK_STREAM, IPPROTO_TCP) {
- connect(foreignAddress, foreignPort);
-}
-
-TCPSocket::TCPSocket(int newConnSD) : CommunicatingSocket(newConnSD) {
-}
-
-// TCPServerSocket Code
-
-TCPServerSocket::TCPServerSocket(unsigned short localPort, int queueLen)
- throw(SocketException) : Socket(SOCK_STREAM, IPPROTO_TCP) {
- const int opt = 1;
- setSocketOpt(SO_REUSEADDR, &opt, sizeof(opt));
- setLocalPort(localPort);
- setListen(queueLen);
-}
-
-TCPServerSocket::TCPServerSocket(const string &localAddress,
- unsigned short localPort, int queueLen)
- throw(SocketException) : Socket(SOCK_STREAM, IPPROTO_TCP) {
- const int opt = 1;
- setSocketOpt(SO_REUSEADDR, &opt, sizeof(opt));
- setLocalAddressAndPort(localAddress, localPort);
- setListen(queueLen);
-}
-
-TCPSocket *TCPServerSocket::accept() throw(SocketException) {
- int newConnSD;
- if ((newConnSD = ::accept(sockDesc, NULL, 0)) < 0) {
- throw SocketException("Accept failed (accept())", true);
- }
-
- return new TCPSocket(newConnSD);
-}
-
-void TCPServerSocket::setListen(int queueLen) throw(SocketException) {
- if (listen(sockDesc, queueLen) < 0) {
- throw SocketException("Set listening socket failed (listen())", true);
- }
-}
-
-// UDPSocket Code
-
-UDPSocket::UDPSocket() throw(SocketException) : CommunicatingSocket(SOCK_DGRAM,
- IPPROTO_UDP) {
-
- const int opt = 1;
- setSocketOpt(SO_REUSEADDR, &opt, sizeof(opt));
- setBroadcast();
-}
-
-UDPSocket::UDPSocket(unsigned short localPort) throw(SocketException) :
- CommunicatingSocket(SOCK_DGRAM, IPPROTO_UDP) {
- const int opt = 1;
- setSocketOpt(SO_REUSEADDR, &opt, sizeof(opt));
- setLocalPort(localPort);
- setBroadcast();
-}
-
-UDPSocket::UDPSocket(const string &localAddress, unsigned short localPort)
- throw(SocketException) : CommunicatingSocket(SOCK_DGRAM, IPPROTO_UDP) {
- const int opt = 1;
- setSocketOpt(SO_REUSEADDR, &opt, sizeof(opt));
- setLocalAddressAndPort(localAddress, localPort);
- setBroadcast();
-}
-
-void UDPSocket::setBroadcast() {
- // If this fails, we'll hear about it when we try to send. This will allow
- // system that cannot broadcast to continue if they don't plan to broadcast
- int broadcastPermission = 1;
- setsockopt(sockDesc, SOL_SOCKET, SO_BROADCAST,
- (raw_type *) &broadcastPermission, sizeof(broadcastPermission));
-}
-
-void UDPSocket::disconnect() throw(SocketException) {
- sockaddr_in nullAddr;
- memset(&nullAddr, 0, sizeof(nullAddr));
- nullAddr.sin_family = AF_UNSPEC;
-
- // Try to disconnect
- if (::connect(sockDesc, (sockaddr *) &nullAddr, sizeof(nullAddr)) < 0) {
- #ifdef WIN32
- if (errno != WSAEAFNOSUPPORT) {
- #else
- if (errno != EAFNOSUPPORT) {
- #endif
- throw SocketException("Disconnect failed (connect())", true);
- }
- }
-}
-
-void UDPSocket::sendTo(const void *buffer, int bufferLen,
- const string &foreignAddress, unsigned short foreignPort)
- throw(SocketException) {
- sockaddr_in destAddr;
- fillAddr(foreignAddress, foreignPort, destAddr);
-
- // Write out the whole buffer as a single message.
- if (sendto(sockDesc, (raw_type *) buffer, bufferLen, 0,
- (sockaddr *) &destAddr, sizeof(destAddr)) != bufferLen) {
- throw SocketException("Send failed (sendto())", true);
- }
-}
-
-int UDPSocket::recvFrom(void *buffer, int bufferLen, string &sourceAddress,
- unsigned short &sourcePort) throw(SocketException) {
- sockaddr_in clntAddr;
- socklen_t addrLen = sizeof(clntAddr);
- int rtn;
- if ((rtn = recvfrom(sockDesc, (raw_type *) buffer, bufferLen, 0,
- (sockaddr *) &clntAddr, (socklen_t *) &addrLen)) < 0) {
- throw SocketException("Receive failed (recvfrom())", true);
- }
- sourceAddress = inet_ntoa(clntAddr.sin_addr);
- sourcePort = ntohs(clntAddr.sin_port);
-
- return rtn;
-}
-
-int UDPSocket::recvFromNonBlocking(void *buffer, int bufferLen, string &sourceAddress,
- unsigned short &sourcePort, int timeOut) throw(SocketException) {
- sockaddr_in clntAddr;
- socklen_t addrLen = sizeof(clntAddr);
- struct pollfd pfd[1];
- pfd[0].fd = sockDesc;
- pfd[0].events = POLLIN;
- int rtn = poll(pfd,1,timeOut);
- if(rtn > 0) {
- if ((rtn = recvfrom(sockDesc, (raw_type *) buffer, bufferLen, 0,
- (sockaddr *) &clntAddr, (socklen_t *) &addrLen)) < 0) {
- throw SocketException("Receive failed (recvfrom())", true);
- }
- if(!rtn) {
- throw SocketException("connection closed by peer", false);
- }
- }
- sourceAddress = inet_ntoa(clntAddr.sin_addr);
- sourcePort = ntohs(clntAddr.sin_port);
-
- return rtn;
-}
-
-void UDPSocket::setMulticastTTL(unsigned char multicastTTL) throw(SocketException) {
- if (setsockopt(sockDesc, IPPROTO_IP, IP_MULTICAST_TTL,
- (raw_type *) &multicastTTL, sizeof(multicastTTL)) < 0) {
- throw SocketException("Multicast TTL set failed (setsockopt())", true);
- }
-}
-
-void UDPSocket::joinGroup(const string &multicastGroup) throw(SocketException) {
- struct ip_mreq multicastRequest;
-
- multicastRequest.imr_multiaddr.s_addr = inet_addr(multicastGroup.c_str());
- multicastRequest.imr_interface.s_addr = htonl(INADDR_ANY);
- if (setsockopt(sockDesc, IPPROTO_IP, IP_ADD_MEMBERSHIP,
- (raw_type *) &multicastRequest,
- sizeof(multicastRequest)) < 0) {
- throw SocketException("Multicast group join failed (setsockopt())", true);
- }
-}
-
-void UDPSocket::leaveGroup(const string &multicastGroup) throw(SocketException) {
- struct ip_mreq multicastRequest;
-
- multicastRequest.imr_multiaddr.s_addr = inet_addr(multicastGroup.c_str());
- multicastRequest.imr_interface.s_addr = htonl(INADDR_ANY);
- if (setsockopt(sockDesc, IPPROTO_IP, IP_DROP_MEMBERSHIP,
- (raw_type *) &multicastRequest,
- sizeof(multicastRequest)) < 0) {
- throw SocketException("Multicast group leave failed (setsockopt())", true);
- }
-}