| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/http/http_network_transaction.h" | 5 #include "net/http/http_network_transaction.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 4098 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4109 MockWrite writes[] = { CreateMockWrite(*req) }; | 4109 MockWrite writes[] = { CreateMockWrite(*req) }; |
| 4110 | 4110 |
| 4111 scoped_ptr<SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); | 4111 scoped_ptr<SpdyFrame> resp(ConstructSpdyGetSynReply(NULL, 0, 1)); |
| 4112 scoped_ptr<SpdyFrame> body(ConstructSpdyBodyFrame(1, true)); | 4112 scoped_ptr<SpdyFrame> body(ConstructSpdyBodyFrame(1, true)); |
| 4113 MockRead reads[] = { | 4113 MockRead reads[] = { |
| 4114 CreateMockRead(*resp), | 4114 CreateMockRead(*resp), |
| 4115 CreateMockRead(*body), | 4115 CreateMockRead(*body), |
| 4116 MockRead(ASYNC, 0, 0) // EOF | 4116 MockRead(ASYNC, 0, 0) // EOF |
| 4117 }; | 4117 }; |
| 4118 | 4118 |
| 4119 net::CapturingBoundNetLog log(net::CapturingNetLog::kUnbounded); | 4119 CapturingBoundNetLog log; |
| 4120 | 4120 |
| 4121 scoped_ptr<DelayedSocketData> data( | 4121 scoped_ptr<DelayedSocketData> data( |
| 4122 new DelayedSocketData(1, reads, arraysize(reads), | 4122 new DelayedSocketData(1, reads, arraysize(reads), |
| 4123 writes, arraysize(writes))); | 4123 writes, arraysize(writes))); |
| 4124 NormalSpdyTransactionHelper helper(CreateGetRequestWithUserAgent(), | 4124 NormalSpdyTransactionHelper helper(CreateGetRequestWithUserAgent(), |
| 4125 log.bound(), GetParam(), NULL); | 4125 log.bound(), GetParam(), NULL); |
| 4126 helper.RunToCompletion(data.get()); | 4126 helper.RunToCompletion(data.get()); |
| 4127 TransactionHelperResult out = helper.output(); | 4127 TransactionHelperResult out = helper.output(); |
| 4128 EXPECT_EQ(OK, out.rv); | 4128 EXPECT_EQ(OK, out.rv); |
| 4129 EXPECT_EQ("HTTP/1.1 200 OK", out.status_line); | 4129 EXPECT_EQ("HTTP/1.1 200 OK", out.status_line); |
| (...skipping 2094 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 6224 // And now we can allow everything else to run to completion. | 6224 // And now we can allow everything else to run to completion. |
| 6225 data->SetStop(10); | 6225 data->SetStop(10); |
| 6226 data->Run(); | 6226 data->Run(); |
| 6227 EXPECT_EQ(OK, callback2.WaitForResult()); | 6227 EXPECT_EQ(OK, callback2.WaitForResult()); |
| 6228 EXPECT_EQ(OK, callback3.WaitForResult()); | 6228 EXPECT_EQ(OK, callback3.WaitForResult()); |
| 6229 | 6229 |
| 6230 helper.VerifyDataConsumed(); | 6230 helper.VerifyDataConsumed(); |
| 6231 } | 6231 } |
| 6232 | 6232 |
| 6233 } // namespace net | 6233 } // namespace net |
| OLD | NEW |