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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
/*
Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies)
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Library General Public License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
Boston, MA 02110-1301, USA.
*/
#ifndef QtNAMThreadSafeProxy_h
#define QtNAMThreadSafeProxy_h
#include <QMutex>
#include <QNetworkCookie>
#include <QNetworkReply>
#include <QObject>
#include <QWaitCondition>
QT_BEGIN_NAMESPACE
class QNetworkAccessManager;
class QNetworkRequest;
class QUrl;
QT_END_NAMESPACE
namespace WebCore {
class QtNAMThreadSafeProxy : public QObject {
Q_OBJECT
public:
QtNAMThreadSafeProxy(QNetworkAccessManager *manager);
void setCookies(const QUrl& url, const QString& cookies)
{
emit localSetCookiesRequested(url, cookies);
}
QList<QNetworkCookie> cookiesForUrl(const QUrl& url)
{
bool done = false;
QList<QNetworkCookie> result;
emit localCookiesForUrlRequested(url, &done, &result);
QMutexLocker lock(&m_resultMutex);
while (!done)
m_resultWaitCondition.wait(&m_resultMutex);
return result;
}
bool willLoadFromCache(const QUrl& url)
{
bool done = false;
bool result;
emit localWillLoadFromCacheRequested(url, &done, &result);
QMutexLocker lock(&m_resultMutex);
while (!done)
m_resultWaitCondition.wait(&m_resultMutex);
return result;
}
bool hasCookieJar();
signals:
void localSetCookiesRequested(const QUrl&, const QString& cookies);
void localCookiesForUrlRequested(const QUrl&, bool* done, QList<QNetworkCookie>* result);
void localWillLoadFromCacheRequested(const QUrl&, bool* done, bool* result);
void hasCookieJarRequested(bool* done, bool* result);
private slots:
void localSetCookies(const QUrl&, const QString& cookies);
void localCookiesForUrl(const QUrl&, bool* done, QList<QNetworkCookie>* result);
void localWillLoadFromCache(const QUrl&, bool* done, bool* result);
void hasCookieJar(bool* done, bool* result);
private:
QNetworkAccessManager* m_manager;
QMutex m_resultMutex;
QWaitCondition m_resultWaitCondition;
};
class QtNetworkReplyThreadSafeProxy : public QObject {
Q_OBJECT
public:
typedef QPair<QByteArray, QByteArray> RawHeaderPair;
QtNetworkReplyThreadSafeProxy(QNetworkAccessManager *manager);
~QtNetworkReplyThreadSafeProxy();
void abort()
{
emit localAbortRequested();
}
void setForwardingDefered(bool forwardingDefered)
{
emit localSetForwardingDeferedRequested(forwardingDefered);
}
QByteArray contentDispositionHeader() { QMutexLocker lock(&m_mirroredMembersMutex); return m_contentDispositionHeader; }
qlonglong contentLengthHeader() { QMutexLocker lock(&m_mirroredMembersMutex); return m_contentLengthHeader; }
QString contentTypeHeader() { QMutexLocker lock(&m_mirroredMembersMutex); return m_contentTypeHeader; }
QNetworkReply::NetworkError error() { QMutexLocker lock(&m_mirroredMembersMutex); return m_error; }
QString errorString() { QMutexLocker lock(&m_mirroredMembersMutex); return m_errorString; }
QByteArray httpReasonPhrase() { QMutexLocker lock(&m_mirroredMembersMutex); return m_httpReasonPhrase; }
int httpStatusCode() { QMutexLocker lock(&m_mirroredMembersMutex); return m_httpStatusCode; }
QUrl url() { QMutexLocker lock(&m_mirroredMembersMutex); return m_url; }
QUrl redirectionTarget() { QMutexLocker lock(&m_mirroredMembersMutex); return m_redirectionTarget; }
QList<RawHeaderPair> rawHeaderPairs() { QMutexLocker lock(&m_mirroredMembersMutex); return m_rawHeaderPairs; }
QNetworkReply* reply()
{
// Careful, acccessing the reply accross threads might be hazardous to your health
return m_reply;
}
public:
void get(const QNetworkRequest &request)
{
emit localGetRequested(request);
}
void post(const QNetworkRequest &request, QIODevice* data)
{
emit localPostRequested(request, data);
}
void head(const QNetworkRequest &request)
{
emit localHeadRequested(request);
}
void put(const QNetworkRequest &request, QIODevice* data)
{
emit localPutRequested(request, data);
}
void deleteResource(const QNetworkRequest &request)
{
emit localDeleteResourceRequested(request);
}
#if QT_VERSION >= QT_VERSION_CHECK(4, 7, 0)
void sendCustomRequest(const QNetworkRequest &request, const QByteArray& verb)
{
emit localCustomRequestRequested(request, verb);
}
#endif
signals:
void localGetRequested(const QNetworkRequest& request);
void localPostRequested(const QNetworkRequest& request, QIODevice* data);
void localHeadRequested(const QNetworkRequest& request);
void localPutRequested(const QNetworkRequest& request, QIODevice* data);
void localDeleteResourceRequested(const QNetworkRequest& request);
void localCustomRequestRequested(const QNetworkRequest& request, const QByteArray& verb);
void localAbortRequested();
void localSetForwardingDeferedRequested(bool forwardingDefered);
void finished();
void readyRead();
void metaDataChanged();
void uploadProgress(qint64 bytesSent, qint64 bytesTotal);
void dataReceived(const QByteArray &data);
private slots:
void localGet(const QNetworkRequest& request);
void localPost(const QNetworkRequest& request, QIODevice* data);
void localHead(const QNetworkRequest& request);
void localPut(const QNetworkRequest& request, QIODevice* data);
void localDeleteResource(const QNetworkRequest& request);
void localCustomRequest(const QNetworkRequest& request, const QByteArray& verb);
void localAbort();
void localForwardData();
void localSetForwardingDefered(bool forwardingDefered);
void localMirrorMembers();
private:
void localSetReply(QNetworkReply *reply);
QNetworkAccessManager *m_manager;
QNetworkReply *m_reply;
bool m_forwardingDefered;
// Mirrored members
QMutex m_mirroredMembersMutex;
QByteArray m_contentDispositionHeader;
qlonglong m_contentLengthHeader;
QString m_contentTypeHeader;
QNetworkReply::NetworkError m_error;
QString m_errorString;
QByteArray m_httpReasonPhrase;
int m_httpStatusCode;
QUrl m_url;
QUrl m_redirectionTarget;
QList<RawHeaderPair> m_rawHeaderPairs;
};
}
#endif // QtNAMThreadSafeProxy_h
|
