/**************************************************************************** ** ** Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies). ** Contact: Nokia Corporation (qt-info@nokia.com) ** ** This file is part of the QtNetwork 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 Technology Preview License Agreement accompanying ** this package. ** ** 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.1, included in the file LGPL_EXCEPTION.txt in this ** package. ** ** If you have questions regarding the use of this file, please contact ** Nokia at qt-info@nokia.com. ** ** ** ** ** ** ** ** ** $QT_END_LICENSE$ ** ****************************************************************************/ #ifndef QNATIVESOCKETENGINE_P_H #define QNATIVESOCKETENGINE_P_H // // W A R N I N G // ------------- // // This file is not part of the Qt API. It exists for the convenience // of the QLibrary class. This header file may change from // version to version without notice, or even be removed. // // We mean it. // #include "QtNetwork/qhostaddress.h" #include "private/qabstractsocketengine_p.h" #ifndef Q_OS_WIN # include "qplatformdefs.h" #else # include #endif QT_BEGIN_NAMESPACE #ifndef Q_OS_WIN // Almost always the same. If not, specify in qplatformdefs.h. #if !defined(QT_SOCKOPTLEN_T) # define QT_SOCKOPTLEN_T QT_SOCKLEN_T #endif // Tru64 redefines accept -> _accept with _XOPEN_SOURCE_EXTENDED static inline int qt_socket_accept(int s, struct sockaddr *addr, QT_SOCKLEN_T *addrlen) { return ::accept(s, addr, static_cast(addrlen)); } #if defined(accept) # undef accept #endif // UnixWare 7 redefines listen -> _listen static inline int qt_socket_listen(int s, int backlog) { return ::listen(s, backlog); } #if defined(listen) # undef listen #endif // UnixWare 7 redefines socket -> _socket static inline int qt_socket_socket(int domain, int type, int protocol) { return ::socket(domain, type, protocol); } #if defined(socket) # undef socket #endif #endif // Use our own defines and structs which we know are correct # define QT_SS_MAXSIZE 128 # define QT_SS_ALIGNSIZE (sizeof(qint64)) # define QT_SS_PAD1SIZE (QT_SS_ALIGNSIZE - sizeof (short)) # define QT_SS_PAD2SIZE (QT_SS_MAXSIZE - (sizeof (short) + QT_SS_PAD1SIZE + QT_SS_ALIGNSIZE)) struct qt_sockaddr_storage { short ss_family; char __ss_pad1[QT_SS_PAD1SIZE]; qint64 __ss_align; char __ss_pad2[QT_SS_PAD2SIZE]; }; // sockaddr_in6 size changed between old and new SDK // Only the new version is the correct one, so always // use this structure. struct qt_in6_addr { quint8 qt_s6_addr[16]; }; struct qt_sockaddr_in6 { short sin6_family; /* AF_INET6 */ quint16 sin6_port; /* Transport level port number */ quint32 sin6_flowinfo; /* IPv6 flow information */ struct qt_in6_addr sin6_addr; /* IPv6 address */ quint32 sin6_scope_id; /* set of interfaces for a scope */ }; union qt_sockaddr { sockaddr a; sockaddr_in a4; qt_sockaddr_in6 a6; qt_sockaddr_storage storage; }; class QNativeSocketEnginePrivate; class Q_AUTOTEST_EXPORT QNativeSocketEngine : public QAbstractSocketEngine { Q_OBJECT public: QNativeSocketEngine(QObject *parent = 0); ~QNativeSocketEngine(); bool initialize(QAbstractSocket::SocketType type, QAbstractSocket::NetworkLayerProtocol protocol = QAbstractSocket::IPv4Protocol); bool initialize(int socketDescriptor, QAbstractSocket::SocketState socketState = QAbstractSocket::ConnectedState); int socketDescriptor() const; bool isValid() const; bool connectToHost(const QHostAddress &address, quint16 port); bool connectToHostByName(const QString &name, quint16 port); bool bind(const QHostAddress &address, quint16 port); bool listen(); int accept(); void close(); qint64 bytesAvailable() const; qint64 read(char *data, qint64 maxlen); qint64 write(const char *data, qint64 len); qint64 readDatagram(char *data, qint64 maxlen, QHostAddress *addr = 0, quint16 *port = 0); qint64 writeDatagram(const char *data, qint64 len, const QHostAddress &addr, quint16 port); bool hasPendingDatagrams() const; qint64 pendingDatagramSize() const; qint64 receiveBufferSize() const; void setReceiveBufferSize(qint64 bufferSize); qint64 sendBufferSize() const; void setSendBufferSize(qint64 bufferSize); int option(SocketOption option) const; bool setOption(SocketOption option, int value); bool waitForRead(int msecs = 30000, bool *timedOut = 0); bool waitForWrite(int msecs = 30000, bool *timedOut = 0); bool waitForReadOrWrite(bool *readyToRead, bool *readyToWrite, bool checkRead, bool checkWrite, int msecs = 30000, bool *timedOut = 0); bool isReadNotificationEnabled() const; void setReadNotificationEnabled(bool enable); bool isWriteNotificationEnabled() const; void setWriteNotificationEnabled(bool enable); bool isExceptionNotificationEnabled() const; void setExceptionNotificationEnabled(bool enable); public Q_SLOTS: // non-virtual override; void connectionNotification(); private: Q_DECLARE_PRIVATE(QNativeSocketEngine) Q_DISABLE_COPY(QNativeSocketEngine) }; #ifdef Q_OS_WIN class QWindowsSockInit { public: QWindowsSockInit(); ~QWindowsSockInit(); int version; }; #endif class QSocketNotifier; class QNativeSocketEnginePrivate : public QAbstractSocketEnginePrivate { Q_DECLARE_PUBLIC(QNativeSocketEngine) public: QNativeSocketEnginePrivate(); ~QNativeSocketEnginePrivate(); int socketDescriptor; QSocketNotifier *readNotifier, *writeNotifier, *exceptNotifier; #ifdef Q_OS_WIN QWindowsSockInit winSock; #endif enum ErrorString { NonBlockingInitFailedErrorString, BroadcastingInitFailedErrorString, NoIpV6ErrorString, RemoteHostClosedErrorString, TimeOutErrorString, ResourceErrorString, OperationUnsupportedErrorString, ProtocolUnsupportedErrorString, InvalidSocketErrorString, HostUnreachableErrorString, NetworkUnreachableErrorString, AccessErrorString, ConnectionTimeOutErrorString, ConnectionRefusedErrorString, AddressInuseErrorString, AddressNotAvailableErrorString, AddressProtectedErrorString, DatagramTooLargeErrorString, SendDatagramErrorString, ReceiveDatagramErrorString, WriteErrorString, ReadErrorString, PortInuseErrorString, NotSocketErrorString, InvalidProxyTypeString, UnknownSocketErrorString = -1 }; void setError(QAbstractSocket::SocketError error, ErrorString errorString) const; // native functions int option(QNativeSocketEngine::SocketOption option) const; bool setOption(QNativeSocketEngine::SocketOption option, int value); bool createNewSocket(QAbstractSocket::SocketType type, QAbstractSocket::NetworkLayerProtocol protocol); bool nativeConnect(const QHostAddress &address, quint16 port); bool nativeBind(const QHostAddress &address, quint16 port); bool nativeListen(int backlog); int nativeAccept(); qint64 nativeBytesAvailable() const; bool nativeHasPendingDatagrams() const; qint64 nativePendingDatagramSize() const; qint64 nativeReceiveDatagram(char *data, qint64 maxLength, QHostAddress *address, quint16 *port); qint64 nativeSendDatagram(const char *data, qint64 length, const QHostAddress &host, quint16 port); qint64 nativeRead(char *data, qint64 maxLength); qint64 nativeWrite(const char *data, qint64 length); int nativeSelect(int timeout, bool selectForRead) const; int nativeSelect(int timeout, bool checkRead, bool checkWrite, bool *selectForRead, bool *selectForWrite) const; void nativeClose(); bool checkProxy(const QHostAddress &address); bool fetchConnectionParameters(); }; QT_END_NAMESPACE #endif // QNATIVESOCKETENGINE_P_H