Index: net/http/http_network_transaction_unittest.cc |
diff --git a/net/http/http_network_transaction_unittest.cc b/net/http/http_network_transaction_unittest.cc |
index cc7f6106e88a5efc4b9d15d21e2e2c87d8feb81d..aba2828919941d86b684290b57785fc5e65d5e6f 100644 |
--- a/net/http/http_network_transaction_unittest.cc |
+++ b/net/http/http_network_transaction_unittest.cc |
@@ -3691,22 +3691,22 @@ |
spdy_util_.ConstructSpdyWindowUpdate(1, wrapped_body->size())); |
MockWrite spdy_writes[] = { |
- CreateMockWrite(*connect, 0), |
- CreateMockWrite(*wrapped_get, 2), |
- CreateMockWrite(*window_update_get_resp, 6), |
+ CreateMockWrite(*connect, 1), |
+ CreateMockWrite(*wrapped_get, 3), |
+ CreateMockWrite(*window_update_get_resp, 5), |
CreateMockWrite(*window_update_body, 7), |
}; |
MockRead spdy_reads[] = { |
- CreateMockRead(*conn_resp, 1, ASYNC), |
- MockRead(ASYNC, ERR_IO_PENDING, 3), |
+ CreateMockRead(*conn_resp, 2, ASYNC), |
CreateMockRead(*wrapped_get_resp, 4, ASYNC), |
- CreateMockRead(*wrapped_body, 5, ASYNC), |
+ CreateMockRead(*wrapped_body, 6, ASYNC), |
MockRead(ASYNC, 0, 8), |
}; |
- SequencedSocketData spdy_data(spdy_reads, arraysize(spdy_reads), spdy_writes, |
- arraysize(spdy_writes)); |
+ OrderedSocketData spdy_data( |
+ spdy_reads, arraysize(spdy_reads), |
+ spdy_writes, arraysize(spdy_writes)); |
session_deps_.socket_factory->AddSocketDataProvider(&spdy_data); |
SSLSocketDataProvider ssl(ASYNC, OK); |
@@ -3721,10 +3721,6 @@ |
int rv = trans->Start(&request, callback1.callback(), log.bound()); |
EXPECT_EQ(ERR_IO_PENDING, rv); |
- // Allow the SpdyProxyClientSocket's write callback to complete. |
- base::MessageLoop::current()->RunUntilIdle(); |
- // Now allow the read of the response to complete. |
- spdy_data.CompleteRead(); |
rv = callback1.WaitForResult(); |
EXPECT_EQ(OK, rv); |
@@ -11889,8 +11885,8 @@ |
reads.push_back(MockRead(ASYNC, OK, 3)); |
} |
- SequencedSocketData data(vector_as_array(&reads), reads.size(), |
- vector_as_array(&writes), writes.size()); |
+ OrderedSocketData data(vector_as_array(&reads), reads.size(), |
+ vector_as_array(&writes), writes.size()); |
session_deps_.socket_factory->AddSocketDataProvider(&data); |
// Connection to the origin fails. |
@@ -11935,10 +11931,6 @@ |
int rv = trans1->Start(&request1, callback1.callback(), BoundNetLog()); |
EXPECT_EQ(ERR_IO_PENDING, rv); |
- base::MessageLoop::current()->RunUntilIdle(); |
- if (data.IsReadPaused()) { |
- data.CompleteRead(); |
- } |
rv = callback1.WaitForResult(); |
if (valid) { |
EXPECT_EQ(OK, rv); |