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
|
/*
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 <QNetworkRequest>
#include <QNetworkAccessManager>
#include "FormData.h"
QT_BEGIN_NAMESPACE
class QFile;
class QNetworkReply;
QT_END_NAMESPACE
namespace WebCore {
class ResourceHandle;
class ResourceResponse;
class QNetworkReplyWrapper : public QObject {
Q_OBJECT
public:
QNetworkReplyWrapper(QNetworkReply*, QObject* parent = 0);
~QNetworkReplyWrapper();
QNetworkReply* reply() const { return m_reply; }
QNetworkReply* release();
QUrl redirectionTargetUrl() const { return m_redirectionTargetUrl; }
QString encoding() const { return m_encoding; }
QString advertisedMimeType() const { return m_advertisedMimeType; }
Q_SIGNALS:
void finished();
void metaDataChanged();
void readyRead();
void uploadProgress(qint64 bytesSent, qint64 bytesTotal);
private Q_SLOTS:
void receiveMetaData();
void didReceiveFinished();
private:
void resetConnections();
QNetworkReply* m_reply;
QUrl m_redirectionTargetUrl;
QString m_encoding;
QString m_advertisedMimeType;
};
class QNetworkReplyHandler : public QObject
{
Q_OBJECT
public:
enum LoadType {
AsynchronousLoad,
SynchronousLoad
};
QNetworkReplyHandler(ResourceHandle*, LoadType, bool deferred = false);
void setLoadingDeferred(bool);
QNetworkReply* reply() const { return m_replyWrapper ? m_replyWrapper->reply() : 0; }
void abort();
QNetworkReply* release();
public slots:
void finish();
void sendResponseIfNeeded();
void forwardData();
void uploadProgress(qint64 bytesSent, qint64 bytesTotal);
private:
void start();
void resetState();
String httpMethod() const;
void resumeDeferredLoad();
void redirect(ResourceResponse&, const QUrl&);
bool wasAborted() const { return !m_resourceHandle; }
QNetworkReply* sendNetworkRequest();
QNetworkReplyWrapper* m_replyWrapper;
ResourceHandle* m_resourceHandle;
bool m_redirected;
bool m_responseSent;
bool m_responseContainsData;
LoadType m_loadType;
QNetworkAccessManager::Operation m_method;
QNetworkRequest m_request;
bool m_deferred;
// defer state holding
bool m_hasStarted;
bool m_callFinishOnResume;
bool m_callSendResponseIfNeededOnResume;
bool m_callForwardDataOnResume;
int m_redirectionTries;
};
// 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
|
