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

Unified Diff: webrtc/sdk/objc/Framework/Classes/RTCPeerConnection.mm

Issue 2513063003: Add the OnAddTrack callback for Objective-C wrapper.
Patch Set: replace the NSStringFromStdString with stringForStdString Created 3 years, 10 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
« no previous file with comments | « no previous file | webrtc/sdk/objc/Framework/Classes/RTCPeerConnection+Private.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webrtc/sdk/objc/Framework/Classes/RTCPeerConnection.mm
diff --git a/webrtc/sdk/objc/Framework/Classes/RTCPeerConnection.mm b/webrtc/sdk/objc/Framework/Classes/RTCPeerConnection.mm
index de7608c3b9941dd1acffc6b8e8dc0d5c52211379..e9428d3b9585d0184b412bd7ee7c1509dc85e122 100644
--- a/webrtc/sdk/objc/Framework/Classes/RTCPeerConnection.mm
+++ b/webrtc/sdk/objc/Framework/Classes/RTCPeerConnection.mm
@@ -27,6 +27,7 @@
#include "webrtc/api/jsepicecandidate.h"
#include "webrtc/base/checks.h"
+#include "webrtc/sdk/objc/Framework/Classes/helpers.h"
tkchin_webrtc 2017/02/24 20:54:15 you don't need this include, NSString+StdString ha
NSString * const kRTCPeerConnectionErrorDomain =
@"org.webrtc.RTCPeerConnection";
@@ -127,9 +128,8 @@ void PeerConnectionDelegateAdapter::OnSignalingChange(
void PeerConnectionDelegateAdapter::OnAddStream(
rtc::scoped_refptr<MediaStreamInterface> stream) {
- RTCMediaStream *mediaStream =
- [[RTCMediaStream alloc] initWithNativeMediaStream:stream];
RTCPeerConnection *peer_connection = peer_connection_;
+ RTCMediaStream *mediaStream = [peer_connection mediaStreamForNativeStream:stream];
[peer_connection.delegate peerConnection:peer_connection
didAddStream:mediaStream];
}
@@ -141,6 +141,7 @@ void PeerConnectionDelegateAdapter::OnRemoveStream(
RTCPeerConnection *peer_connection = peer_connection_;
[peer_connection.delegate peerConnection:peer_connection
didRemoveStream:mediaStream];
+ [peer_connection removeNativeMediaStream:stream];
}
void PeerConnectionDelegateAdapter::OnDataChannel(
@@ -200,6 +201,28 @@ void PeerConnectionDelegateAdapter::OnIceCandidatesRemoved(
didRemoveIceCandidates:ice_candidates];
}
+void PeerConnectionDelegateAdapter::OnAddTrack(
+ rtc::scoped_refptr<RtpReceiverInterface> receiver,
+ const std::vector<rtc::scoped_refptr<MediaStreamInterface>>& streams) {
+ RTCRtpReceiver* rtpReceiver =
+ [[RTCRtpReceiver alloc] initWithNativeRtpReceiver:receiver];
+ NSMutableArray* mediaStreams =
+ [NSMutableArray arrayWithCapacity:streams.size()];
+
+ RTCPeerConnection* peer_connection = peer_connection_;
+ for (const auto stream : streams) {
+ RTCMediaStream* mediaStream =
+ [peer_connection mediaStreamForNativeStream:stream];
+ [mediaStreams addObject:mediaStream];
+ }
+ if ([peer_connection.delegate
+ respondsToSelector:@selector(peerConnection:didAddTrack:streams:)]) {
+ [peer_connection.delegate peerConnection:peer_connection
+ didAddTrack:rtpReceiver
+ streams:mediaStreams];
+ }
+}
+
} // namespace webrtc
@@ -209,6 +232,7 @@ void PeerConnectionDelegateAdapter::OnIceCandidatesRemoved(
rtc::scoped_refptr<webrtc::PeerConnectionInterface> _peerConnection;
std::unique_ptr<webrtc::MediaConstraints> _nativeConstraints;
BOOL _hasStartedRtcEventLog;
+ NSMutableDictionary<NSString *, RTCMediaStream *> *_mediaStreamsByStreamId;
}
@synthesize delegate = _delegate;
@@ -238,6 +262,7 @@ void PeerConnectionDelegateAdapter::OnIceCandidatesRemoved(
}
_localStreams = [[NSMutableArray alloc] init];
_delegate = delegate;
+ _mediaStreamsByStreamId = [NSMutableDictionary dictionary];
}
return self;
}
@@ -588,6 +613,21 @@ void PeerConnectionDelegateAdapter::OnIceCandidatesRemoved(
}
}
+- (RTCMediaStream *)mediaStreamForNativeStream:
+ (rtc::scoped_refptr<webrtc::MediaStreamInterface>)stream {
+ RTCMediaStream *mediaStream =
+ _mediaStreamsByStreamId[[NSString stringForStdString:stream->label()]];
tkchin_webrtc 2017/02/24 20:54:15 nit: pull this out into a local so you're not crea
+ if (!mediaStream) {
+ mediaStream = [[RTCMediaStream alloc] initWithNativeMediaStream:stream.get()];
+ _mediaStreamsByStreamId[[NSString stringForStdString:stream->label()]] = mediaStream;
+ }
+ return mediaStream;
+}
+
+- (void)removeNativeMediaStream:(rtc::scoped_refptr<webrtc::MediaStreamInterface>)stream {
+ [_mediaStreamsByStreamId removeObjectForKey:[NSString stringForStdString:stream->label()]];
+}
+
- (rtc::scoped_refptr<webrtc::PeerConnectionInterface>)nativePeerConnection {
return _peerConnection;
}
« no previous file with comments | « no previous file | webrtc/sdk/objc/Framework/Classes/RTCPeerConnection+Private.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698