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
|
/*
Copyright (C) 2008 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 QNetworkReplyHandler_h
#define QNetworkReplyHandler_h
#include <QObject>
#include <QNetworkAccessManager>
#include <QNetworkReply>
#include <QNetworkRequest>
#include "FormData.h"
#include "QtMIMETypeSniffer.h"
QT_BEGIN_NAMESPACE
class QFile;
class QNetworkReply;
QT_END_NAMESPACE
namespace WebCore {
class FormDataIODevice;
class ResourceError;
class ResourceHandle;
class ResourceRequest;
class ResourceResponse;
class QNetworkReplyHandler;
class QNetworkReplyHandlerCallQueue : public QObject {
Q_OBJECT
public:
QNetworkReplyHandlerCallQueue(QNetworkReplyHandler*, bool deferSignals);
bool deferSignals() const { return m_deferSignals; }
void setDeferSignals(bool, bool sync = false);
typedef void (QNetworkReplyHandler::*EnqueuedCall)();
void push(EnqueuedCall method);
void clear() { m_enqueuedCalls.clear(); }
void lock();
void unlock();
private:
QNetworkReplyHandler* m_replyHandler;
int m_locks;
bool m_deferSignals;
bool m_flushing;
QList<EnqueuedCall> m_enqueuedCalls;
Q_INVOKABLE void flush();
};
class QNetworkReplyWrapper : public QObject {
Q_OBJECT
public:
QNetworkReplyWrapper(QNetworkReplyHandlerCallQueue*, QNetworkReply*, bool sniffMIMETypes, QObject* parent = 0);
~QNetworkReplyWrapper();
QNetworkReply* reply() const { return m_reply; }
QNetworkReply* release();
void synchronousLoad();
QUrl redirectionTargetUrl() const { return m_redirectionTargetUrl; }
QString encoding() const { return m_encoding; }
QString advertisedMIMEType() const { return m_advertisedMIMEType; }
QString mimeType() const { return m_sniffedMIMEType.isEmpty() ? m_advertisedMIMEType : m_sniffedMIMEType; }
bool responseContainsData() const { return m_responseContainsData; }
bool wasRedirected() const { return m_redirectionTargetUrl.isValid(); }
// See setFinished().
bool isFinished() const { return m_reply->property("_q_isFinished").toBool(); }
private Q_SLOTS:
void receiveMetaData();
void didReceiveFinished();
void didReceiveReadyRead();
void receiveSniffedMIMEType();
void setFinished();
private:
void resetConnections();
void emitMetaDataChanged();
QNetworkReply* m_reply;
QUrl m_redirectionTargetUrl;
QString m_encoding;
QNetworkReplyHandlerCallQueue* m_queue;
bool m_responseContainsData;
QString m_advertisedMIMEType;
QString m_sniffedMIMEType;
OwnPtr<QtMIMETypeSniffer> m_sniffer;
bool m_sniffMIMETypes;
};
class QNetworkReplyHandler : public QObject
{
Q_OBJECT
public:
enum LoadType {
AsynchronousLoad,
SynchronousLoad
};
QNetworkReplyHandler(ResourceHandle*, LoadType, bool deferred = false);
void setLoadingDeferred(bool deferred) { m_queue.setDeferSignals(deferred, m_loadType == SynchronousLoad); }
QNetworkReply* reply() const { return m_replyWrapper ? m_replyWrapper->reply() : 0; }
void abort();
QNetworkReply* release();
void finish();
void forwardData();
void sendResponseIfNeeded();
static ResourceError errorForReply(QNetworkReply*);
private Q_SLOTS:
void uploadProgress(qint64 bytesSent, qint64 bytesTotal);
private:
void start();
String httpMethod() const;
void redirect(ResourceResponse&, const QUrl&);
bool wasAborted() const { return !m_resourceHandle; }
QNetworkReply* sendNetworkRequest(QNetworkAccessManager*, const ResourceRequest&);
FormDataIODevice* getIODevice(const ResourceRequest&);
void clearContentHeaders();
OwnPtr<QNetworkReplyWrapper> m_replyWrapper;
ResourceHandle* m_resourceHandle;
LoadType m_loadType;
QNetworkAccessManager::Operation m_method;
QNetworkRequest m_request;
// defer state holding
int m_redirectionTries;
QNetworkReplyHandlerCallQueue m_queue;
};
// Self destructing QIODevice for FormData
// For QNetworkAccessManager::put we will have to gurantee that the
// QIODevice is valid as long finished() of the QNetworkReply has not
// been emitted. With the presence of QNetworkReplyHandler::release I do
// not want to gurantee this.
class FormDataIODevice : public QIODevice {
Q_OBJECT
public:
FormDataIODevice(FormData*);
~FormDataIODevice();
bool isSequential() const;
qint64 getFormDataSize() const { return m_fileSize + m_dataSize; }
protected:
qint64 readData(char*, qint64);
qint64 writeData(const char*, qint64);
private:
void moveToNextElement();
qint64 computeSize();
void openFileForCurrentElement();
private:
Vector<FormDataElement> m_formElements;
QFile* m_currentFile;
qint64 m_currentDelta;
qint64 m_fileSize;
qint64 m_dataSize;
};
}
#endif // QNetworkReplyHandler_h
|
