diff options
author | Alexis Menard <alexis.menard@nokia.com> | 2009-04-17 14:06:06 (GMT) |
---|---|---|
committer | Alexis Menard <alexis.menard@nokia.com> | 2009-04-17 14:06:06 (GMT) |
commit | f15b8a83e2e51955776a3f07cb85ebfc342dd8ef (patch) | |
tree | c5dc684986051654898db11ce73e03b9fec8db99 /src/qt3support/network/q3serversocket.cpp | |
download | Qt-f15b8a83e2e51955776a3f07cb85ebfc342dd8ef.zip Qt-f15b8a83e2e51955776a3f07cb85ebfc342dd8ef.tar.gz Qt-f15b8a83e2e51955776a3f07cb85ebfc342dd8ef.tar.bz2 |
Initial import of statemachine branch from the old kinetic repository
Diffstat (limited to 'src/qt3support/network/q3serversocket.cpp')
-rw-r--r-- | src/qt3support/network/q3serversocket.cpp | 298 |
1 files changed, 298 insertions, 0 deletions
diff --git a/src/qt3support/network/q3serversocket.cpp b/src/qt3support/network/q3serversocket.cpp new file mode 100644 index 0000000..f61b652 --- /dev/null +++ b/src/qt3support/network/q3serversocket.cpp @@ -0,0 +1,298 @@ +/**************************************************************************** +** +** Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies). +** Contact: Qt Software Information (qt-info@nokia.com) +** +** This file is part of the Qt3Support module of the Qt Toolkit. +** +** $QT_BEGIN_LICENSE:LGPL$ +** No Commercial Usage +** This file contains pre-release code and may not be distributed. +** You may use this file in accordance with the terms and conditions +** contained in the either Technology Preview License Agreement or the +** Beta Release License Agreement. +** +** GNU Lesser General Public License Usage +** Alternatively, this file may be used under the terms of the GNU Lesser +** General Public License version 2.1 as published by the Free Software +** Foundation and appearing in the file LICENSE.LGPL included in the +** packaging of this file. Please review the following information to +** ensure the GNU Lesser General Public License version 2.1 requirements +** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. +** +** In addition, as a special exception, Nokia gives you certain +** additional rights. These rights are described in the Nokia Qt LGPL +** Exception version 1.0, included in the file LGPL_EXCEPTION.txt in this +** package. +** +** GNU General Public License Usage +** Alternatively, this file may be used under the terms of the GNU +** General Public License version 3.0 as published by the Free Software +** Foundation and appearing in the file LICENSE.GPL included in the +** packaging of this file. Please review the following information to +** ensure the GNU General Public License version 3.0 requirements will be +** met: http://www.gnu.org/copyleft/gpl.html. +** +** If you are unsure which license is appropriate for your use, please +** contact the sales department at qt-sales@nokia.com. +** $QT_END_LICENSE$ +** +****************************************************************************/ + +#include "q3serversocket.h" + +#ifndef QT_NO_NETWORK + +#include "qsocketnotifier.h" + +QT_BEGIN_NAMESPACE + +class Q3ServerSocketPrivate { +public: + Q3ServerSocketPrivate(): s(0), n(0) {} + ~Q3ServerSocketPrivate() { delete n; delete s; } + Q3SocketDevice *s; + QSocketNotifier *n; +}; + + +/*! + \class Q3ServerSocket + \brief The Q3ServerSocket class provides a TCP-based server. + + \compat + + This class is a convenience class for accepting incoming TCP + connections. You can specify the port or have Q3ServerSocket pick + one, and listen on just one address or on all the machine's + addresses. + + Using the API is very simple: subclass Q3ServerSocket, call the + constructor of your choice, and implement newConnection() to + handle new incoming connections. There is nothing more to do. + + (Note that due to lack of support in the underlying APIs, + Q3ServerSocket cannot accept or reject connections conditionally.) + + \sa Q3Socket, Q3SocketDevice, QHostAddress, QSocketNotifier +*/ + + +/*! + Creates a server socket object, that will serve the given \a port + on all the addresses of this host. If \a port is 0, Q3ServerSocket + will pick a suitable port in a system-dependent manner. Use \a + backlog to specify how many pending connections the server can + have. + + The \a parent and \a name arguments are passed on to the QObject + constructor. + + \warning On Tru64 Unix systems a value of 0 for \a backlog means + that you don't accept any connections at all; you should specify a + value larger than 0. +*/ + +Q3ServerSocket::Q3ServerSocket( Q_UINT16 port, int backlog, + QObject *parent, const char *name ) + : QObject( parent, name ) +{ + d = new Q3ServerSocketPrivate; + init( QHostAddress(), port, backlog ); +} + + +/*! + Creates a server socket object, that will serve the given \a port + only on the given \a address. Use \a backlog to specify how many + pending connections the server can have. + + The \a parent and \a name arguments are passed on to the QObject + constructor. + + \warning On Tru64 Unix systems a value of 0 for \a backlog means + that you don't accept any connections at all; you should specify a + value larger than 0. +*/ + +Q3ServerSocket::Q3ServerSocket( const QHostAddress & address, Q_UINT16 port, + int backlog, + QObject *parent, const char *name ) + : QObject( parent, name ) +{ + d = new Q3ServerSocketPrivate; + init( address, port, backlog ); +} + + +/*! + Construct an empty server socket. + + This constructor, in combination with setSocket(), allows us to + use the Q3ServerSocket class as a wrapper for other socket types + (e.g. Unix Domain Sockets under Unix). + + The \a parent and \a name arguments are passed on to the QObject + constructor. + + \sa setSocket() +*/ + +Q3ServerSocket::Q3ServerSocket( QObject *parent, const char *name ) + : QObject( parent, name ) +{ + d = new Q3ServerSocketPrivate; +} + + +/*! + Returns true if the construction succeeded; otherwise returns false. +*/ +bool Q3ServerSocket::ok() const +{ + return !!d->s; +} + +/* + The common bit of the constructors. + */ +void Q3ServerSocket::init( const QHostAddress & address, Q_UINT16 port, int backlog ) +{ + d->s = new Q3SocketDevice( Q3SocketDevice::Stream, address.isIPv4Address() + ? Q3SocketDevice::IPv4 : Q3SocketDevice::IPv6, 0 ); +#if !defined(Q_OS_WIN32) + // Under Unix, we want to be able to use the port, even if a socket on the + // same address-port is in TIME_WAIT. Under Windows this is possible anyway + // -- furthermore, the meaning of reusable is different: it means that you + // can use the same address-port for multiple listening sockets. + d->s->setAddressReusable( true ); +#endif + if ( d->s->bind( address, port ) + && d->s->listen( backlog ) ) + { + d->n = new QSocketNotifier( d->s->socket(), QSocketNotifier::Read, + this, "accepting new connections" ); + connect( d->n, SIGNAL(activated(int)), + this, SLOT(incomingConnection(int)) ); + } else { + qWarning( "Q3ServerSocket: failed to bind or listen to the socket" ); + delete d->s; + d->s = 0; + } +} + + +/*! + Destroys the socket. + + This causes any backlogged connections (connections that have + reached the host, but not yet been completely set up by calling + Q3SocketDevice::accept()) to be severed. + + Existing connections continue to exist; this only affects the + acceptance of new connections. +*/ +Q3ServerSocket::~Q3ServerSocket() +{ + delete d; +} + + +/*! + \fn void Q3ServerSocket::newConnection( int socket ) + + This pure virtual function is responsible for setting up a new + incoming connection. \a socket is the fd (file descriptor) for the + newly accepted connection. +*/ + + +void Q3ServerSocket::incomingConnection( int ) +{ + int fd = d->s->accept(); + if ( fd >= 0 ) + newConnection( fd ); +} + + +/*! + Returns the port number on which this server socket listens. This + is always non-zero; if you specify 0 in the constructor, + Q3ServerSocket will pick a non-zero port itself. ok() must be true + before calling this function. + + \sa address() Q3SocketDevice::port() +*/ +Q_UINT16 Q3ServerSocket::port() const +{ + if ( !d || !d->s ) + return 0; + return d->s->port(); +} + + +/*! + Returns the operating system socket. +*/ +int Q3ServerSocket::socket() const +{ + if ( !d || !d->s ) + return -1; + + return d->s->socket(); +} + +/*! + Returns the address on which this object listens, or 0.0.0.0 if + this object listens on more than one address. ok() must be true + before calling this function. + + \sa port() Q3SocketDevice::address() +*/ +QHostAddress Q3ServerSocket::address() const +{ + if ( !d || !d->s ) + return QHostAddress(); + + return d->s->address(); +} + + +/*! + Returns a pointer to the internal socket device. The returned + pointer is 0 if there is no connection or pending connection. + + There is normally no need to manipulate the socket device directly + since this class does all the necessary setup for most client or + server socket applications. +*/ +Q3SocketDevice *Q3ServerSocket::socketDevice() +{ + if ( !d ) + return 0; + + return d->s; +} + + +/*! + Sets the socket to use \a socket. bind() and listen() should + already have been called for \a socket. + + This allows us to use the Q3ServerSocket class as a wrapper for + other socket types (e.g. Unix Domain Sockets). +*/ +void Q3ServerSocket::setSocket( int socket ) +{ + delete d; + d = new Q3ServerSocketPrivate; + d->s = new Q3SocketDevice( socket, Q3SocketDevice::Stream ); + d->n = new QSocketNotifier( d->s->socket(), QSocketNotifier::Read, + this, "accepting new connections" ); + connect( d->n, SIGNAL(activated(int)), + this, SLOT(incomingConnection(int)) ); +} + +QT_END_NAMESPACE + +#endif //QT_NO_NETWORK |