1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
// Copyright (C) 2024 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
#ifndef QSOCKETABSTRACTION_P_H
#define QSOCKETABSTRACTION_P_H
#include <private/qtnetworkglobal_p.h>
#include <QtNetwork/qabstractsocket.h>
#if QT_CONFIG(localserver)
# include <QtNetwork/qlocalsocket.h>
#endif
#include <QtCore/qxpfunctional.h>
//
// W A R N I N G
// -------------
//
// This file is not part of the Qt API. It exists for the convenience
// of the Network Access API. This header file may change from
// version to version without notice, or even be removed.
//
// We mean it.
//
QT_BEGIN_NAMESPACE
// Helper functions to deal with a QIODevice that is either a socket or a local
// socket.
namespace QSocketAbstraction {
template <typename Fn, typename... Args>
auto visit(Fn &&fn, QIODevice *socket, Args &&...args)
{
if (auto *s = qobject_cast<QAbstractSocket *>(socket))
return std::forward<Fn>(fn)(s, std::forward<Args>(args)...);
#if QT_CONFIG(localserver)
if (auto *s = qobject_cast<QLocalSocket *>(socket))
return std::forward<Fn>(fn)(s, std::forward<Args>(args)...);
#endif
Q_UNREACHABLE();
}
// Since QLocalSocket's LocalSocketState's values are defined as being equal
// to some of QAbstractSocket's SocketState's values, we can use the superset
// of the two as the return type.
inline QAbstractSocket::SocketState socketState(QIODevice *device)
{
auto getState = [](auto *s) {
using T = std::remove_pointer_t<decltype(s)>;
if constexpr (std::is_same_v<T, QAbstractSocket>) {
return s->state();
#if QT_CONFIG(localserver)
} else if constexpr (std::is_same_v<T, QLocalSocket>) {
QLocalSocket::LocalSocketState st = s->state();
return static_cast<QAbstractSocket::SocketState>(st);
#endif
}
Q_UNREACHABLE();
};
return visit(getState, device);
}
// Same as for socketState(), but for the errors
inline QAbstractSocket::SocketError socketError(QIODevice *device)
{
auto getError = [](auto *s) {
using T = std::remove_pointer_t<decltype(s)>;
if constexpr (std::is_same_v<T, QAbstractSocket>) {
return s->error();
#if QT_CONFIG(localserver)
} else if constexpr (std::is_same_v<T, QLocalSocket>) {
QLocalSocket::LocalSocketError st = s->error();
return static_cast<QAbstractSocket::SocketError>(st);
#endif
}
Q_UNREACHABLE();
};
return visit(getError, device);
}
inline QString socketPeerName(QIODevice *device)
{
auto getPeerName = [](auto *s) {
using T = std::remove_pointer_t<decltype(s)>;
if constexpr (std::is_same_v<T, QAbstractSocket>) {
return s->peerName();
#if QT_CONFIG(localserver)
} else if constexpr (std::is_same_v<T, QLocalSocket>) {
return s->serverName();
#endif
}
Q_UNREACHABLE();
};
return visit(getPeerName, device);
}
} // namespace QSocketAbstraction
QT_END_NAMESPACE
#endif // QSOCKETABSTRACTION_P_H
|
