Chromium Code Reviews| Index: content/renderer/media/rtc_peer_connection_handler.cc |
| diff --git a/content/renderer/media/rtc_peer_connection_handler.cc b/content/renderer/media/rtc_peer_connection_handler.cc |
| index 3240a7a2fbe2e9e97bb3f0bade3ce22d159fb618..554a3267124ec110e76b6b489b4459821efaa132 100644 |
| --- a/content/renderer/media/rtc_peer_connection_handler.cc |
| +++ b/content/renderer/media/rtc_peer_connection_handler.cc |
| @@ -29,6 +29,7 @@ |
| #include "content/renderer/media/rtc_data_channel_handler.h" |
| #include "content/renderer/media/rtc_dtmf_sender_handler.h" |
| #include "content/renderer/media/webrtc/peer_connection_dependency_factory.h" |
| +#include "content/renderer/media/webrtc/rtc_rtp_receiver.h" |
| #include "content/renderer/media/webrtc/rtc_stats.h" |
| #include "content/renderer/media/webrtc/webrtc_media_stream_adapter.h" |
| #include "content/renderer/media/webrtc_audio_device_impl.h" |
| @@ -1634,6 +1635,30 @@ void RTCPeerConnectionHandler::getStats( |
| base::Passed(&callback))); |
| } |
| +blink::WebVector<std::unique_ptr<blink::WebRTCRtpReceiver>> |
| +RTCPeerConnectionHandler::getReceivers() { |
| + DCHECK(thread_checker_.CalledOnValidThread()); |
| + TRACE_EVENT0("webrtc", "RTCPeerConnectionHandler::getReceivers"); |
| + |
| + std::vector<rtc::scoped_refptr<webrtc::RtpReceiverInterface>> |
| + webrtc_receivers = native_peer_connection_->GetReceivers(); |
| + blink::WebVector<std::unique_ptr<blink::WebRTCRtpReceiver>> web_receivers( |
| + webrtc_receivers.size()); |
| + for (size_t i = 0; i < webrtc_receivers.size(); ++i) { |
| + rtc::scoped_refptr<webrtc::MediaStreamTrackInterface> webrtc_track = |
| + webrtc_receivers[i]->track(); |
| + DCHECK(webrtc_track); |
| + if (webrtc_track->kind() == webrtc::MediaStreamTrackInterface::kAudioKind) { |
| + web_receivers[i].reset(new RTCRtpReceiver( |
|
Taylor_Brandstetter
2017/03/24 18:13:07
If I understand correctly: this method will create
hbos_chromium
2017/03/27 14:55:19
You understand correctly.
There are comments in W
|
| + webrtc_receivers[i].get(), GetRemoteAudioTrack(webrtc_track->id()))); |
| + } else { |
| + web_receivers[i].reset(new RTCRtpReceiver( |
| + webrtc_receivers[i].get(), GetRemoteVideoTrack(webrtc_track->id()))); |
| + } |
| + } |
| + return web_receivers; |
| +} |
| + |
| void RTCPeerConnectionHandler::CloseClientPeerConnection() { |
| DCHECK(thread_checker_.CalledOnValidThread()); |
| if (!is_closed_) |
| @@ -1994,6 +2019,32 @@ void RTCPeerConnectionHandler::RunSynchronousClosureOnSignalingThread( |
| } |
| } |
| +blink::WebMediaStreamTrack RTCPeerConnectionHandler::GetRemoteAudioTrack( |
| + const std::string& track_id) const { |
| + DCHECK(thread_checker_.CalledOnValidThread()); |
| + blink::WebString id = blink::WebString::fromUTF8(track_id); |
| + for (const auto& remote_stream_pair : remote_streams_) { |
|
Taylor_Brandstetter
2017/03/24 18:13:07
May be a corner case, but someone could remove the
hbos_chromium
2017/03/27 14:55:19
The case of adding or removing tracks to streams i
Taylor_Brandstetter
2017/03/27 21:39:01
Sounds like a reasonable plan. I'm happy as long a
|
| + blink::WebMediaStreamTrack web_track = |
| + remote_stream_pair.second->webkit_stream().getAudioTrack(id); |
| + if (!web_track.isNull()) |
| + return web_track; |
| + } |
| + return blink::WebMediaStreamTrack(); |
| +} |
| + |
| +blink::WebMediaStreamTrack RTCPeerConnectionHandler::GetRemoteVideoTrack( |
| + const std::string& track_id) const { |
| + DCHECK(thread_checker_.CalledOnValidThread()); |
| + blink::WebString id = blink::WebString::fromUTF8(track_id); |
| + for (const auto& remote_stream_pair : remote_streams_) { |
| + blink::WebMediaStreamTrack web_track = |
| + remote_stream_pair.second->webkit_stream().getVideoTrack(id); |
| + if (!web_track.isNull()) |
| + return web_track; |
| + } |
| + return blink::WebMediaStreamTrack(); |
| +} |
| + |
| void RTCPeerConnectionHandler::ReportICEState( |
| webrtc::PeerConnectionInterface::IceConnectionState new_state) { |
| DCHECK(thread_checker_.CalledOnValidThread()); |