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 <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/poll.h>
#include <string.h>

namespace ibrcommon
{
        tcpserver::tcpserver(NetInterface net, int port)
         : _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)
                {
                        throw SocketException("TCPConvergenceLayer: cannot create listen socket");
                }

                // bind to the socket
                if ( bind(_socket, (struct sockaddr *) &sock_address, sizeof(sock_address)) < 0 )
                {

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

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

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

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

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

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

                if (ret > 0)
                {
                        return new tcpstream(ret);
                }

                throw SocketException("socket closed");
        }
}

---