1 /****************************************************************************

     2 **

     3 ** Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies).

     4 ** All rights reserved.

     5 ** Contact: Nokia Corporation (qt-info@nokia.com)

     6 **

     7 ** This file is part of the QtNetwork module of the Qt Toolkit.

     8 **

     9 ** $QT_BEGIN_LICENSE:LGPL$

    10 ** No Commercial Usage

    11 ** This file contains pre-release code and may not be distributed.

    12 ** You may use this file in accordance with the terms and conditions

    13 ** contained in the Technology Preview License Agreement accompanying

    14 ** this package.

    15 **

    16 ** GNU Lesser General Public License Usage

    17 ** Alternatively, this file may be used under the terms of the GNU Lesser

    18 ** General Public License version 2.1 as published by the Free Software

    19 ** Foundation and appearing in the file LICENSE.LGPL included in the

    20 ** packaging of this file.  Please review the following information to

    21 ** ensure the GNU Lesser General Public License version 2.1 requirements

    22 ** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.

    23 **

    24 ** In addition, as a special exception, Nokia gives you certain additional

    25 ** rights.  These rights are described in the Nokia Qt LGPL Exception

    26 ** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.

    27 **

    28 ** If you have questions regarding the use of this file, please contact

    29 ** Nokia at qt-info@nokia.com.

    30 **

    31 **

    32 **

    33 **

    34 **

    35 **

    36 **

    37 **

    38 ** $QT_END_LICENSE$

    39 **

    40 ****************************************************************************/

    41 

    42 #ifndef QHTTPSOCKETENGINE_P_H

    43 #define QHTTPSOCKETENGINE_P_H

    44 

    45 //

    46 //  W A R N I N G

    47 //  -------------

    48 //

    49 // This file is not part of the Qt API.  It exists purely as an

    50 // implementation detail.  This header file may change from version to

    51 // version without notice, or even be removed.

    52 //

    53 // We mean it.

    54 //

    55 

    56 #include "private/qabstractsocketengine_p.h"

    57 #include "qabstractsocket.h"

    58 #include "qnetworkproxy.h"

    59 #include "private/qauthenticator_p.h"

    60 

    61 QT_BEGIN_NAMESPACE

    62 

    63 #if !defined(QT_NO_NETWORKPROXY) && !defined(QT_NO_HTTP)

    64 

    65 class QTcpSocket;

    66 class QHttpSocketEnginePrivate;

    67 

    68 class Q_AUTOTEST_EXPORT QHttpSocketEngine : public QAbstractSocketEngine

    69 {

    70     Q_OBJECT

    71 public:

    72     enum HttpState {

    73         None,

    74         ConnectSent,

    75         Connected,

    76         SendAuthentication,

    77         ReadResponseContent

    78     };

    79     QHttpSocketEngine(QObject *parent = 0);

    80     ~QHttpSocketEngine();

    81 

    82     bool initialize(QAbstractSocket::SocketType type, QAbstractSocket::NetworkLayerProtocol protocol = QAbstractSocket::IPv4Protocol);

    83     bool initialize(int socketDescriptor, QAbstractSocket::SocketState socketState = QAbstractSocket::ConnectedState);

    84 

    85     void setProxy(const QNetworkProxy &networkProxy);

    86 

    87     int socketDescriptor() const;

    88 

    89     bool isValid() const;

    90 

    91     bool connectInternal();

    92     bool connectToHost(const QHostAddress &address, quint16 port);

    93     bool connectToHostByName(const QString &name, quint16 port);

    94     bool bind(const QHostAddress &address, quint16 port);

    95     bool listen();

    96     int accept();

    97     void close();

    98 

    99     qint64 bytesAvailable() const;

   100 

   101     qint64 read(char *data, qint64 maxlen);

   102     qint64 write(const char *data, qint64 len);

   103 

   104 #ifndef QT_NO_UDPSOCKET

   105     qint64 readDatagram(char *data, qint64 maxlen, QHostAddress *addr = 0,

   106         quint16 *port = 0);

   107     qint64 writeDatagram(const char *data, qint64 len, const QHostAddress &addr,

   108         quint16 port);

   109     bool hasPendingDatagrams() const;

   110     qint64 pendingDatagramSize() const;

   111 #endif // QT_NO_UDPSOCKET

   112 

   113     int option(SocketOption option) const;

   114     bool setOption(SocketOption option, int value);

   115 

   116     bool waitForRead(int msecs = 30000, bool *timedOut = 0);

   117     bool waitForWrite(int msecs = 30000, bool *timedOut = 0);

   118     bool waitForReadOrWrite(bool *readyToRead, bool *readyToWrite,

   119                             bool checkRead, bool checkWrite,

   120                             int msecs = 30000, bool *timedOut = 0);

   121 

   122     bool isReadNotificationEnabled() const;

   123     void setReadNotificationEnabled(bool enable);

   124     bool isWriteNotificationEnabled() const;

   125     void setWriteNotificationEnabled(bool enable);

   126     bool isExceptionNotificationEnabled() const;

   127     void setExceptionNotificationEnabled(bool enable);

   128 

   129 public slots:

   130     void slotSocketConnected();

   131     void slotSocketDisconnected();

   132     void slotSocketReadNotification();

   133     void slotSocketBytesWritten();

   134     void slotSocketError(QAbstractSocket::SocketError error);

   135     void slotSocketStateChanged(QAbstractSocket::SocketState state);

   136 

   137 private slots:

   138     void emitPendingReadNotification();

   139     void emitPendingWriteNotification();

   140     void emitPendingConnectionNotification();

   141 

   142 private:

   143     void emitReadNotification();

   144     void emitWriteNotification();

   145     void emitConnectionNotification();

   146 

   147     Q_DECLARE_PRIVATE(QHttpSocketEngine)

   148     Q_DISABLE_COPY(QHttpSocketEngine)

   149 

   150 };

   151 

   152 

   153 class QHttpSocketEnginePrivate : public QAbstractSocketEnginePrivate

   154 {

   155     Q_DECLARE_PUBLIC(QHttpSocketEngine)

   156 public:

   157     QHttpSocketEnginePrivate();

   158     ~QHttpSocketEnginePrivate();

   159 

   160     QNetworkProxy proxy;

   161     QString peerName;

   162     QTcpSocket *socket;

   163     QByteArray readBuffer;

   164     QHttpSocketEngine::HttpState state;

   165     QAuthenticator authenticator;

   166     bool readNotificationEnabled;

   167     bool writeNotificationEnabled;

   168     bool exceptNotificationEnabled;

   169     bool readNotificationActivated;

   170     bool writeNotificationActivated;

   171     bool readNotificationPending;

   172     bool writeNotificationPending;

   173     bool connectionNotificationPending;

   174     uint pendingResponseData;

   175 };

   176 

   177 class Q_AUTOTEST_EXPORT QHttpSocketEngineHandler : public QSocketEngineHandler

   178 {

   179 public:

   180     virtual QAbstractSocketEngine *createSocketEngine(QAbstractSocket::SocketType socketType,

   181                                                       const QNetworkProxy &, QObject *parent);

   182     virtual QAbstractSocketEngine *createSocketEngine(int socketDescripter, QObject *parent);

   183 };

   184 #endif

   185 

   186 QT_END_NAMESPACE

   187 

   188 #endif // QHTTPSOCKETENGINE_H