ibrcommon/ibrcommon/net/tcpserver.cpp

Go to the documentation of this file.

/*
 * tcpserver.cpp
 *
 *  Created on: 30.07.2009
 *      Author: morgenro
 */

#include "ibrcommon/config.h"
#include "ibrcommon/net/tcpserver.h"
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/poll.h>

#ifndef HAVE_BZERO
#define bzero(s,n) (memset((s), '\0', (n)), (void) 0)
#endif

namespace ibrcommon
{
        tcpserver::tcpserver(const ibrcommon::File &s)
         : _socket(0), _closed(false)
        {
                struct sockaddr_un address;
                size_t address_length;

                _socket = socket(PF_UNIX, SOCK_STREAM, 0);

                // check for errors
                if (_socket < 0)
                switch (_socket)
                {
                case EACCES:
                        throw SocketException("Permission  to create a socket of the specified type and/or protocol is denied.");

                case EAFNOSUPPORT:
                        throw SocketException("The implementation does not support the specified address family.");

                case EINVAL:
                        throw SocketException("Unknown protocol, or protocol family not available.");

                case EMFILE:
                        throw SocketException("Process file table overflow.");

                case ENFILE:
                        throw SocketException("The system limit on the total number of open files has been reached.");

                case ENOBUFS:
                case ENOMEM:
                        throw SocketException("Insufficient memory is available. The socket cannot be created until sufficient resources are freed.");

                case EPROTONOSUPPORT:
                        throw SocketException("The protocol type or the specified protocol is not supported within this domain.");

                default:
                        throw SocketException("cannot create listen socket");
                }

                // remove old sockets
                unlink(s.getPath().c_str());

                address.sun_family = AF_UNIX;
                strcpy(address.sun_path, s.getPath().c_str());
                address_length = sizeof(address.sun_family) + strlen(address.sun_path);

                // bind to the socket
                int bind_ret = ::bind(_socket, (struct sockaddr *) &address, address_length);

                if ( bind_ret < 0) switch ( bind_ret )
                {
                case EBADF:
                        throw SocketException("sockfd ist kein gueltiger Deskriptor.");

                // Die  folgenden  Fehlermeldungen  sind  spezifisch fr UNIX-Domnensockets (AF_UNIX)

                case EINVAL:
                        throw SocketException("Die addr_len war  falsch  oder  der  Socket  gehrte  nicht  zur AF_UNIX Familie.");

                case EROFS:
                        throw SocketException("Die Socket \"Inode\" sollte auf einem schreibgeschtzten Dateisystem residieren.");

                case EFAULT:
                        throw SocketException("my_addr  weist  auf  eine  Adresse  auerhalb  des  erreichbaren Adressraumes zu.");

                case ENAMETOOLONG:
                        throw SocketException("my_addr ist zu lang.");

                case ENOENT:
                        throw SocketException("Die Datei existiert nicht.");

                case ENOMEM:
                        throw SocketException("Nicht genug Kernelspeicher vorhanden.");

                case ENOTDIR:
                        throw SocketException("Eine Komponente des Pfad-Prfixes ist kein Verzeichnis.");

                case EACCES:
                        throw SocketException("Keine  berechtigung  um  eine  Komponente  des Pfad-prefixes zu durchsuchen.");

                case ELOOP:
                        throw SocketException("my_addr enthlt eine Kreis-Referenz (zum  Beispiel  durch  einen symbolischen Link)");

                default:
                        throw SocketException("cannot bind socket");
                }

                if(listen(_socket, 5) != 0)
                {
                        throw SocketException("cannot listen to socket");
                }
        }

        tcpserver::tcpserver(NetInterface net, int port, bool reuseaddr)
         : _socket(0), _closed(false)
        {
                struct sockaddr_in sock_address;
                bzero((char *) &sock_address, sizeof(sock_address));

                // define the protocol family
                sock_address.sin_family = AF_INET;

                // set the local interface address
                net.getAddress(&sock_address.sin_addr);

                // set the local port
                sock_address.sin_port = htons(port);

                // Create socket for listening for client connection requests.
                _socket = ::socket(sock_address.sin_family, SOCK_STREAM, 0);

                // check for errors
                if (_socket < 0)
                switch (_socket)
                {
                case EACCES:
                        throw SocketException("Permission  to create a socket of the specified type and/or protocol is denied.");

                case EAFNOSUPPORT:
                        throw SocketException("The implementation does not support the specified address family.");

                case EINVAL:
                        throw SocketException("Unknown protocol, or protocol family not available.");

                case EMFILE:
                        throw SocketException("Process file table overflow.");

                case ENFILE:
                        throw SocketException("The system limit on the total number of open files has been reached.");

                case ENOBUFS:
                case ENOMEM:
                        throw SocketException("Insufficient memory is available. The socket cannot be created until sufficient resources are freed.");

                case EPROTONOSUPPORT:
                        throw SocketException("The protocol type or the specified protocol is not supported within this domain.");

                default:
                        throw SocketException("cannot create listen socket");
                }

                // enable reuse address if requested
                if (reuseaddr)
                {
                        int on = 1;
                        if (::setsockopt(_socket, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0)
                        {
                                throw SocketException("setsockopt(SO_REUSEADDR) failed");
                        }
                }

                // bind to the socket
                int bind_ret = ::bind(_socket, (struct sockaddr *) &sock_address, sizeof(sock_address));
                if (bind_ret < 0)
                switch ( bind_ret )
                {
                case EBADF:
                        throw SocketException("sockfd ist kein gueltiger Deskriptor.");

                // Die  folgenden  Fehlermeldungen  sind  spezifisch fr UNIX-Domnensockets (AF_UNIX)

                case EINVAL:
                        throw SocketException("Die addr_len war  falsch  oder  der  Socket  gehrte  nicht  zur AF_UNIX Familie.");

                case EROFS:
                        throw SocketException("Die Socket \"Inode\" sollte auf einem schreibgeschtzten Dateisystem residieren.");

                case EFAULT:
                        throw SocketException("my_addr  weist  auf  eine  Adresse  auerhalb  des  erreichbaren Adressraumes zu.");

                case ENAMETOOLONG:
                        throw SocketException("my_addr ist zu lang.");

                case ENOENT:
                        throw SocketException("Die Datei existiert nicht.");

                case ENOMEM:
                        throw SocketException("Nicht genug Kernelspeicher vorhanden.");

                case ENOTDIR:
                        throw SocketException("Eine Komponente des Pfad-Prfixes ist kein Verzeichnis.");

                case EACCES:
                        throw SocketException("Keine  berechtigung  um  eine  Komponente  des Pfad-prefixes zu durchsuchen.");

                case ELOOP:
                        throw SocketException("my_addr enthlt eine Kreis-Referenz (zum  Beispiel  durch  einen symbolischen Link)");

                default:
                        throw SocketException("cannot bind socket");
                }

                // listen on the socket, max. 5 concurrent awaiting connections
                ::listen (_socket, 5);

                // set linger option to the socket
                struct linger linger;

                linger.l_onoff = 1;
                linger.l_linger = 1;
                ::setsockopt(_socket, SOL_SOCKET, SO_LINGER, &linger, sizeof(linger));
        }

        tcpserver::~tcpserver()
        {
                close();
        }

        void tcpserver::close()
        {
                _closed = true;
		::close(_socket);
        }

        void tcpserver::shutdown()
        {
		::shutdown(_socket, SHUT_RDWR);
        }

        tcpstream* tcpserver::accept()
        {
                struct sockaddr_in cliaddr;
                socklen_t len;
                len = sizeof(cliaddr);

                int ret = ::accept(_socket, (struct sockaddr *) &cliaddr, &len );

                if (ret <= 0)
                {
                        throw SocketException("socket closed");
                }

                return new tcpstream(ret);
        }
}