OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "base/bind.h" | 5 #include "base/bind.h" |
6 #include "base/file_path.h" | 6 #include "base/file_path.h" |
7 #include "base/file_util.h" | 7 #include "base/file_util.h" |
8 #include "base/path_service.h" | 8 #include "base/path_service.h" |
9 #include "base/time.h" | 9 #include "base/time.h" |
10 #include "base/test/test_timeouts.h" | 10 #include "base/test/test_timeouts.h" |
(...skipping 363 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
374 host_session_->CreateStreamChannel( | 374 host_session_->CreateStreamChannel( |
375 kChannelName, | 375 kChannelName, |
376 base::Bind(&TCPChannelTester::OnChannelReady, | 376 base::Bind(&TCPChannelTester::OnChannelReady, |
377 base::Unretained(this), 0)); | 377 base::Unretained(this), 0)); |
378 client_session_->CreateStreamChannel( | 378 client_session_->CreateStreamChannel( |
379 kChannelName, | 379 kChannelName, |
380 base::Bind(&TCPChannelTester::OnChannelReady, | 380 base::Bind(&TCPChannelTester::OnChannelReady, |
381 base::Unretained(this), 1)); | 381 base::Unretained(this), 1)); |
382 } | 382 } |
383 | 383 |
384 void OnChannelReady(int id, const std::string name, | 384 void OnChannelReady(int id, net::StreamSocket* socket) { |
385 net::StreamSocket* socket) { | |
386 ASSERT_TRUE(socket); | 385 ASSERT_TRUE(socket); |
387 ASSERT_EQ(name, kChannelName); | |
388 if (!socket) { | 386 if (!socket) { |
389 Done(); | 387 Done(); |
390 return; | 388 return; |
391 } | 389 } |
392 | 390 |
393 DCHECK(id >= 0 && id < 2); | 391 DCHECK(id >= 0 && id < 2); |
394 sockets_[id].reset(socket); | 392 sockets_[id].reset(socket); |
395 | 393 |
396 if (sockets_[0].get() && sockets_[1].get()) { | 394 if (sockets_[0].get() && sockets_[1].get()) { |
397 InitBuffers(); | 395 InitBuffers(); |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
540 host_session_->CreateDatagramChannel( | 538 host_session_->CreateDatagramChannel( |
541 kChannelName, | 539 kChannelName, |
542 base::Bind(&UDPChannelTester::OnChannelReady, | 540 base::Bind(&UDPChannelTester::OnChannelReady, |
543 base::Unretained(this), 0)); | 541 base::Unretained(this), 0)); |
544 client_session_->CreateDatagramChannel( | 542 client_session_->CreateDatagramChannel( |
545 kChannelName, | 543 kChannelName, |
546 base::Bind(&UDPChannelTester::OnChannelReady, | 544 base::Bind(&UDPChannelTester::OnChannelReady, |
547 base::Unretained(this), 1)); | 545 base::Unretained(this), 1)); |
548 } | 546 } |
549 | 547 |
550 void OnChannelReady(int id, const std::string name, net::Socket* socket) { | 548 void OnChannelReady(int id, net::Socket* socket) { |
551 ASSERT_TRUE(socket); | 549 ASSERT_TRUE(socket); |
552 ASSERT_EQ(name, kChannelName); | |
553 if (!socket) { | 550 if (!socket) { |
554 Done(); | 551 Done(); |
555 return; | 552 return; |
556 } | 553 } |
557 | 554 |
558 DCHECK(id >= 0 && id < 2); | 555 DCHECK(id >= 0 && id < 2); |
559 sockets_[id].reset(socket); | 556 sockets_[id].reset(socket); |
560 | 557 |
561 if (sockets_[0].get() && sockets_[1].get()) { | 558 if (sockets_[0].get() && sockets_[1].get()) { |
562 InitBuffers(); | 559 InitBuffers(); |
(...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
779 ASSERT_TRUE(tester->WaitFinished()); | 776 ASSERT_TRUE(tester->WaitFinished()); |
780 LOG(INFO) << "Time for 500k bytes " | 777 LOG(INFO) << "Time for 500k bytes " |
781 << tester->GetElapsedTime().InMilliseconds() << " ms."; | 778 << tester->GetElapsedTime().InMilliseconds() << " ms."; |
782 | 779 |
783 // Connections must be closed while |tester| still exists. | 780 // Connections must be closed while |tester| still exists. |
784 CloseSessions(); | 781 CloseSessions(); |
785 } | 782 } |
786 | 783 |
787 } // namespace protocol | 784 } // namespace protocol |
788 } // namespace remoting | 785 } // namespace remoting |
OLD | NEW |