| 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 talk_base::RefCountedObject<MockRTCStatsResponse>(); | 96 response_ = new rtc::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 talk_base::RefCountedObject<MockRTCStatsRequest>()); | 462 new rtc::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 talk_base::RefCountedObject<MockRTCStatsRequest>()); | 471 new rtc::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 talk_base::RefCountedObject<MockRTCStatsRequest>()); | 489 new rtc::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 talk_base::RefCountedObject<MockRTCStatsRequest>()); | 506 new rtc::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 talk_base::RefCountedObject<MockRTCStatsRequest>()); | 525 new rtc::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 |