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
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "net/http/failing_http_transaction_factory.h"
#include "base/bind.h"
#include "base/compiler_specific.h"
#include "base/logging.h"
#include "base/message_loop/message_loop.h"
#include "net/base/load_timing_info.h"
#include "net/base/upload_progress.h"
namespace net {
class AuthCredentials;
class BoundNetLog;
class HttpRequestHeaders;
class IOBuffer;
class X509Certificate;
struct HttpRequestInfo;
namespace {
// A simple class to interpose between the cache and network http layers.
// These transactions can be generated by the FailingHttpTransactionFactory
// to test interactions between cache and network.
class FailingHttpTransaction : public HttpTransaction {
public:
explicit FailingHttpTransaction(Error error);
virtual ~FailingHttpTransaction();
// HttpTransaction
virtual int Start(const HttpRequestInfo* request_info,
const CompletionCallback& callback,
const BoundNetLog& net_log) OVERRIDE;
virtual int RestartIgnoringLastError(
const CompletionCallback& callback) OVERRIDE;
virtual int RestartWithCertificate(
X509Certificate* client_cert,
const CompletionCallback& callback) OVERRIDE;
virtual int RestartWithAuth(
const AuthCredentials& credentials,
const CompletionCallback& callback) OVERRIDE;
virtual bool IsReadyToRestartForAuth() OVERRIDE;
virtual int Read(IOBuffer* buf, int buf_len,
const CompletionCallback& callback) OVERRIDE;
virtual void StopCaching() OVERRIDE;
virtual bool GetFullRequestHeaders(
HttpRequestHeaders* headers) const OVERRIDE;
virtual int64 GetTotalReceivedBytes() const OVERRIDE;
virtual void DoneReading() OVERRIDE;
virtual const HttpResponseInfo* GetResponseInfo() const OVERRIDE;
virtual LoadState GetLoadState() const OVERRIDE;
virtual UploadProgress GetUploadProgress() const OVERRIDE;
virtual void SetQuicServerInfo(
net::QuicServerInfo* quic_server_info) OVERRIDE;
virtual bool GetLoadTimingInfo(
LoadTimingInfo* load_timing_info) const OVERRIDE;
virtual void SetPriority(RequestPriority priority) OVERRIDE;
virtual void SetWebSocketHandshakeStreamCreateHelper(
WebSocketHandshakeStreamBase::CreateHelper* create_helper) OVERRIDE;
virtual void SetBeforeNetworkStartCallback(
const BeforeNetworkStartCallback& callback) OVERRIDE;
virtual void SetBeforeProxyHeadersSentCallback(
const BeforeProxyHeadersSentCallback& callback) OVERRIDE;
virtual int ResumeNetworkStart() OVERRIDE;
private:
Error error_;
};
FailingHttpTransaction::FailingHttpTransaction(Error error) : error_(error) {
DCHECK_LT(error, OK);
}
FailingHttpTransaction::~FailingHttpTransaction() {}
int FailingHttpTransaction::Start(const HttpRequestInfo* request_info,
const CompletionCallback& callback,
const BoundNetLog& net_log) {
base::MessageLoop::current()->PostTask(
FROM_HERE, base::Bind(callback, error_));
return ERR_IO_PENDING;
}
int FailingHttpTransaction::RestartIgnoringLastError(
const CompletionCallback& callback) {
return ERR_FAILED;
}
int FailingHttpTransaction::RestartWithCertificate(
X509Certificate* client_cert,
const CompletionCallback& callback) {
return ERR_FAILED;
}
int FailingHttpTransaction::RestartWithAuth(
const AuthCredentials& credentials,
const CompletionCallback& callback) {
return ERR_FAILED;
}
bool FailingHttpTransaction::IsReadyToRestartForAuth() {
return false;
}
int FailingHttpTransaction::Read(IOBuffer* buf, int buf_len,
const CompletionCallback& callback) {
NOTREACHED();
return ERR_FAILED;
}
void FailingHttpTransaction::StopCaching() {}
bool FailingHttpTransaction::GetFullRequestHeaders(
HttpRequestHeaders* headers) const {
return false;
}
int64 FailingHttpTransaction::GetTotalReceivedBytes() const {
return 0;
}
void FailingHttpTransaction::DoneReading() {
NOTREACHED();
}
const HttpResponseInfo* FailingHttpTransaction::GetResponseInfo() const {
return NULL;
}
LoadState FailingHttpTransaction::GetLoadState() const {
return LOAD_STATE_IDLE;
}
UploadProgress FailingHttpTransaction::GetUploadProgress() const {
return UploadProgress();
}
void FailingHttpTransaction::SetQuicServerInfo(
net::QuicServerInfo* quic_server_info) {}
bool FailingHttpTransaction::GetLoadTimingInfo(
LoadTimingInfo* load_timing_info) const {
return false;
}
void FailingHttpTransaction::SetPriority(RequestPriority priority) {}
void FailingHttpTransaction::SetWebSocketHandshakeStreamCreateHelper(
WebSocketHandshakeStreamBase::CreateHelper* create_helper) {
NOTREACHED();
}
void FailingHttpTransaction::SetBeforeNetworkStartCallback(
const BeforeNetworkStartCallback& callback) {
}
void FailingHttpTransaction::SetBeforeProxyHeadersSentCallback(
const BeforeProxyHeadersSentCallback& callback) {
}
int FailingHttpTransaction::ResumeNetworkStart() {
NOTREACHED();
return ERR_FAILED;
}
} // namespace
FailingHttpTransactionFactory::FailingHttpTransactionFactory(
HttpNetworkSession* session,
Error error) : session_(session), error_(error) {
DCHECK_LT(error, OK);
}
FailingHttpTransactionFactory::~FailingHttpTransactionFactory() {}
// HttpTransactionFactory:
int FailingHttpTransactionFactory::CreateTransaction(
RequestPriority priority,
scoped_ptr<HttpTransaction>* trans) {
trans->reset(new FailingHttpTransaction(error_));
return OK;
}
HttpCache* FailingHttpTransactionFactory::GetCache() {
return NULL;
}
HttpNetworkSession* FailingHttpTransactionFactory::GetSession() {
return session_;
}
} // namespace net
|
