New peerconnection test case, for video stream forwarding.

webrtc/media/engine/webrtcvideoengine2.cc

 /*
  *  Copyright (c) 2014 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 1544 matching lines @@
   memset(video_frame->buffer(webrtc::kUPlane), 128,
          video_frame->allocated_size(webrtc::kUPlane));
   memset(video_frame->buffer(webrtc::kVPlane), 128,
          video_frame->allocated_size(webrtc::kVPlane));
   video_frame->set_rotation(rotation);
 }
 
 void WebRtcVideoChannel2::WebRtcVideoSendStream::OnFrame(
     const VideoFrame& frame) {
   TRACE_EVENT0("webrtc", "WebRtcVideoSendStream::OnFrame");
-  webrtc::VideoFrame video_frame(frame.GetVideoFrameBuffer(), 0, 0,
-                                 frame.GetVideoRotation());
+  invoker_.AsyncInvoke<void>(

[pbos-webrtc, 2016/04/08 14:08:56]

I really don't want a thread hop here, I've CLs that should get rid of the
requirement to run this on the worker thread that need to be relanded (hopefully
early next week). Can we wait until that?

I'm also a bit afraid that this invoke call could outlive this object (frame ->
destroy stream -> invoke happens).

[perkj_webrtc, 2016/04/08 14:34:07]

This can wait until then.... 

[nisse-webrtc, 2016/04/08 14:57:03]

Agreed.

[nisse-webrtc, 2016/04/11 06:35:39]

Can you cc me on that cl?

+      worker_thread_,
+      rtc::Bind(&WebRtcVideoChannel2::WebRtcVideoSendStream::OnFrame_w,
+                this,
+                webrtc::VideoFrame(frame.GetVideoFrameBuffer(), 0, 0,
+                                   frame.GetVideoRotation()),
+                frame.GetTimeStamp() / rtc::kNumNanosecsPerMillisec));
+}
+
+void WebRtcVideoChannel2::WebRtcVideoSendStream::OnFrame_w(
+    webrtc::VideoFrame video_frame, int64_t frame_delta_ms) {
+  RTC_DCHECK(worker_thread_->IsCurrent());
   rtc::CritScope cs(&lock_);
   if (stream_ == NULL) {
     // Frame input before send codecs are configured, dropping frame.
     return;
   }
 
-  int64_t frame_delta_ms = frame.GetTimeStamp() / rtc::kNumNanosecsPerMillisec;
   // frame->GetTimeStamp() is essentially a delta, align to webrtc time
   if (first_frame_timestamp_ms_ == 0) {
     first_frame_timestamp_ms_ = rtc::Time() - frame_delta_ms;
   }
 
   last_frame_timestamp_ms_ = first_frame_timestamp_ms_ + frame_delta_ms;
   video_frame.set_render_time_ms(last_frame_timestamp_ms_);
   // Reconfigure codec if necessary.
   SetDimensions(video_frame.width(), video_frame.height());
   last_rotation_ = video_frame.rotation();
@@ skipping 981 matching lines @@
         rtx_mapping[video_codecs[i].codec.id] !=
             fec_settings.red_payload_type) {
       video_codecs[i].rtx_payload_type = rtx_mapping[video_codecs[i].codec.id];
     }
   }
 
   return video_codecs;
 }
 
 }  // namespace cricket