qnativesocketengine_win.cpp File Reference

#include <winsock2.h>
#include <ws2tcpip.h>
#include "qnativesocketengine_p.h"
#include <qabstracteventdispatcher.h>
#include <qsocketnotifier.h>
#include <qdebug.h>
#include <qdatetime.h>
#include <qnetworkinterface.h>

Go to the source code of this file.

Macros
#define	_WSAIOW(x, y)   (IOC_IN|(x)|(y))
#define	AF_INET6   23 /* Internetwork Version 6 */
#define	IOC_VENDOR   0x18000000
#define	QT_SOCKLEN_T   int
#define	QT_SOCKOPTLEN_T   int
#define	SIO_UDP_CONNRESET   _WSAIOW(IOC_VENDOR,12)
#define	SO_EXCLUSIVEADDRUSE   ((int)(~SO_REUSEADDR)) /* disallow local address reuse */
#define	WS_ERROR_DEBUG(x)   Q_UNUSED(x)

Functions
static bool	multicastMembershipHelper (QNativeSocketEnginePrivate *d, int how6, int how4, const QHostAddress &groupAddress, const QNetworkInterface &iface)
static int	qt_socket_getMaxMsgSize (int socketDescriptor)
static void	qt_socket_getPortAndAddress (SOCKET socketDescriptor, const qt_sockaddr *sa, quint16 *port, QHostAddress *address)
static QAbstractSocket::SocketType	qt_socket_getType (int socketDescriptor)
static void	qt_socket_setPortAndAddress (SOCKET socketDescriptor, sockaddr_in *sockAddrIPv4, qt_sockaddr_in6 *sockAddrIPv6, quint16 port, const QHostAddress &address, sockaddr **sockAddrPtr, QT_SOCKLEN_T *sockAddrSize)
	Sets the port and address to a sockaddr. More...

Macro Definition Documentation

_WSAIOW

#define _WSAIOW	(		x,
			y
	)		(IOC_IN|(x)|(y))

Definition at line 298 of file qnativesocketengine_win.cpp.

AF_INET6

#define AF_INET6   23 /* Internetwork Version 6 */

Definition at line 155 of file qnativesocketengine_win.cpp.

Referenced by qt_socket_getPortAndAddress(), and qt_socket_setPortAndAddress().

IOC_VENDOR

#define IOC_VENDOR   0x18000000

Definition at line 295 of file qnativesocketengine_win.cpp.

QT_SOCKLEN_T

#define QT_SOCKLEN_T   int

Definition at line 163 of file qnativesocketengine_win.cpp.

Referenced by multicastMembershipHelper(), qt_socket_getMaxMsgSize(), and qt_socket_getType().

QT_SOCKOPTLEN_T

#define QT_SOCKOPTLEN_T   int

Definition at line 164 of file qnativesocketengine_win.cpp.

Referenced by multicastMembershipHelper().

SIO_UDP_CONNRESET

#define SIO_UDP_CONNRESET   _WSAIOW(IOC_VENDOR,12)

Definition at line 300 of file qnativesocketengine_win.cpp.

SO_EXCLUSIVEADDRUSE

#define SO_EXCLUSIVEADDRUSE   ((int)(~SO_REUSEADDR)) /* disallow local address reuse */

Definition at line 159 of file qnativesocketengine_win.cpp.

WS_ERROR_DEBUG

#define WS_ERROR_DEBUG

(

x

)

Q_UNUSED(x)

Definition at line 150 of file qnativesocketengine_win.cpp.

Referenced by multicastMembershipHelper(), qt_socket_getMaxMsgSize(), and qt_socket_getType().

Function Documentation

multicastMembershipHelper()

static bool multicastMembershipHelper ( QNativeSocketEnginePrivate *  d, int  how6, int  how4, const QHostAddress &  groupAddress, const QNetworkInterface &  iface  )

static

Definition at line 840 of file qnativesocketengine_win.cpp.

{
    int level = 0;
    int sockOpt = 0;
    char *sockArg;
    int sockArgSize;

    struct ip_mreq mreq4;
#ifndef QT_NO_IPV6
    struct ipv6_mreq mreq6;

    if (groupAddress.protocol() == QAbstractSocket::IPv6Protocol) {
        level = IPPROTO_IPV6;
        sockOpt = how6;
        sockArg = reinterpret_cast<char *>(&mreq6);
        sockArgSize = sizeof(mreq6);
        memset(&mreq6, 0, sizeof(mreq6));
        Q_IPV6ADDR ip6 = groupAddress.toIPv6Address();
        memcpy(&mreq6.ipv6mr_multiaddr, &ip6, sizeof(ip6));
        mreq6.ipv6mr_interface = iface.index();
    } else
#endif
    if (groupAddress.protocol() == QAbstractSocket::IPv4Protocol) {
        level = IPPROTO_IP;
        sockOpt = how4;
        sockArg = reinterpret_cast<char *>(&mreq4);
        sockArgSize = sizeof(mreq4);
        memset(&mreq4, 0, sizeof(mreq4));
        mreq4.imr_multiaddr.s_addr = htonl(groupAddress.toIPv4Address());

        if (iface.isValid()) {
            QList<QNetworkAddressEntry> addressEntries = iface.addressEntries();
            if (!addressEntries.isEmpty()) {
                QHostAddress firstIP = addressEntries.first().ip();
                mreq4.imr_interface.s_addr = htonl(firstIP.toIPv4Address());
            } else {
                d->setError(QAbstractSocket::NetworkError,
                            QNativeSocketEnginePrivate::NetworkUnreachableErrorString);
                return false;
            }
        } else {
            mreq4.imr_interface.s_addr = INADDR_ANY;
        }
    } else {
        // unreachable
        d->setError(QAbstractSocket::UnsupportedSocketOperationError,
                    QNativeSocketEnginePrivate::ProtocolUnsupportedErrorString);
        return false;
    }

    int res = setsockopt(d->socketDescriptor, level, sockOpt, sockArg, sockArgSize);
    if (res == -1) {
        d->setError(QAbstractSocket::UnsupportedSocketOperationError,
                    QNativeSocketEnginePrivate::OperationUnsupportedErrorString);
        return false;
    }
    return true;
}

qt_socket_getMaxMsgSize()

static int qt_socket_getMaxMsgSize ( int  socketDescriptor )

inlinestatic

Warning

This function is not part of the public interface.

Definition at line 259 of file qnativesocketengine_win.cpp.

{
    int value = 0;
    QT_SOCKLEN_T valueSize = sizeof(value);
    if (::getsockopt(socketDescriptor, SOL_SOCKET, SO_MAX_MSG_SIZE, (char *) &value, &valueSize) != 0) {
        WS_ERROR_DEBUG(WSAGetLastError());
    }
    return value;
}

qt_socket_getPortAndAddress()

static void qt_socket_getPortAndAddress ( SOCKET  socketDescriptor, const qt_sockaddr *  sa, quint16 *  port, QHostAddress *  address  )

inlinestatic

Definition at line 171 of file qnativesocketengine_win.cpp.

Referenced by multicastMembershipHelper().

{
#if !defined (QT_NO_IPV6)
    if (sa->a.sa_family == AF_INET6) {
        const qt_sockaddr_in6 *sa6 = &sa->a6;
        Q_IPV6ADDR tmp;
        for (int i = 0; i < 16; ++i)
            tmp.c[i] = sa6->sin6_addr.qt_s6_addr[i];
        if (address) {
            QHostAddress a;
            a.setAddress(tmp);
            a.setScopeId(QString::number(sa6->sin6_scope_id));
            *address = a;
        }
        if (port)
        WSANtohs(socketDescriptor, sa6->sin6_port, port);
    } else
#endif
    if (sa->a.sa_family == AF_INET) {
        const sockaddr_in *sa4 = &sa->a4;
        unsigned long addr;
        WSANtohl(socketDescriptor, sa4->sin_addr.s_addr, &addr);
        QHostAddress a;
    a.setAddress(addr);
    if (address)
        *address = a;
        if (port)
        WSANtohs(socketDescriptor, sa4->sin_port, port);
    }
}

qt_socket_getType()

static QAbstractSocket::SocketType qt_socket_getType ( int  socketDescriptor )

inlinestatic

Warning

This function is not part of the public interface.

Definition at line 241 of file qnativesocketengine_win.cpp.

{
    int value = 0;
    QT_SOCKLEN_T valueSize = sizeof(value);
    if (::getsockopt(socketDescriptor, SOL_SOCKET, SO_TYPE, (char *) &value, &valueSize) != 0) {
        WS_ERROR_DEBUG(WSAGetLastError());
    } else {
        if (value == SOCK_STREAM)
            return QAbstractSocket::TcpSocket;
        else if (value == SOCK_DGRAM)
            return QAbstractSocket::UdpSocket;
    }
    return QAbstractSocket::UnknownSocketType;
}

qt_socket_setPortAndAddress()

static void qt_socket_setPortAndAddress ( SOCKET  socketDescriptor, sockaddr_in *  sockAddrIPv4, qt_sockaddr_in6 *  sockAddrIPv6, quint16  port, const QHostAddress &  address, sockaddr **  sockAddrPtr, QT_SOCKLEN_T *  sockAddrSize  )

inlinestatic

Sets the port and address to a sockaddr.

Warning

This function is not part of the public interface.

Requires that sa point to the IPv6 struct if the address is IPv6.

Definition at line 210 of file qnativesocketengine_win.cpp.

Referenced by multicastMembershipHelper().

{
#if !defined(QT_NO_IPV6)
    if (address.protocol() == QAbstractSocket::IPv6Protocol) {
        memset(sockAddrIPv6, 0, sizeof(qt_sockaddr_in6));
        sockAddrIPv6->sin6_family = AF_INET6;
        sockAddrIPv6->sin6_scope_id = address.scopeId().toInt();
        WSAHtons(socketDescriptor, port, &(sockAddrIPv6->sin6_port));
        Q_IPV6ADDR tmp = address.toIPv6Address();
        memcpy(&(sockAddrIPv6->sin6_addr.qt_s6_addr), &tmp, sizeof(tmp));
        *sockAddrSize = sizeof(qt_sockaddr_in6);
        *sockAddrPtr = (struct sockaddr *) sockAddrIPv6;
    } else
#endif
    if (address.protocol() == QAbstractSocket::IPv4Protocol
        || address.protocol() == QAbstractSocket::UnknownNetworkLayerProtocol) {
        memset(sockAddrIPv4, 0, sizeof(sockaddr_in));
        sockAddrIPv4->sin_family = AF_INET;
        WSAHtons(socketDescriptor, port, &(sockAddrIPv4->sin_port));
        WSAHtonl(socketDescriptor, address.toIPv4Address(), &(sockAddrIPv4->sin_addr.s_addr));
        *sockAddrSize = sizeof(sockaddr_in);
        *sockAddrPtr = (struct sockaddr *) sockAddrIPv4;
    } else {
        // unreachable
    }
}