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 <string> | 5 #include <string> |
6 #include <vector> | 6 #include <vector> |
7 | 7 |
8 #include "base/memory/scoped_ptr.h" | 8 #include "base/memory/scoped_ptr.h" |
9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/strings/utf_string_conversions.h" | 10 #include "base/strings/utf_string_conversions.h" |
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
86 request_succeeded_called_(false) {} | 86 request_succeeded_called_(false) {} |
87 | 87 |
88 virtual bool hasSelector() const OVERRIDE { | 88 virtual bool hasSelector() const OVERRIDE { |
89 return has_selector_; | 89 return has_selector_; |
90 } | 90 } |
91 virtual blink::WebMediaStreamTrack component() const OVERRIDE { | 91 virtual blink::WebMediaStreamTrack component() const OVERRIDE { |
92 return component_; | 92 return component_; |
93 } | 93 } |
94 virtual scoped_refptr<LocalRTCStatsResponse> createResponse() OVERRIDE { | 94 virtual scoped_refptr<LocalRTCStatsResponse> createResponse() OVERRIDE { |
95 DCHECK(!response_.get()); | 95 DCHECK(!response_.get()); |
96 response_ = new rtc::RefCountedObject<MockRTCStatsResponse>(); | 96 response_ = new talk_base::RefCountedObject<MockRTCStatsResponse>(); |
97 return response_; | 97 return response_; |
98 } | 98 } |
99 | 99 |
100 virtual void requestSucceeded(const LocalRTCStatsResponse* response) | 100 virtual void requestSucceeded(const LocalRTCStatsResponse* response) |
101 OVERRIDE { | 101 OVERRIDE { |
102 EXPECT_EQ(response, response_.get()); | 102 EXPECT_EQ(response, response_.get()); |
103 request_succeeded_called_ = true; | 103 request_succeeded_called_ = true; |
104 } | 104 } |
105 | 105 |
106 // Function for setting whether or not a selector is available. | 106 // Function for setting whether or not a selector is available. |
(...skipping 345 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
452 EXPECT_EQ( | 452 EXPECT_EQ( |
453 1u, | 453 1u, |
454 mock_peer_connection_->local_streams()->at(0)->GetAudioTracks().size()); | 454 mock_peer_connection_->local_streams()->at(0)->GetAudioTracks().size()); |
455 EXPECT_EQ( | 455 EXPECT_EQ( |
456 1u, | 456 1u, |
457 mock_peer_connection_->local_streams()->at(0)->GetVideoTracks().size()); | 457 mock_peer_connection_->local_streams()->at(0)->GetVideoTracks().size()); |
458 } | 458 } |
459 | 459 |
460 TEST_F(RTCPeerConnectionHandlerTest, GetStatsNoSelector) { | 460 TEST_F(RTCPeerConnectionHandlerTest, GetStatsNoSelector) { |
461 scoped_refptr<MockRTCStatsRequest> request( | 461 scoped_refptr<MockRTCStatsRequest> request( |
462 new rtc::RefCountedObject<MockRTCStatsRequest>()); | 462 new talk_base::RefCountedObject<MockRTCStatsRequest>()); |
463 pc_handler_->getStats(request.get()); | 463 pc_handler_->getStats(request.get()); |
464 // Note that callback gets executed synchronously by mock. | 464 // Note that callback gets executed synchronously by mock. |
465 ASSERT_TRUE(request->result()); | 465 ASSERT_TRUE(request->result()); |
466 EXPECT_LT(1, request->result()->report_count()); | 466 EXPECT_LT(1, request->result()->report_count()); |
467 } | 467 } |
468 | 468 |
469 TEST_F(RTCPeerConnectionHandlerTest, GetStatsAfterClose) { | 469 TEST_F(RTCPeerConnectionHandlerTest, GetStatsAfterClose) { |
470 scoped_refptr<MockRTCStatsRequest> request( | 470 scoped_refptr<MockRTCStatsRequest> request( |
471 new rtc::RefCountedObject<MockRTCStatsRequest>()); | 471 new talk_base::RefCountedObject<MockRTCStatsRequest>()); |
472 pc_handler_->stop(); | 472 pc_handler_->stop(); |
473 pc_handler_->getStats(request.get()); | 473 pc_handler_->getStats(request.get()); |
474 // Note that callback gets executed synchronously by mock. | 474 // Note that callback gets executed synchronously by mock. |
475 ASSERT_TRUE(request->result()); | 475 ASSERT_TRUE(request->result()); |
476 EXPECT_LT(1, request->result()->report_count()); | 476 EXPECT_LT(1, request->result()->report_count()); |
477 } | 477 } |
478 | 478 |
479 TEST_F(RTCPeerConnectionHandlerTest, GetStatsWithLocalSelector) { | 479 TEST_F(RTCPeerConnectionHandlerTest, GetStatsWithLocalSelector) { |
480 blink::WebMediaStream local_stream( | 480 blink::WebMediaStream local_stream( |
481 CreateLocalMediaStream("local_stream")); | 481 CreateLocalMediaStream("local_stream")); |
482 blink::WebMediaConstraints constraints; | 482 blink::WebMediaConstraints constraints; |
483 pc_handler_->addStream(local_stream, constraints); | 483 pc_handler_->addStream(local_stream, constraints); |
484 blink::WebVector<blink::WebMediaStreamTrack> tracks; | 484 blink::WebVector<blink::WebMediaStreamTrack> tracks; |
485 local_stream.audioTracks(tracks); | 485 local_stream.audioTracks(tracks); |
486 ASSERT_LE(1ul, tracks.size()); | 486 ASSERT_LE(1ul, tracks.size()); |
487 | 487 |
488 scoped_refptr<MockRTCStatsRequest> request( | 488 scoped_refptr<MockRTCStatsRequest> request( |
489 new rtc::RefCountedObject<MockRTCStatsRequest>()); | 489 new talk_base::RefCountedObject<MockRTCStatsRequest>()); |
490 request->setSelector(tracks[0]); | 490 request->setSelector(tracks[0]); |
491 pc_handler_->getStats(request.get()); | 491 pc_handler_->getStats(request.get()); |
492 EXPECT_EQ(1, request->result()->report_count()); | 492 EXPECT_EQ(1, request->result()->report_count()); |
493 } | 493 } |
494 | 494 |
495 TEST_F(RTCPeerConnectionHandlerTest, GetStatsWithRemoteSelector) { | 495 TEST_F(RTCPeerConnectionHandlerTest, GetStatsWithRemoteSelector) { |
496 scoped_refptr<webrtc::MediaStreamInterface> stream( | 496 scoped_refptr<webrtc::MediaStreamInterface> stream( |
497 AddRemoteMockMediaStream("remote_stream", "video", "audio")); | 497 AddRemoteMockMediaStream("remote_stream", "video", "audio")); |
498 pc_handler_->OnAddStream(stream.get()); | 498 pc_handler_->OnAddStream(stream.get()); |
499 const blink::WebMediaStream& remote_stream = mock_client_->remote_stream(); | 499 const blink::WebMediaStream& remote_stream = mock_client_->remote_stream(); |
500 | 500 |
501 blink::WebVector<blink::WebMediaStreamTrack> tracks; | 501 blink::WebVector<blink::WebMediaStreamTrack> tracks; |
502 remote_stream.audioTracks(tracks); | 502 remote_stream.audioTracks(tracks); |
503 ASSERT_LE(1ul, tracks.size()); | 503 ASSERT_LE(1ul, tracks.size()); |
504 | 504 |
505 scoped_refptr<MockRTCStatsRequest> request( | 505 scoped_refptr<MockRTCStatsRequest> request( |
506 new rtc::RefCountedObject<MockRTCStatsRequest>()); | 506 new talk_base::RefCountedObject<MockRTCStatsRequest>()); |
507 request->setSelector(tracks[0]); | 507 request->setSelector(tracks[0]); |
508 pc_handler_->getStats(request.get()); | 508 pc_handler_->getStats(request.get()); |
509 EXPECT_EQ(1, request->result()->report_count()); | 509 EXPECT_EQ(1, request->result()->report_count()); |
510 } | 510 } |
511 | 511 |
512 TEST_F(RTCPeerConnectionHandlerTest, GetStatsWithBadSelector) { | 512 TEST_F(RTCPeerConnectionHandlerTest, GetStatsWithBadSelector) { |
513 // The setup is the same as GetStatsWithLocalSelector, but the stream is not | 513 // The setup is the same as GetStatsWithLocalSelector, but the stream is not |
514 // added to the PeerConnection. | 514 // added to the PeerConnection. |
515 blink::WebMediaStream local_stream( | 515 blink::WebMediaStream local_stream( |
516 CreateLocalMediaStream("local_stream_2")); | 516 CreateLocalMediaStream("local_stream_2")); |
517 blink::WebMediaConstraints constraints; | 517 blink::WebMediaConstraints constraints; |
518 blink::WebVector<blink::WebMediaStreamTrack> tracks; | 518 blink::WebVector<blink::WebMediaStreamTrack> tracks; |
519 | 519 |
520 local_stream.audioTracks(tracks); | 520 local_stream.audioTracks(tracks); |
521 blink::WebMediaStreamTrack component = tracks[0]; | 521 blink::WebMediaStreamTrack component = tracks[0]; |
522 mock_peer_connection_->SetGetStatsResult(false); | 522 mock_peer_connection_->SetGetStatsResult(false); |
523 | 523 |
524 scoped_refptr<MockRTCStatsRequest> request( | 524 scoped_refptr<MockRTCStatsRequest> request( |
525 new rtc::RefCountedObject<MockRTCStatsRequest>()); | 525 new talk_base::RefCountedObject<MockRTCStatsRequest>()); |
526 request->setSelector(component); | 526 request->setSelector(component); |
527 pc_handler_->getStats(request.get()); | 527 pc_handler_->getStats(request.get()); |
528 EXPECT_EQ(0, request->result()->report_count()); | 528 EXPECT_EQ(0, request->result()->report_count()); |
529 } | 529 } |
530 | 530 |
531 TEST_F(RTCPeerConnectionHandlerTest, OnSignalingChange) { | 531 TEST_F(RTCPeerConnectionHandlerTest, OnSignalingChange) { |
532 testing::InSequence sequence; | 532 testing::InSequence sequence; |
533 | 533 |
534 webrtc::PeerConnectionInterface::SignalingState new_state = | 534 webrtc::PeerConnectionInterface::SignalingState new_state = |
535 webrtc::PeerConnectionInterface::kHaveRemoteOffer; | 535 webrtc::PeerConnectionInterface::kHaveRemoteOffer; |
(...skipping 320 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
856 EXPECT_CALL(*mock_tracker_.get(), | 856 EXPECT_CALL(*mock_tracker_.get(), |
857 TrackCreateDTMFSender(pc_handler_.get(), | 857 TrackCreateDTMFSender(pc_handler_.get(), |
858 testing::Ref(tracks[0]))); | 858 testing::Ref(tracks[0]))); |
859 | 859 |
860 scoped_ptr<blink::WebRTCDTMFSenderHandler> sender( | 860 scoped_ptr<blink::WebRTCDTMFSenderHandler> sender( |
861 pc_handler_->createDTMFSender(tracks[0])); | 861 pc_handler_->createDTMFSender(tracks[0])); |
862 EXPECT_TRUE(sender.get()); | 862 EXPECT_TRUE(sender.get()); |
863 } | 863 } |
864 | 864 |
865 } // namespace content | 865 } // namespace content |
OLD | NEW |