Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2008)

Unified Diff: content/renderer/media/rtc_peer_connection_handler.cc

Issue 2759953003: Interface RTCRtpReceiver and RTCPeerConnection.getReceivers() added. (Closed)
Patch Set: removeInactiveReceivers in didRemoveRemoteStream Created 3 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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());

Powered by Google App Engine
This is Rietveld 408576698