OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/spdy/bidirectional_stream_spdy_impl.h" | 5 #include "net/spdy/bidirectional_stream_spdy_impl.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/macros.h" | 10 #include "base/macros.h" |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
106 error_ = error; | 106 error_ = error; |
107 on_failed_called_ = true; | 107 on_failed_called_ = true; |
108 if (run_until_completion_) | 108 if (run_until_completion_) |
109 loop_->Quit(); | 109 loop_->Quit(); |
110 } | 110 } |
111 | 111 |
112 void Start(const BidirectionalStreamRequestInfo* request, | 112 void Start(const BidirectionalStreamRequestInfo* request, |
113 const BoundNetLog& net_log) { | 113 const BoundNetLog& net_log) { |
114 stream_->Start(request, net_log, | 114 stream_->Start(request, net_log, |
115 /*send_request_headers_automatically=*/false, this, | 115 /*send_request_headers_automatically=*/false, this, |
116 base::WrapUnique(new base::Timer(false, false))); | 116 base::MakeUnique<base::Timer>(false, false)); |
117 not_expect_callback_ = false; | 117 not_expect_callback_ = false; |
118 } | 118 } |
119 | 119 |
120 void SendData(IOBuffer* data, int length, bool end_of_stream) { | 120 void SendData(IOBuffer* data, int length, bool end_of_stream) { |
121 not_expect_callback_ = true; | 121 not_expect_callback_ = true; |
122 stream_->SendData(data, length, end_of_stream); | 122 stream_->SendData(data, length, end_of_stream); |
123 not_expect_callback_ = false; | 123 not_expect_callback_ = false; |
124 } | 124 } |
125 | 125 |
126 void SendvData(const std::vector<scoped_refptr<IOBuffer>>& data, | 126 void SendvData(const std::vector<scoped_refptr<IOBuffer>>& data, |
(...skipping 180 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
307 EXPECT_EQ(0, delegate->on_data_sent_count()); | 307 EXPECT_EQ(0, delegate->on_data_sent_count()); |
308 EXPECT_EQ(kProtoHTTP2, delegate->GetProtocol()); | 308 EXPECT_EQ(kProtoHTTP2, delegate->GetProtocol()); |
309 // BidirectionalStreamSpdyStreamJob does not count the bytes sent for |rst| | 309 // BidirectionalStreamSpdyStreamJob does not count the bytes sent for |rst| |
310 // because it is sent after SpdyStream::Delegate::OnClose is called. | 310 // because it is sent after SpdyStream::Delegate::OnClose is called. |
311 EXPECT_EQ(CountWriteBytes(writes, 1), delegate->GetTotalSentBytes()); | 311 EXPECT_EQ(CountWriteBytes(writes, 1), delegate->GetTotalSentBytes()); |
312 EXPECT_EQ(CountReadBytes(reads, arraysize(reads)), | 312 EXPECT_EQ(CountReadBytes(reads, arraysize(reads)), |
313 delegate->GetTotalReceivedBytes()); | 313 delegate->GetTotalReceivedBytes()); |
314 } | 314 } |
315 | 315 |
316 } // namespace net | 316 } // namespace net |
OLD | NEW |