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

Side by Side Diff: net/http/http_network_transaction_unittest.cc

Issue 1326503003: Added a net::BidirectionalStream to expose a bidirectional streaming interface (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Make the wrapper class own the stream Created 5 years, 2 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 unified diff | Download patch
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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 <math.h> // ceil 7 #include <math.h> // ceil
8 #include <stdarg.h> 8 #include <stdarg.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
(...skipping 14114 matching lines...) Expand 10 before | Expand all | Expand 10 after
14125 RequestPriority priority, 14125 RequestPriority priority,
14126 const SSLConfig& server_ssl_config, 14126 const SSLConfig& server_ssl_config,
14127 const SSLConfig& proxy_ssl_config, 14127 const SSLConfig& proxy_ssl_config,
14128 HttpStreamRequest::Delegate* delegate, 14128 HttpStreamRequest::Delegate* delegate,
14129 const BoundNetLog& net_log) override { 14129 const BoundNetLog& net_log) override {
14130 FakeStreamRequest* fake_request = new FakeStreamRequest(priority, delegate); 14130 FakeStreamRequest* fake_request = new FakeStreamRequest(priority, delegate);
14131 last_stream_request_ = fake_request->AsWeakPtr(); 14131 last_stream_request_ = fake_request->AsWeakPtr();
14132 return fake_request; 14132 return fake_request;
14133 } 14133 }
14134 14134
14135 HttpStreamRequest* RequestBidirectionalStream(
14136 const HttpRequestInfo& info,
14137 RequestPriority priority,
14138 const SSLConfig& server_ssl_config,
14139 const SSLConfig& proxy_ssl_config,
14140 HttpStreamRequest::Delegate* delegate,
14141 const BoundNetLog& net_log) override {
14142 NOTREACHED();
14143 return nullptr;
14144 }
14145
14135 HttpStreamRequest* RequestWebSocketHandshakeStream( 14146 HttpStreamRequest* RequestWebSocketHandshakeStream(
14136 const HttpRequestInfo& info, 14147 const HttpRequestInfo& info,
14137 RequestPriority priority, 14148 RequestPriority priority,
14138 const SSLConfig& server_ssl_config, 14149 const SSLConfig& server_ssl_config,
14139 const SSLConfig& proxy_ssl_config, 14150 const SSLConfig& proxy_ssl_config,
14140 HttpStreamRequest::Delegate* delegate, 14151 HttpStreamRequest::Delegate* delegate,
14141 WebSocketHandshakeStreamBase::CreateHelper* create_helper, 14152 WebSocketHandshakeStreamBase::CreateHelper* create_helper,
14142 const BoundNetLog& net_log) override { 14153 const BoundNetLog& net_log) override {
14143 FakeStreamRequest* fake_request = 14154 FakeStreamRequest* fake_request =
14144 new FakeStreamRequest(priority, delegate, create_helper); 14155 new FakeStreamRequest(priority, delegate, create_helper);
(...skipping 1221 matching lines...) Expand 10 before | Expand all | Expand 10 after
15366 std::string response_data; 15377 std::string response_data;
15367 EXPECT_EQ(OK, ReadTransaction(trans.get(), &response_data)); 15378 EXPECT_EQ(OK, ReadTransaction(trans.get(), &response_data));
15368 15379
15369 EXPECT_EQ(CountWriteBytes(data_writes, arraysize(data_writes)), 15380 EXPECT_EQ(CountWriteBytes(data_writes, arraysize(data_writes)),
15370 trans->GetTotalSentBytes()); 15381 trans->GetTotalSentBytes());
15371 EXPECT_EQ(CountReadBytes(data_reads, arraysize(data_reads)), 15382 EXPECT_EQ(CountReadBytes(data_reads, arraysize(data_reads)),
15372 trans->GetTotalReceivedBytes()); 15383 trans->GetTotalReceivedBytes());
15373 } 15384 }
15374 15385
15375 } // namespace net 15386 } // namespace net
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698