Forward the SignalFirstPacketReceived to RtpReceiver.

webrtc/api/rtpreceiver.cc

 /*
  *  Copyright 2015 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 11 matching lines @@
                                    const std::string& track_id,
                                    uint32_t ssrc,
                                    AudioProviderInterface* provider)
     : id_(track_id),
       ssrc_(ssrc),
       provider_(provider),
       track_(AudioTrackProxy::Create(
           rtc::Thread::Current(),
           AudioTrack::Create(track_id,
                              RemoteAudioSource::Create(ssrc, provider)))),
-      cached_track_enabled_(track_->enabled()) {
+      cached_track_enabled_(track_->enabled()),
+      rtp_receiver_observer_(nullptr) {
   RTC_DCHECK(track_->GetSource()->remote());
   track_->RegisterObserver(this);
   track_->GetSource()->RegisterAudioObserver(this);
   Reconfigure();
   stream->AddTrack(track_);
+  provider_->SignalFirstAudioPacketReceived.connect(
+      this, &AudioRtpReceiver::onFirstAudioPacketReceived);
 }
 
 AudioRtpReceiver::~AudioRtpReceiver() {
   track_->GetSource()->UnregisterAudioObserver(this);
   track_->UnregisterObserver(this);
   Stop();
 }
 
 void AudioRtpReceiver::OnChanged() {
   if (cached_track_enabled_ != track_->enabled()) {
@@ skipping 28 matching lines @@
   return provider_->SetAudioRtpReceiveParameters(ssrc_, parameters);
 }
 
 void AudioRtpReceiver::Reconfigure() {
   if (!provider_) {
     return;
   }
   provider_->SetAudioPlayout(ssrc_, track_->enabled());
 }
 
+void AudioRtpReceiver::RegisterRtpReceiverObserver(
+    RtpReceiverObserverInterface* observer) {
+  rtp_receiver_observer_ = observer;

[pthatcher2, 2016/05/20 20:23:13]

We could add:

if (received_first_packet_) {
  observer::OnFirstPacketReceived();
}

[Zhi Huang, 2016/06/09 00:37:36]

This is a good point! In this way, we can fire the signal even the observer is
not set before the receiving the first packet.

+}
+
+void AudioRtpReceiver::onFirstAudioPacketReceived() {
+  if (rtp_receiver_observer_) {
+    rtp_receiver_observer_->onFirstPacketReceived(cricket::MEDIA_TYPE_AUDIO);
+  }

[pthatcher2, 2016/05/20 20:23:13]

Right here we could store:

received_first_packet_ = true;

+}
+
 VideoRtpReceiver::VideoRtpReceiver(MediaStreamInterface* stream,
                                    const std::string& track_id,
                                    rtc::Thread* worker_thread,
                                    uint32_t ssrc,
                                    VideoProviderInterface* provider)
     : id_(track_id),
       ssrc_(ssrc),
       provider_(provider),
       source_(new RefCountedObject<VideoTrackSource>(&broadcaster_,
                                                      true /* remote */)),
       track_(VideoTrackProxy::Create(
           rtc::Thread::Current(),
           worker_thread,
           VideoTrack::Create(
               track_id,
               VideoTrackSourceProxy::Create(rtc::Thread::Current(),
                                             worker_thread,
-                                            source_)))) {
+                                            source_)))),
+      rtp_receiver_observer_(nullptr) {
   source_->SetState(MediaSourceInterface::kLive);
   provider_->SetVideoPlayout(ssrc_, true, &broadcaster_);
   stream->AddTrack(track_);
+  provider_->SignalFirstVideoPacketReceived.connect(
+      this, &VideoRtpReceiver::onFirstVideoPacketReceived);
 }
 
 VideoRtpReceiver::~VideoRtpReceiver() {
   // Since cricket::VideoRenderer is not reference counted,
   // we need to remove it from the provider before we are deleted.
   Stop();
 }
 
 void VideoRtpReceiver::Stop() {
   // TODO(deadbeef): Need to do more here to fully stop receiving packets.
   if (!provider_) {
     return;
   }
   source_->SetState(MediaSourceInterface::kEnded);
   source_->OnSourceDestroyed();
   provider_->SetVideoPlayout(ssrc_, false, nullptr);
   provider_ = nullptr;
 }
 
 RtpParameters VideoRtpReceiver::GetParameters() const {
   return provider_->GetVideoRtpReceiveParameters(ssrc_);
 }
 
 bool VideoRtpReceiver::SetParameters(const RtpParameters& parameters) {
   TRACE_EVENT0("webrtc", "VideoRtpReceiver::SetParameters");
   return provider_->SetVideoRtpReceiveParameters(ssrc_, parameters);
 }
 
+void VideoRtpReceiver::RegisterRtpReceiverObserver(
+    RtpReceiverObserverInterface* observer) {
+  rtp_receiver_observer_ = observer;
+}
+
+void VideoRtpReceiver::onFirstVideoPacketReceived() {
+  if (rtp_receiver_observer_) {
+    rtp_receiver_observer_->onFirstPacketReceived(cricket::MEDIA_TYPE_VIDEO);
+  }
+}

[pthatcher2, 2016/05/20 20:23:13]

Same here.

+
 }  // namespace webrtc