RTCPeerConnection.ontrack event added.

third_party/WebKit/Source/modules/peerconnection/RTCPeerConnection.cpp

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 57 matching lines @@
 #include "modules/peerconnection/RTCRtpReceiver.h"
 #include "modules/peerconnection/RTCRtpSender.h"
 #include "modules/peerconnection/RTCSessionDescription.h"
 #include "modules/peerconnection/RTCSessionDescriptionCallback.h"
 #include "modules/peerconnection/RTCSessionDescriptionInit.h"
 #include "modules/peerconnection/RTCSessionDescriptionRequestImpl.h"
 #include "modules/peerconnection/RTCSessionDescriptionRequestPromiseImpl.h"
 #include "modules/peerconnection/RTCStatsCallback.h"
 #include "modules/peerconnection/RTCStatsReport.h"
 #include "modules/peerconnection/RTCStatsRequestImpl.h"
+#include "modules/peerconnection/RTCTrackEvent.h"
 #include "modules/peerconnection/RTCVoidRequestImpl.h"
 #include "modules/peerconnection/RTCVoidRequestPromiseImpl.h"
 #include "platform/RuntimeEnabledFeatures.h"
 #include "platform/bindings/Microtask.h"
 #include "platform/bindings/ScriptState.h"
 #include "platform/bindings/V8ThrowException.h"
 #include "platform/peerconnection/RTCAnswerOptionsPlatform.h"
 #include "platform/peerconnection/RTCOfferOptionsPlatform.h"
 #include "platform/wtf/CurrentTime.h"
 #include "platform/wtf/PtrUtil.h"
@@ skipping 1348 matching lines @@
 }
 
 void RTCPeerConnection::DidChangeICEConnectionState(
     ICEConnectionState new_state) {
   DCHECK(!closed_);
   DCHECK(GetExecutionContext()->IsContextThread());
   ChangeIceConnectionState(new_state);
 }
 
 void RTCPeerConnection::DidAddRemoteStream(
-    const WebMediaStream& remote_stream) {
+    const WebMediaStream& remote_stream,
+    WebVector<std::unique_ptr<WebRTCRtpReceiver>>* stream_web_rtp_receivers) {
   DCHECK(!closed_);
   DCHECK(GetExecutionContext()->IsContextThread());
 
   if (signaling_state_ == kSignalingStateClosed)
     return;
 
   MediaStream* stream =
       MediaStream::Create(GetExecutionContext(), remote_stream);
   remote_streams_.push_back(stream);
   stream->RegisterObserver(this);
   for (auto& track : stream->getTracks()) {
     DCHECK(track->Component());
     tracks_.insert(track->Component(), track);
   }
 
   ScheduleDispatchEvent(
       MediaStreamEvent::Create(EventTypeNames::addstream, stream));
+
+  // TODO(hbos): ...
+  HeapVector<Member<MediaStream>> streams(1, stream);
+  for (auto& track : stream->getTracks()) {
+    std::unique_ptr<WebRTCRtpReceiver> track_web_rtp_receiver;
+    for (auto& web_rtp_receiver : *stream_web_rtp_receivers) {
+      if (static_cast<String>(web_rtp_receiver->Track().Id()) == track->id()) {
+        track_web_rtp_receiver.reset(web_rtp_receiver.release());
+        break;
+      }
+    }
+    DCHECK(track_web_rtp_receiver);
+    uintptr_t id = track_web_rtp_receiver->Id();
+    RTCRtpReceiver* track_rtp_receiver = nullptr;
+    const auto it = rtp_receivers_.find(id);
+    if (it != rtp_receivers_.end()) {
+      track_rtp_receiver = it->value;
+    } else {
+      // There does not exist a |RTCRtpReceiver| for this |WebRTCRtpReceiver|
+      // yet, create it.
+      MediaStreamTrack* track = GetTrack(track_web_rtp_receiver->Track());
+      DCHECK(track);
+      track_rtp_receiver =
+          new RTCRtpReceiver(std::move(track_web_rtp_receiver), track);
+      rtp_receivers_.insert(id, track_rtp_receiver);
+    }
+    ScheduleDispatchEvent(
+        new RTCTrackEvent(track_rtp_receiver, track, streams));
+  }
 }
 
 void RTCPeerConnection::DidRemoveRemoteStream(
     const WebMediaStream& remote_stream) {
   DCHECK(!closed_);
   DCHECK(GetExecutionContext()->IsContextThread());
 
   MediaStreamDescriptor* stream_descriptor = remote_stream;
   DCHECK(stream_descriptor->Client());
 
@@ skipping 181 matching lines @@
   visitor->Trace(rtp_senders_);
   visitor->Trace(rtp_receivers_);
   visitor->Trace(dispatch_scheduled_event_runner_);
   visitor->Trace(scheduled_events_);
   EventTargetWithInlineData::Trace(visitor);
   SuspendableObject::Trace(visitor);
   MediaStreamObserver::Trace(visitor);
 }
 
 }  // namespace blink