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
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
|
// 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 "extensions/browser/api/socket/tls_socket.h"
#include <stddef.h>
#include <stdint.h>
#include <deque>
#include <utility>
#include "base/macros.h"
#include "base/memory/scoped_ptr.h"
#include "base/strings/string_piece.h"
#include "net/base/address_list.h"
#include "net/base/completion_callback.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "net/base/rand_callback.h"
#include "net/socket/ssl_client_socket.h"
#include "net/socket/tcp_client_socket.h"
#include "testing/gmock/include/gmock/gmock.h"
using testing::_;
using testing::DoAll;
using testing::Invoke;
using testing::Gt;
using testing::Return;
using testing::SaveArg;
using testing::WithArgs;
using base::StringPiece;
namespace extensions {
class MockSSLClientSocket : public net::SSLClientSocket {
public:
MockSSLClientSocket() {}
MOCK_METHOD0(Disconnect, void());
MOCK_METHOD3(Read,
int(net::IOBuffer* buf,
int buf_len,
const net::CompletionCallback& callback));
MOCK_METHOD3(Write,
int(net::IOBuffer* buf,
int buf_len,
const net::CompletionCallback& callback));
MOCK_METHOD1(SetReceiveBufferSize, int(int32_t));
MOCK_METHOD1(SetSendBufferSize, int(int32_t));
MOCK_METHOD1(Connect, int(const CompletionCallback&));
MOCK_CONST_METHOD0(IsConnectedAndIdle, bool());
MOCK_CONST_METHOD1(GetPeerAddress, int(net::IPEndPoint*));
MOCK_CONST_METHOD1(GetLocalAddress, int(net::IPEndPoint*));
MOCK_CONST_METHOD0(NetLog, const net::BoundNetLog&());
MOCK_METHOD0(SetSubresourceSpeculation, void());
MOCK_METHOD0(SetOmniboxSpeculation, void());
MOCK_CONST_METHOD0(WasEverUsed, bool());
MOCK_CONST_METHOD0(UsingTCPFastOpen, bool());
MOCK_METHOD1(GetSSLInfo, bool(net::SSLInfo*));
MOCK_CONST_METHOD1(GetConnectionAttempts, void(net::ConnectionAttempts*));
MOCK_METHOD0(ClearConnectionAttempts, void());
MOCK_METHOD1(AddConnectionAttempts, void(const net::ConnectionAttempts&));
MOCK_CONST_METHOD0(GetTotalReceivedBytes, int64_t());
MOCK_METHOD5(ExportKeyingMaterial,
int(const StringPiece&,
bool,
const StringPiece&,
unsigned char*,
unsigned int));
MOCK_METHOD1(GetSSLCertRequestInfo, void(net::SSLCertRequestInfo*));
MOCK_CONST_METHOD1(GetNextProto,
net::SSLClientSocket::NextProtoStatus(std::string*));
MOCK_CONST_METHOD0(GetUnverifiedServerCertificateChain,
scoped_refptr<net::X509Certificate>());
MOCK_CONST_METHOD0(GetChannelIDService, net::ChannelIDService*());
MOCK_METHOD2(GetSignedEKMForTokenBinding,
net::Error(crypto::ECPrivateKey*, std::vector<uint8_t>*));
MOCK_CONST_METHOD0(GetChannelIDKey, crypto::ECPrivateKey*());
MOCK_CONST_METHOD0(GetSSLFailureState, net::SSLFailureState());
bool IsConnected() const override { return true; }
private:
DISALLOW_COPY_AND_ASSIGN(MockSSLClientSocket);
};
class MockTCPSocket : public net::TCPClientSocket {
public:
explicit MockTCPSocket(const net::AddressList& address_list)
: net::TCPClientSocket(address_list, NULL, net::NetLog::Source()) {}
MOCK_METHOD3(Read,
int(net::IOBuffer* buf,
int buf_len,
const net::CompletionCallback& callback));
MOCK_METHOD3(Write,
int(net::IOBuffer* buf,
int buf_len,
const net::CompletionCallback& callback));
MOCK_METHOD2(SetKeepAlive, bool(bool enable, int delay));
MOCK_METHOD1(SetNoDelay, bool(bool no_delay));
bool IsConnected() const override { return true; }
private:
DISALLOW_COPY_AND_ASSIGN(MockTCPSocket);
};
class CompleteHandler {
public:
CompleteHandler() {}
MOCK_METHOD1(OnComplete, void(int result_code));
MOCK_METHOD2(OnReadComplete,
void(int result_code, scoped_refptr<net::IOBuffer> io_buffer));
MOCK_METHOD2(OnAccept, void(int, net::TCPClientSocket*));
private:
DISALLOW_COPY_AND_ASSIGN(CompleteHandler);
};
class TLSSocketTest : public ::testing::Test {
public:
TLSSocketTest() {}
void SetUp() override {
net::AddressList address_list;
// |ssl_socket_| is owned by |socket_|. TLSSocketTest keeps a pointer to
// it to expect invocations from TLSSocket to |ssl_socket_|.
scoped_ptr<MockSSLClientSocket> ssl_sock(new MockSSLClientSocket);
ssl_socket_ = ssl_sock.get();
socket_.reset(new TLSSocket(std::move(ssl_sock), "test_extension_id"));
EXPECT_CALL(*ssl_socket_, Disconnect()).Times(1);
};
void TearDown() override {
ssl_socket_ = NULL;
socket_.reset();
};
protected:
MockSSLClientSocket* ssl_socket_;
scoped_ptr<TLSSocket> socket_;
};
// Verify that a Read() on TLSSocket will pass through into a Read() on
// |ssl_socket_| and invoke its completion callback.
TEST_F(TLSSocketTest, TestTLSSocketRead) {
CompleteHandler handler;
EXPECT_CALL(*ssl_socket_, Read(_, _, _)).Times(1);
EXPECT_CALL(handler, OnReadComplete(_, _)).Times(1);
const int count = 512;
socket_->Read(
count,
base::Bind(&CompleteHandler::OnReadComplete, base::Unretained(&handler)));
}
// Verify that a Write() on a TLSSocket will pass through to Write()
// invocations on |ssl_socket_|, handling partial writes correctly, and calls
// the completion callback correctly.
TEST_F(TLSSocketTest, TestTLSSocketWrite) {
CompleteHandler handler;
net::CompletionCallback callback;
EXPECT_CALL(*ssl_socket_, Write(_, _, _)).Times(2).WillRepeatedly(
DoAll(SaveArg<2>(&callback), Return(128)));
EXPECT_CALL(handler, OnComplete(_)).Times(1);
scoped_refptr<net::IOBufferWithSize> io_buffer(
new net::IOBufferWithSize(256));
socket_->Write(
io_buffer.get(),
io_buffer->size(),
base::Bind(&CompleteHandler::OnComplete, base::Unretained(&handler)));
}
// Simulate a blocked Write, and verify that, when simulating the Write going
// through, the callback gets invoked.
TEST_F(TLSSocketTest, TestTLSSocketBlockedWrite) {
CompleteHandler handler;
net::CompletionCallback callback;
// Return ERR_IO_PENDING to say the Write()'s blocked. Save the |callback|
// Write()'s passed.
EXPECT_CALL(*ssl_socket_, Write(_, _, _)).Times(2).WillRepeatedly(
DoAll(SaveArg<2>(&callback), Return(net::ERR_IO_PENDING)));
scoped_refptr<net::IOBufferWithSize> io_buffer(new net::IOBufferWithSize(42));
socket_->Write(
io_buffer.get(),
io_buffer->size(),
base::Bind(&CompleteHandler::OnComplete, base::Unretained(&handler)));
// After the simulated asynchronous writes come back (via calls to
// callback.Run()), hander's OnComplete() should get invoked with the total
// amount written.
EXPECT_CALL(handler, OnComplete(42)).Times(1);
callback.Run(40);
callback.Run(2);
}
// Simulate multiple blocked Write()s.
TEST_F(TLSSocketTest, TestTLSSocketBlockedWriteReentry) {
const int kNumIOs = 5;
CompleteHandler handlers[kNumIOs];
net::CompletionCallback callback;
scoped_refptr<net::IOBufferWithSize> io_buffers[kNumIOs];
// The implementation of TLSSocket::Write() is inherited from
// Socket::Write(), which implements an internal write queue that wraps
// TLSSocket::WriteImpl(). Each call from TLSSocket::WriteImpl() will invoke
// |ssl_socket_|'s Write() (mocked here). Save the |callback| (assume they
// will all be equivalent), and return ERR_IO_PENDING, to indicate a blocked
// request. The mocked SSLClientSocket::Write() will get one request per
// TLSSocket::Write() request invoked on |socket_| below.
EXPECT_CALL(*ssl_socket_, Write(_, _, _)).Times(kNumIOs).WillRepeatedly(
DoAll(SaveArg<2>(&callback), Return(net::ERR_IO_PENDING)));
// Send out |kNuMIOs| requests, each with a different size.
for (int i = 0; i < kNumIOs; i++) {
io_buffers[i] = new net::IOBufferWithSize(128 + i * 50);
socket_->Write(io_buffers[i].get(),
io_buffers[i]->size(),
base::Bind(&CompleteHandler::OnComplete,
base::Unretained(&handlers[i])));
// Set up expectations on all |kNumIOs| handlers.
EXPECT_CALL(handlers[i], OnComplete(io_buffers[i]->size())).Times(1);
}
// Finish each pending I/O. This should satisfy the expectations on the
// handlers.
for (int i = 0; i < kNumIOs; i++) {
callback.Run(128 + i * 50);
}
}
typedef std::pair<net::CompletionCallback, int> PendingCallback;
class CallbackList : public std::deque<PendingCallback> {
public:
void append(const net::CompletionCallback& cb, int arg) {
push_back(std::make_pair(cb, arg));
}
};
// Simulate Write()s above and below a SSLClientSocket size limit.
TEST_F(TLSSocketTest, TestTLSSocketLargeWrites) {
const int kSizeIncrement = 4096;
const int kNumIncrements = 10;
const int kFragmentIncrement = 4;
const int kSizeLimit = kSizeIncrement * kFragmentIncrement;
net::CompletionCallback callback;
CompleteHandler handler;
scoped_refptr<net::IOBufferWithSize> io_buffers[kNumIncrements];
CallbackList pending_callbacks;
size_t total_bytes_requested = 0;
size_t total_bytes_written = 0;
// Some implementations of SSLClientSocket may have write-size limits (e.g,
// max 1 TLS record, which is 16k). This test mocks a size limit at
// |kSizeIncrement| and calls Write() above and below that limit. It
// simulates SSLClientSocket::Write() behavior in only writing up to the size
// limit, requiring additional calls for the remaining data to be sent.
// Socket::Write() (and supporting methods) execute the additional calls as
// needed. This test verifies that this inherited implementation does
// properly issue additional calls, and that the total amount returned from
// all mocked SSLClientSocket::Write() calls is the same as originally
// requested.
// |ssl_socket_|'s Write() will write at most |kSizeLimit| bytes. The
// inherited Socket::Write() will repeatedly call |ssl_socket_|'s Write()
// until the entire original request is sent. Socket::Write() will queue any
// additional write requests until the current request is complete. A
// request is complete when the callback passed to Socket::WriteImpl() is
// invoked with an argument equal to the original number of bytes requested
// from Socket::Write(). If the callback is invoked with a smaller number,
// Socket::WriteImpl() will get repeatedly invoked until the sum of the
// callbacks' arguments is equal to the original requested amount.
EXPECT_CALL(*ssl_socket_, Write(_, _, _)).WillRepeatedly(
DoAll(WithArgs<2, 1>(Invoke(&pending_callbacks, &CallbackList::append)),
Return(net::ERR_IO_PENDING)));
// Observe what comes back from Socket::Write() here.
EXPECT_CALL(handler, OnComplete(Gt(0))).Times(kNumIncrements);
// Send out |kNumIncrements| requests, each with a different size. The
// last request is the same size as the first, and the ones in the middle
// are monotonically increasing from the first.
for (int i = 0; i < kNumIncrements; i++) {
const bool last = i == (kNumIncrements - 1);
io_buffers[i] = new net::IOBufferWithSize(last ? kSizeIncrement
: kSizeIncrement * (i + 1));
total_bytes_requested += io_buffers[i]->size();
// Invoke Socket::Write(). This will invoke |ssl_socket_|'s Write(), which
// this test mocks out. That mocked Write() is in an asynchronous waiting
// state until the passed callback (saved in the EXPECT_CALL for
// |ssl_socket_|'s Write()) is invoked.
socket_->Write(
io_buffers[i].get(),
io_buffers[i]->size(),
base::Bind(&CompleteHandler::OnComplete, base::Unretained(&handler)));
}
// Invoke callbacks for pending I/Os. These can synchronously invoke more of
// |ssl_socket_|'s Write() as needed. The callback checks how much is left
// in the request, and then starts issuing any queued Socket::Write()
// invocations.
while (!pending_callbacks.empty()) {
PendingCallback cb = pending_callbacks.front();
pending_callbacks.pop_front();
int amount_written_invocation = std::min(kSizeLimit, cb.second);
total_bytes_written += amount_written_invocation;
cb.first.Run(amount_written_invocation);
}
ASSERT_EQ(total_bytes_requested, total_bytes_written)
<< "There should be exactly as many bytes written as originally "
<< "requested to Write().";
}
} // namespace extensions
|