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/socket/transport_client_socket_pool.h" | 5 #include "net/socket/transport_client_socket_pool.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "base/callback.h" | 9 #include "base/callback.h" |
10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
(...skipping 447 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
458 public: | 458 public: |
459 RequestSocketCallback(ClientSocketHandle* handle, | 459 RequestSocketCallback(ClientSocketHandle* handle, |
460 TransportClientSocketPool* pool) | 460 TransportClientSocketPool* pool) |
461 : handle_(handle), | 461 : handle_(handle), |
462 pool_(pool), | 462 pool_(pool), |
463 within_callback_(false), | 463 within_callback_(false), |
464 callback_(base::Bind(&RequestSocketCallback::OnComplete, | 464 callback_(base::Bind(&RequestSocketCallback::OnComplete, |
465 base::Unretained(this))) { | 465 base::Unretained(this))) { |
466 } | 466 } |
467 | 467 |
468 virtual ~RequestSocketCallback() {} | 468 ~RequestSocketCallback() override {} |
469 | 469 |
470 const CompletionCallback& callback() const { return callback_; } | 470 const CompletionCallback& callback() const { return callback_; } |
471 | 471 |
472 private: | 472 private: |
473 void OnComplete(int result) { | 473 void OnComplete(int result) { |
474 SetResult(result); | 474 SetResult(result); |
475 ASSERT_EQ(OK, result); | 475 ASSERT_EQ(OK, result); |
476 | 476 |
477 if (!within_callback_) { | 477 if (!within_callback_) { |
478 // Don't allow reuse of the socket. Disconnect it and then release it and | 478 // Don't allow reuse of the socket. Disconnect it and then release it and |
(...skipping 624 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1103 handle.socket()->GetLocalAddress(&endpoint); | 1103 handle.socket()->GetLocalAddress(&endpoint); |
1104 EXPECT_EQ(kIPv6AddressSize, endpoint.address().size()); | 1104 EXPECT_EQ(kIPv6AddressSize, endpoint.address().size()); |
1105 EXPECT_EQ(1, client_socket_factory_.allocation_count()); | 1105 EXPECT_EQ(1, client_socket_factory_.allocation_count()); |
1106 // Verify that TCP FastOpen was not turned on for the socket. | 1106 // Verify that TCP FastOpen was not turned on for the socket. |
1107 EXPECT_FALSE(handle.socket()->UsingTCPFastOpen()); | 1107 EXPECT_FALSE(handle.socket()->UsingTCPFastOpen()); |
1108 } | 1108 } |
1109 | 1109 |
1110 } // namespace | 1110 } // namespace |
1111 | 1111 |
1112 } // namespace net | 1112 } // namespace net |
OLD | NEW |