Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(401)

Unified Diff: net/spdy/spdy_network_transaction_unittest.cc

Issue 9425016: Change MockRead and MockWrite (et. al.) to take an IoMode enum, instead (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src/
Patch Set: sync Created 8 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: net/spdy/spdy_network_transaction_unittest.cc
===================================================================
--- net/spdy/spdy_network_transaction_unittest.cc (revision 122608)
+++ net/spdy/spdy_network_transaction_unittest.cc (working copy)
@@ -231,7 +231,7 @@
DCHECK(!deterministic_);
data_vector_.push_back(data);
linked_ptr<SSLSocketDataProvider> ssl_(
- new SSLSocketDataProvider(true, OK));
+ new SSLSocketDataProvider(ASYNC, OK));
if (test_type_ == SPDYNPN) {
ssl_->next_proto_status = SSLClientSocket::kNextProtoNegotiated;
ssl_->next_proto = "spdy/2.1";
@@ -259,7 +259,7 @@
DCHECK(deterministic_);
data_vector_.push_back(data);
linked_ptr<SSLSocketDataProvider> ssl_(
- new SSLSocketDataProvider(true, OK));
+ new SSLSocketDataProvider(ASYNC, OK));
if (test_type_ == SPDYNPN) {
ssl_->next_proto_status = SSLClientSocket::kNextProtoNegotiated;
ssl_->next_proto = "spdy/2.1";
@@ -557,7 +557,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -607,7 +607,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -668,7 +668,7 @@
CreateMockRead(*fbody2),
CreateMockRead(*fbody3),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<OrderedSocketData> data(
new OrderedSocketData(reads, arraysize(reads),
@@ -752,7 +752,7 @@
CreateMockRead(*body2),
CreateMockRead(*fbody),
CreateMockRead(*fbody2),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<OrderedSocketData> data(
new OrderedSocketData(reads, arraysize(reads),
@@ -839,7 +839,7 @@
CreateMockRead(*body2),
CreateMockRead(*fbody),
CreateMockRead(*fbody2),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<OrderedSocketData> preconnect_data(
new OrderedSocketData(reads, arraysize(reads),
@@ -965,7 +965,7 @@
CreateMockRead(*body3),
CreateMockRead(*fbody3),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<OrderedSocketData> data(
@@ -1105,7 +1105,7 @@
CreateMockRead(*body3),
CreateMockRead(*fbody3),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<OrderedSocketData> data(
@@ -1242,7 +1242,7 @@
CreateMockRead(*resp2, 7),
CreateMockRead(*body2),
CreateMockRead(*fbody2),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<OrderedSocketData> data(
@@ -1372,7 +1372,7 @@
CreateMockRead(*body),
CreateMockRead(*fin_body),
CreateMockRead(*resp2, 7),
- MockRead(true, ERR_CONNECTION_RESET, 0), // Abort!
+ MockRead(ASYNC, ERR_CONNECTION_RESET, 0), // Abort!
};
scoped_ptr<OrderedSocketData> data(
@@ -1494,7 +1494,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1565,7 +1565,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1593,7 +1593,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1625,7 +1625,7 @@
CreateMockRead(*resp),
CreateMockRead(*chunk1),
CreateMockRead(*chunk2),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1663,7 +1663,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1710,7 +1710,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1749,7 +1749,7 @@
MockRead reads[] = {
CreateMockRead(*stream_reply, 2),
CreateMockRead(*stream_body, 3),
- MockRead(false, 0, 0) // EOF
+ MockRead(SYNCHRONOUS, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1773,15 +1773,15 @@
scoped_ptr<spdy::SpdyFrame> rst(
ConstructSpdyRstStream(1, spdy::CANCEL));
MockWrite writes[] = {
- CreateMockWrite(*req.get(), 0, false),
- MockWrite(false, 0, 0, 2),
- CreateMockWrite(*rst.get(), 3, false),
+ CreateMockWrite(*req.get(), 0, SYNCHRONOUS),
+ MockWrite(SYNCHRONOUS, 0, 0, 2),
+ CreateMockWrite(*rst.get(), 3, SYNCHRONOUS),
};
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
- CreateMockRead(*resp.get(), 1, true),
- MockRead(true, 0, 0, 4) // EOF
+ CreateMockRead(*resp.get(), 1, ASYNC),
+ MockRead(ASYNC, 0, 0, 4) // EOF
};
scoped_refptr<DeterministicSocketData> data(
@@ -1813,7 +1813,7 @@
scoped_ptr<spdy::SpdyFrame> body(ConstructSpdyBodyFrame(1, true));
MockRead reads[] = {
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1837,7 +1837,7 @@
CreateMockRead(*resp),
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1925,7 +1925,7 @@
CreateMockRead(*window_update),
CreateMockRead(*resp),
CreateMockRead(*body_end),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -1988,10 +1988,10 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body_no_fin),
- MockRead(true, ERR_IO_PENDING, 0), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 0), // Force a pause
CreateMockRead(*body_fin),
- MockRead(true, ERR_IO_PENDING, 0), // Force a pause
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, ERR_IO_PENDING, 0), // Force a pause
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -2088,8 +2088,8 @@
CreateMockRead(*window_update),
CreateMockRead(*window_update),
CreateMockRead(*window_update),
- MockRead(true, ERR_IO_PENDING, 0), // Wait for the RST to be written.
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, ERR_IO_PENDING, 0), // Wait for the RST to be written.
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -2195,7 +2195,7 @@
CreateMockRead(*reply),
CreateMockRead(*body2),
CreateMockRead(*body3),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
// Force all writes to happen before any read, last write will not
@@ -2257,7 +2257,7 @@
// RunAllPending() call at the end since the SpdySession survives the
// HttpNetworkTransaction and still tries to continue Read()'ing. Any
// MockRead will do here.
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
StaticSocketDataProvider data(reads, arraysize(reads),
@@ -2287,14 +2287,14 @@
scoped_ptr<spdy::SpdyFrame> rst(
ConstructSpdyRstStream(1, spdy::CANCEL));
MockWrite writes[] = {
- CreateMockWrite(*req, 0, false),
- CreateMockWrite(*rst, 2, false),
+ CreateMockWrite(*req, 0, SYNCHRONOUS),
+ CreateMockWrite(*rst, 2, SYNCHRONOUS),
};
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
- CreateMockRead(*resp, 1, true),
- MockRead(true, 0, 0, 3) // EOF
+ CreateMockRead(*resp, 1, ASYNC),
+ MockRead(ASYNC, 0, 0, 3) // EOF
};
scoped_refptr<DeterministicSocketData> data(
@@ -2344,15 +2344,15 @@
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
CreateMockRead(*resp, 2),
- MockRead(true, ERR_IO_PENDING, 3), // Force a pause
- MockRead(true, reinterpret_cast<const char*>(kGetBodyFrame2),
+ MockRead(ASYNC, ERR_IO_PENDING, 3), // Force a pause
+ MockRead(ASYNC, reinterpret_cast<const char*>(kGetBodyFrame2),
arraysize(kGetBodyFrame2), 4),
- MockRead(true, ERR_IO_PENDING, 5), // Force a pause
- MockRead(true, 0, 0, 6), // EOF
+ MockRead(ASYNC, ERR_IO_PENDING, 5), // Force a pause
+ MockRead(ASYNC, 0, 0, 6), // EOF
};
MockRead reads2[] = {
CreateMockRead(*resp, 2),
- MockRead(true, 0, 0, 3), // EOF
+ MockRead(ASYNC, 0, 0, 3), // EOF
};
scoped_ptr<OrderedSocketData> data(
@@ -2399,9 +2399,9 @@
scoped_ptr<spdy::SpdyFrame> body(ConstructSpdyBodyFrame(1, true));
MockRead reads[] = {
CreateMockRead(*resp.get(), 2),
- MockRead(true, ERR_IO_PENDING, 3), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 3), // Force a pause
CreateMockRead(*body.get(), 4),
- MockRead(true, 0, 0, 5), // EOF
+ MockRead(ASYNC, 0, 0, 5), // EOF
};
scoped_ptr<OrderedSocketData> data(
@@ -2486,7 +2486,7 @@
};
MockRead reads[] = {
CreateMockRead(*resp, 2),
- MockRead(true, 0, 0, 3) // EOF
+ MockRead(ASYNC, 0, 0, 3) // EOF
};
// Setup writes/reads to www.foo.com
@@ -2498,7 +2498,7 @@
MockRead reads2[] = {
CreateMockRead(*resp2, 2),
CreateMockRead(*body2, 3),
- MockRead(true, 0, 0, 4) // EOF
+ MockRead(ASYNC, 0, 0, 4) // EOF
};
scoped_ptr<OrderedSocketData> data(
new OrderedSocketData(reads, arraysize(reads),
@@ -2557,7 +2557,7 @@
reply(ConstructSpdyGetSynReply(kExtraHeaders, 1, 1));
MockRead reads[] = {
CreateMockRead(*reply, 1),
- MockRead(true, ERR_IO_PENDING, 3), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 3), // Force a pause
};
HttpResponseInfo response;
@@ -2620,7 +2620,7 @@
CreateMockRead(*stream1_reply),
CreateMockRead(*stream1_headers),
CreateMockRead(*stream1_body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -2654,7 +2654,7 @@
CreateMockRead(*reply, 1),
CreateMockRead(*push, 1),
CreateMockRead(*body, 1),
- MockRead(true, ERR_IO_PENDING, 3), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 3), // Force a pause
};
HttpResponseInfo response;
@@ -2721,8 +2721,8 @@
CreateMockRead(*resp, 2),
CreateMockRead(*rep, 3),
CreateMockRead(*body, 4),
- MockRead(true, ERR_IO_PENDING, 5), // Force a pause
- MockRead(true, 0, 0, 7) // EOF
+ MockRead(ASYNC, ERR_IO_PENDING, 5), // Force a pause
+ MockRead(ASYNC, 0, 0, 7) // EOF
};
// Setup writes/reads to www.foo.com
@@ -2754,7 +2754,7 @@
MockRead reads2[] = {
CreateMockRead(*resp2, 2),
CreateMockRead(*body2, 3),
- MockRead(true, 0, 0, 5) // EOF
+ MockRead(ASYNC, 0, 0, 5) // EOF
};
scoped_ptr<OrderedSocketData> data(
new OrderedSocketData(reads, arraysize(reads),
@@ -2834,10 +2834,10 @@
MockRead reads[] = {
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
- CreateMockRead(*stream1_body, 4, false),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ CreateMockRead(*stream1_body, 4, SYNCHRONOUS),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 5),
- MockRead(true, ERR_IO_PENDING, 6), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 6), // Force a pause
};
HttpResponseInfo response;
@@ -2887,10 +2887,10 @@
MockRead reads[] = {
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 5),
- CreateMockRead(*stream1_body, 4, false),
- MockRead(true, ERR_IO_PENDING, 6), // Force a pause
+ CreateMockRead(*stream1_body, 4, SYNCHRONOUS),
+ MockRead(ASYNC, ERR_IO_PENDING, 6), // Force a pause
};
HttpResponseInfo response;
@@ -2938,8 +2938,8 @@
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
CreateMockRead(*stream2_rst, 4),
- CreateMockRead(*stream1_body, 5, false),
- MockRead(true, ERR_IO_PENDING, 6), // Force a pause
+ CreateMockRead(*stream1_body, 5, SYNCHRONOUS),
+ MockRead(ASYNC, ERR_IO_PENDING, 6), // Force a pause
};
scoped_ptr<OrderedSocketData> data(
@@ -3015,10 +3015,10 @@
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
CreateMockRead(*stream3_syn, 4),
- CreateMockRead(*stream1_body, 6, false),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ CreateMockRead(*stream1_body, 6, SYNCHRONOUS),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 7),
- MockRead(true, ERR_IO_PENDING, 8), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 8), // Force a pause
};
HttpResponseInfo response;
@@ -3072,16 +3072,16 @@
MockRead reads[] = {
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame1),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame1),
arraysize(kPushBodyFrame1), 4),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame2),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame2),
arraysize(kPushBodyFrame2) - 1, 5),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame3),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame3),
arraysize(kPushBodyFrame3) - 1, 6),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame4),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame4),
arraysize(kPushBodyFrame4) - 1, 7),
- CreateMockRead(*stream1_body, 8, false),
- MockRead(true, ERR_IO_PENDING, 9), // Force a pause
+ CreateMockRead(*stream1_body, 8, SYNCHRONOUS),
+ MockRead(ASYNC, ERR_IO_PENDING, 9), // Force a pause
};
HttpResponseInfo response;
@@ -3137,17 +3137,17 @@
MockRead reads[] = {
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame1),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame1),
arraysize(kPushBodyFrame1), 4),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame2),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame2),
arraysize(kPushBodyFrame2) - 1, 5),
- MockRead(true, ERR_IO_PENDING, 6), // Force a pause
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame3),
+ MockRead(ASYNC, ERR_IO_PENDING, 6), // Force a pause
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame3),
arraysize(kPushBodyFrame3) - 1, 7),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame4),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame4),
arraysize(kPushBodyFrame4) - 1, 8),
- CreateMockRead(*stream1_body.get(), 9, false),
- MockRead(true, ERR_IO_PENDING, 10) // Force a pause.
+ CreateMockRead(*stream1_body.get(), 9, SYNCHRONOUS),
+ MockRead(ASYNC, ERR_IO_PENDING, 10) // Force a pause.
};
HttpResponseInfo response;
@@ -3198,7 +3198,7 @@
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
CreateMockRead(*stream1_body, 4),
- MockRead(true, ERR_IO_PENDING, 5) // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 5) // Force a pause
};
scoped_ptr<OrderedSocketData> data(
@@ -3260,7 +3260,7 @@
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
CreateMockRead(*stream1_body, 4),
- MockRead(true, ERR_IO_PENDING, 5), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 5), // Force a pause
};
scoped_ptr<OrderedSocketData> data(
@@ -3318,7 +3318,7 @@
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
CreateMockRead(*stream1_body, 4),
- MockRead(true, ERR_IO_PENDING, 5) // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 5) // Force a pause
};
scoped_ptr<OrderedSocketData> data(
@@ -3407,7 +3407,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -3546,7 +3546,7 @@
MockRead reads[] = {
CreateMockRead(*frame_reply),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
// Attach the headers to the request.
@@ -3662,7 +3662,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -3694,14 +3694,14 @@
ConstructSpdyGet(NULL, 0, false, 1, LOWEST));
MockWrite writes[] = {
CreateMockWrite(*req),
- MockWrite(true, 0, 0) // EOF
+ MockWrite(ASYNC, 0, 0) // EOF
};
scoped_ptr<spdy::SpdyFrame> body(ConstructSpdyBodyFrame(1, true));
MockRead reads[] = {
CreateMockRead(*test_cases[i].syn_reply),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -3720,9 +3720,9 @@
scoped_ptr<spdy::SpdyFrame> req(ConstructSpdyGet(NULL, 0, false, 1, LOWEST));
MockWrite writes[] = {
// We'll write 10 bytes successfully
- MockWrite(true, req->data(), 10),
+ MockWrite(ASYNC, req->data(), 10),
// Followed by ERROR!
- MockWrite(true, ERR_FAILED),
+ MockWrite(ASYNC, ERR_FAILED),
};
scoped_ptr<DelayedSocketData> data(
@@ -3748,7 +3748,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -3810,7 +3810,7 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
net::CapturingBoundNetLog log(net::CapturingNetLog::kUnbounded);
@@ -3912,11 +3912,11 @@
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
CreateMockRead(*resp),
- MockRead(true, ERR_IO_PENDING), // Force a pause
- MockRead(true, combined_data_frames, combined_data_frames_len),
- MockRead(true, ERR_IO_PENDING), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING), // Force a pause
+ MockRead(ASYNC, combined_data_frames, combined_data_frames_len),
+ MockRead(ASYNC, ERR_IO_PENDING), // Force a pause
CreateMockRead(*last_frame),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4011,9 +4011,9 @@
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
CreateMockRead(*resp),
- MockRead(true, ERR_IO_PENDING), // Force a pause
- MockRead(true, combined_data_frames, combined_data_frames_len),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, ERR_IO_PENDING), // Force a pause
+ MockRead(ASYNC, combined_data_frames, combined_data_frames_len),
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4110,8 +4110,8 @@
combined_frames, arraysize(combined_frames));
MockRead reads[] = {
- MockRead(true, combined_frames, combined_frames_len),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, combined_frames, combined_frames_len),
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4198,9 +4198,9 @@
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
CreateMockRead(*resp),
- MockRead(true, ERR_IO_PENDING), // Force a wait
- MockRead(true, combined_data_frames, combined_data_frames_len),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, ERR_IO_PENDING), // Force a wait
+ MockRead(ASYNC, combined_data_frames, combined_data_frames_len),
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4279,9 +4279,9 @@
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
CreateMockRead(*resp),
- MockRead(true, ERR_IO_PENDING), // Force a wait
+ MockRead(ASYNC, ERR_IO_PENDING), // Force a wait
CreateMockRead(*data_frame),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4410,7 +4410,7 @@
CreateMockRead(*reply),
CreateMockRead(*body),
CreateMockRead(*settings_frame),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4528,7 +4528,7 @@
MockRead reads[] = {
CreateMockRead(*reply),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4572,7 +4572,7 @@
scoped_ptr<spdy::SpdyFrame> go_away(ConstructSpdyGoAway());
MockRead reads[] = {
CreateMockRead(*go_away),
- MockRead(true, 0, 0), // EOF
+ MockRead(ASYNC, 0, 0), // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4593,7 +4593,7 @@
scoped_ptr<spdy::SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1));
MockRead reads[] = {
CreateMockRead(*resp),
- MockRead(false, 0, 0) // EOF
+ MockRead(SYNCHRONOUS, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -4647,25 +4647,25 @@
scoped_ptr<spdy::SpdyFrame> body(ConstructSpdyBodyFrame(1, true));
MockWrite writes_SPDYNPN[] = {
- MockWrite(false, kConnect443, arraysize(kConnect443) - 1, 0),
+ MockWrite(SYNCHRONOUS, kConnect443, arraysize(kConnect443) - 1, 0),
CreateMockWrite(*req, 2),
};
MockRead reads_SPDYNPN[] = {
- MockRead(false, kHTTP200, arraysize(kHTTP200) - 1, 1),
+ MockRead(SYNCHRONOUS, kHTTP200, arraysize(kHTTP200) - 1, 1),
CreateMockRead(*resp, 3),
CreateMockRead(*body.get(), 4),
- MockRead(true, 0, 0, 5),
+ MockRead(ASYNC, 0, 0, 5),
};
MockWrite writes_SPDYSSL[] = {
- MockWrite(false, kConnect80, arraysize(kConnect80) - 1, 0),
+ MockWrite(SYNCHRONOUS, kConnect80, arraysize(kConnect80) - 1, 0),
CreateMockWrite(*req, 2),
};
MockRead reads_SPDYSSL[] = {
- MockRead(false, kHTTP200, arraysize(kHTTP200) - 1, 1),
+ MockRead(SYNCHRONOUS, kHTTP200, arraysize(kHTTP200) - 1, 1),
CreateMockRead(*resp, 3),
CreateMockRead(*body.get(), 4),
- MockRead(true, 0, 0, 5),
+ MockRead(ASYNC, 0, 0, 5),
};
MockWrite writes_SPDYNOSSL[] = {
@@ -4675,7 +4675,7 @@
MockRead reads_SPDYNOSSL[] = {
CreateMockRead(*resp, 1),
CreateMockRead(*body.get(), 2),
- MockRead(true, 0, 0, 3),
+ MockRead(ASYNC, 0, 0, 3),
};
scoped_ptr<OrderedSocketData> data;
@@ -4755,8 +4755,8 @@
MockRead reads[] = {
CreateMockRead(*resp, 2),
CreateMockRead(*body, 3),
- MockRead(true, ERR_IO_PENDING, 4), // Force a pause
- MockRead(true, 0, 5) // EOF
+ MockRead(ASYNC, ERR_IO_PENDING, 4), // Force a pause
+ MockRead(ASYNC, 0, 5) // EOF
};
scoped_ptr<OrderedSocketData> data(
new OrderedSocketData(reads, arraysize(reads),
@@ -4806,14 +4806,14 @@
scoped_ptr<spdy::SpdyFrame> body2(ConstructSpdyBodyFrame(1, true));
MockWrite writes_SPDYNPN[] = {
- MockWrite(false, kConnect443, arraysize(kConnect443) - 1, 0),
+ MockWrite(SYNCHRONOUS, kConnect443, arraysize(kConnect443) - 1, 0),
CreateMockWrite(*req2, 2),
};
MockRead reads_SPDYNPN[] = {
- MockRead(false, kHTTP200, arraysize(kHTTP200) - 1, 1),
+ MockRead(SYNCHRONOUS, kHTTP200, arraysize(kHTTP200) - 1, 1),
CreateMockRead(*resp2, 3),
CreateMockRead(*body2, 4),
- MockRead(true, 0, 5) // EOF
+ MockRead(ASYNC, 0, 5) // EOF
};
MockWrite writes_SPDYNOSSL[] = {
@@ -4822,18 +4822,18 @@
MockRead reads_SPDYNOSSL[] = {
CreateMockRead(*resp2, 1),
CreateMockRead(*body2, 2),
- MockRead(true, 0, 3) // EOF
+ MockRead(ASYNC, 0, 3) // EOF
};
MockWrite writes_SPDYSSL[] = {
- MockWrite(false, kConnect80, arraysize(kConnect80) - 1, 0),
+ MockWrite(SYNCHRONOUS, kConnect80, arraysize(kConnect80) - 1, 0),
CreateMockWrite(*req2, 2),
};
MockRead reads_SPDYSSL[] = {
- MockRead(false, kHTTP200, arraysize(kHTTP200) - 1, 1),
+ MockRead(SYNCHRONOUS, kHTTP200, arraysize(kHTTP200) - 1, 1),
CreateMockRead(*resp2, 3),
CreateMockRead(*body2, 4),
- MockRead(true, 0, 0, 5),
+ MockRead(ASYNC, 0, 0, 5),
};
scoped_ptr<OrderedSocketData> data_proxy;
@@ -4910,14 +4910,14 @@
MockRead reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, ERR_IO_PENDING),
- MockRead(true, ERR_CONNECTION_RESET),
+ MockRead(ASYNC, ERR_IO_PENDING),
+ MockRead(ASYNC, ERR_CONNECTION_RESET),
};
MockRead reads2[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
// This test has a couple of variants.
@@ -4996,7 +4996,7 @@
MockRead spdy_reads[] = {
CreateMockRead(*resp),
CreateMockRead(*body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -5015,7 +5015,7 @@
MockRead http_reads[] = {
MockRead("HTTP/1.1 200 OK\r\n\r\n"),
MockRead("hello from http"),
- MockRead(false, OK),
+ MockRead(SYNCHRONOUS, OK),
};
scoped_ptr<DelayedSocketData> data2(
new DelayedSocketData(1, http_reads, arraysize(http_reads),
@@ -5076,7 +5076,7 @@
CreateMockRead(*body_authentication, 3),
CreateMockRead(*resp_data, 5),
CreateMockRead(*body_data, 6),
- MockRead(true, 0, 7),
+ MockRead(ASYNC, 0, 7),
};
scoped_ptr<OrderedSocketData> data(
@@ -5179,10 +5179,10 @@
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
CreateMockRead(*stream2_headers, 4),
- CreateMockRead(*stream1_body, 5, false),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ CreateMockRead(*stream1_body, 5, SYNCHRONOUS),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 6),
- MockRead(true, ERR_IO_PENDING, 7), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 7), // Force a pause
};
HttpResponseInfo response;
@@ -5219,7 +5219,7 @@
scoped_ptr<spdy::SpdyFrame>
stream1_body(ConstructSpdyBodyFrame(1, true));
MockWrite writes[] = {
- CreateMockWrite(*stream1_syn, 0, false),
+ CreateMockWrite(*stream1_syn, 0, SYNCHRONOUS),
};
static const char* const kInitialHeaders[] = {
@@ -5264,9 +5264,9 @@
CreateMockRead(*stream2_syn, 2),
CreateMockRead(*stream1_body, 3),
CreateMockRead(*stream2_headers, 4),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 5),
- MockRead(true, 0, 5), // EOF
+ MockRead(ASYNC, 0, 5), // EOF
};
HttpResponseInfo response;
@@ -5356,7 +5356,7 @@
scoped_ptr<spdy::SpdyFrame>
stream1_body(ConstructSpdyBodyFrame(1, true));
MockWrite writes[] = {
- CreateMockWrite(*stream1_syn, 0, false),
+ CreateMockWrite(*stream1_syn, 0, SYNCHRONOUS),
};
static const char* const kInitialHeaders[] = {
@@ -5415,9 +5415,9 @@
CreateMockRead(*stream1_body, 3),
CreateMockRead(*stream2_headers1, 4),
CreateMockRead(*stream2_headers2, 5),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 6),
- MockRead(true, 0, 6), // EOF
+ MockRead(ASYNC, 0, 6), // EOF
};
HttpResponseInfo response;
@@ -5544,7 +5544,7 @@
CreateMockRead(*stream1_reply),
CreateMockRead(*stream1_headers),
CreateMockRead(*stream1_body),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -5602,7 +5602,7 @@
CreateMockRead(*stream1_body),
CreateMockRead(*stream1_headers),
CreateMockRead(*stream1_body2),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -5660,7 +5660,7 @@
CreateMockRead(*stream1_body),
CreateMockRead(*stream1_headers),
CreateMockRead(*stream1_body2),
- MockRead(true, 0, 0) // EOF
+ MockRead(ASYNC, 0, 0) // EOF
};
scoped_ptr<DelayedSocketData> data(
@@ -5734,10 +5734,10 @@
MockRead reads[] = {
CreateMockRead(*stream1_reply, 2),
CreateMockRead(*stream2_syn, 3),
- CreateMockRead(*stream1_body, 5, false),
- MockRead(true, reinterpret_cast<const char*>(kPushBodyFrame),
+ CreateMockRead(*stream1_body, 5, SYNCHRONOUS),
+ MockRead(ASYNC, reinterpret_cast<const char*>(kPushBodyFrame),
arraysize(kPushBodyFrame), 6),
- MockRead(true, ERR_IO_PENDING, 7), // Force a pause
+ MockRead(ASYNC, ERR_IO_PENDING, 7), // Force a pause
};
HttpResponseInfo response;
@@ -5802,7 +5802,7 @@
CreateMockRead(*refused, 2),
CreateMockRead(*resp, 4),
CreateMockRead(*body, 5),
- MockRead(true, 0, 6) // EOF
+ MockRead(ASYNC, 0, 6) // EOF
};
scoped_ptr<OrderedSocketData> data(

Powered by Google App Engine
This is Rietveld 408576698