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()); |