Measure encoding time on encode callbacks.

webrtc/video/video_capture_input.cc

Index: webrtc/video/video_capture_input.cc
diff --git a/webrtc/video/video_capture_input.cc b/webrtc/video/video_capture_input.cc
index 1c5f2992910737e14b9cf72e036c3af7e358464d..405a0b67108c8c05aa3931d4795ff4cb3d868a46 100644
--- a/webrtc/video/video_capture_input.cc
+++ b/webrtc/video/video_capture_input.cc
@@ -14,7 +14,6 @@
 #include "webrtc/base/logging.h"
 #include "webrtc/base/trace_event.h"
 #include "webrtc/modules/include/module_common_types.h"
-#include "webrtc/modules/utility/include/process_thread.h"
 #include "webrtc/modules/video_capture/video_capture_factory.h"
 #include "webrtc/modules/video_processing/include/video_processing.h"
 #include "webrtc/modules/video_render/video_render_defines.h"
@@ -29,14 +28,12 @@ namespace webrtc {
 
 namespace internal {
 VideoCaptureInput::VideoCaptureInput(
-    ProcessThread* module_process_thread,
     VideoCaptureCallback* frame_callback,
     VideoRenderer* local_renderer,
     SendStatisticsProxy* stats_proxy,
-    CpuOveruseObserver* overuse_observer,
+    OveruseFrameDetector* overuse_detector,
     EncodingTimeObserver* encoding_time_observer)
     : capture_cs_(CriticalSectionWrapper::CreateCriticalSection()),
-      module_process_thread_(module_process_thread),
       frame_callback_(frame_callback),
       local_renderer_(local_renderer),
       stats_proxy_(stats_proxy),
@@ -48,19 +45,13 @@ VideoCaptureInput::VideoCaptureInput(
       delta_ntp_internal_ms_(
           Clock::GetRealTimeClock()->CurrentNtpInMilliseconds() -
           TickTime::MillisecondTimestamp()),
-      overuse_detector_(new OveruseFrameDetector(Clock::GetRealTimeClock(),
-                                                 CpuOveruseOptions(),
-                                                 overuse_observer,
-                                                 stats_proxy)),
+      overuse_detector_(overuse_detector),
       encoding_time_observer_(encoding_time_observer) {
   encoder_thread_.Start();
   encoder_thread_.SetPriority(rtc::kHighPriority);
-  module_process_thread_->RegisterModule(overuse_detector_.get());
 }
 
 VideoCaptureInput::~VideoCaptureInput() {
-  module_process_thread_->DeRegisterModule(overuse_detector_.get());
-
   // Stop the thread.
   rtc::AtomicOps::ReleaseStore(&stop_, 1);
   capture_event_.Set();
@@ -108,9 +99,7 @@ void VideoCaptureInput::IncomingCapturedFrame(const VideoFrame& video_frame) {
   captured_frame_.ShallowCopy(incoming_frame);
   last_captured_timestamp_ = incoming_frame.ntp_time_ms();
 
-  overuse_detector_->FrameCaptured(captured_frame_.width(),
-                                   captured_frame_.height(),
-                                   captured_frame_.render_time_ms());
+  overuse_detector_->FrameCaptured(captured_frame_);
 
   TRACE_EVENT_ASYNC_BEGIN1("webrtc", "Video", video_frame.render_time_ms(),
                            "render_time", video_frame.render_time_ms());
@@ -124,7 +113,6 @@ bool VideoCaptureInput::EncoderThreadFunction(void* obj) {
 
 bool VideoCaptureInput::EncoderProcess() {
   static const int kThreadWaitTimeMs = 100;
-  int64_t capture_time = -1;
   if (capture_event_.Wait(kThreadWaitTimeMs)) {
     if (rtc::AtomicOps::AcquireLoad(&stop_))
       return false;
@@ -139,7 +127,6 @@ bool VideoCaptureInput::EncoderProcess() {
       }
     }
     if (!deliver_frame.IsZeroSize()) {
-      capture_time = deliver_frame.render_time_ms();
       encode_start_time = Clock::GetRealTimeClock()->TimeInMilliseconds();
       frame_callback_->DeliverFrame(deliver_frame);
     }
@@ -147,17 +134,13 @@ bool VideoCaptureInput::EncoderProcess() {
     if (encode_start_time != -1) {
       int encode_time_ms = static_cast<int>(
           Clock::GetRealTimeClock()->TimeInMilliseconds() - encode_start_time);
-      stats_proxy_->OnEncodedFrame(encode_time_ms);
+      // TODO(pbos): Move encoding_time_observer into OveruseFrameDetector.

[mflodman, 2016/01/21 08:00:05]

I think this CL is touching a lot of files already, shouldn't this be done right
away instead to get the same encoding times in this callback as used for overuse
detection?

[pbos-webrtc, 2016/01/21 14:18:33]

Yep, done. This has the downside that times are not reported if encoding takes
>1 second. Removed EncodingTimeObserver in favor of adding OnEncodeTiming to
EncodedFrameCallback.

       if (encoding_time_observer_) {
         encoding_time_observer_->OnReportEncodedTime(
             deliver_frame.ntp_time_ms(), encode_time_ms);
       }
     }
   }
-  // We're done!
-  if (capture_time != -1) {
-    overuse_detector_->FrameSent(capture_time);
-  }
   return true;
 }