blob: 5b53d07470a2ea7c1f0a80f9ff74c889cfb5c096 [file] [log] [blame]
henrike@webrtc.org28e20752013-07-10 00:45:36 +00001// libjingle
2// Copyright 2010 Google Inc.
3//
4// Redistribution and use in source and binary forms, with or without
5// modification, are permitted provided that the following conditions are met:
6//
7// 1. Redistributions of source code must retain the above copyright notice,
8// this list of conditions and the following disclaimer.
9// 2. Redistributions in binary form must reproduce the above copyright notice,
10// this list of conditions and the following disclaimer in the documentation
11// and/or other materials provided with the distribution.
12// 3. The name of the author may not be used to endorse or promote products
13// derived from this software without specific prior written permission.
14//
15// THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
16// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
17// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
18// EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
19// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
20// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
21// OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
22// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
23// OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
24// ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25
26#include "talk/media/base/videoadapter.h"
27
28#include <limits.h> // For INT_MAX
29
henrike@webrtc.org28e20752013-07-10 00:45:36 +000030#include "talk/base/logging.h"
31#include "talk/base/timeutils.h"
henrike@webrtc.org28654cb2013-07-22 21:07:49 +000032#include "talk/media/base/constants.h"
henrike@webrtc.org28e20752013-07-10 00:45:36 +000033#include "talk/media/base/videoframe.h"
34
35namespace cricket {
36
37// TODO(fbarchard): Make downgrades settable
38static const int kMaxCpuDowngrades = 2; // Downgrade at most 2 times for CPU.
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +000039// The number of cpu samples to require before adapting. This value depends on
40// the cpu monitor sampling frequency being 2000ms.
41static const int kCpuLoadMinSamples = 3;
henrike@webrtc.org28654cb2013-07-22 21:07:49 +000042// The amount of weight to give to each new cpu load sample. The lower the
43// value, the slower we'll adapt to changing cpu conditions.
44static const float kCpuLoadWeightCoefficient = 0.4f;
45// The seed value for the cpu load moving average.
46static const float kCpuLoadInitialAverage = 0.5f;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000047
henrike@webrtc.org28e20752013-07-10 00:45:36 +000048// Desktop needs 1/8 scale for HD (1280 x 720) to QQVGA (160 x 90)
wu@webrtc.orgcadf9042013-08-30 21:24:16 +000049static const float kScaleFactors[] = {
50 1.f / 1.f, // Full size.
51 3.f / 4.f, // 3/4 scale.
52 1.f / 2.f, // 1/2 scale.
53 3.f / 8.f, // 3/8 scale.
54 1.f / 4.f, // 1/4 scale.
henrike@webrtc.org28e20752013-07-10 00:45:36 +000055 3.f / 16.f, // 3/16 scale.
wu@webrtc.orgcadf9042013-08-30 21:24:16 +000056 1.f / 8.f, // 1/8 scale.
57 0.f // End of table.
henrike@webrtc.org28e20752013-07-10 00:45:36 +000058};
henrike@webrtc.org28e20752013-07-10 00:45:36 +000059
wu@webrtc.orgcadf9042013-08-30 21:24:16 +000060// TODO(fbarchard): Use this table (optionally) for CPU and GD as well.
61static const float kViewScaleFactors[] = {
62 1.f / 1.f, // Full size.
63 3.f / 4.f, // 3/4 scale.
64 2.f / 3.f, // 2/3 scale. // Allow 1080p to 720p.
65 1.f / 2.f, // 1/2 scale.
66 3.f / 8.f, // 3/8 scale.
67 1.f / 3.f, // 1/3 scale. // Allow 1080p to 360p.
68 1.f / 4.f, // 1/4 scale.
69 3.f / 16.f, // 3/16 scale.
70 1.f / 8.f, // 1/8 scale.
71 0.f // End of table.
72};
henrike@webrtc.org28e20752013-07-10 00:45:36 +000073
wu@webrtc.orgcadf9042013-08-30 21:24:16 +000074const float* VideoAdapter::GetViewScaleFactors() const {
75 return scale_third_ ? kViewScaleFactors : kScaleFactors;
76}
77
78// For resolutions that would scale down a little instead of up a little,
79// bias toward scaling up a little. This will tend to choose 3/4 scale instead
80// of 2/3 scale, when the 2/3 is not an exact match.
81static const float kUpBias = -0.9f;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000082// Find the scale factor that, when applied to width and height, is closest
83// to num_pixels.
wu@webrtc.orgcadf9042013-08-30 21:24:16 +000084float VideoAdapter::FindScale(const float* scale_factors,
85 const float upbias,
86 int width, int height,
87 int target_num_pixels) {
88 const float kMinNumPixels = 160 * 90;
henrike@webrtc.org28e20752013-07-10 00:45:36 +000089 if (!target_num_pixels) {
90 return 0.f;
91 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +000092 float best_distance = static_cast<float>(INT_MAX);
93 float best_scale = 1.f; // Default to unscaled if nothing matches.
94 float pixels = static_cast<float>(width * height);
95 for (int i = 0; ; ++i) {
96 float scale = scale_factors[i];
97 float test_num_pixels = pixels * scale * scale;
98 // Do not consider scale factors that produce too small images.
99 // Scale factor of 0 at end of table will also exit here.
100 if (test_num_pixels < kMinNumPixels) {
101 break;
102 }
103 float diff = target_num_pixels - test_num_pixels;
104 // If resolution is higher than desired, bias the difference based on
105 // preference for slightly larger for nearest, or avoid completely if
106 // looking for lower resolutions only.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000107 if (diff < 0) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000108 diff = diff * kUpBias;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000109 }
110 if (diff < best_distance) {
111 best_distance = diff;
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000112 best_scale = scale;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000113 if (best_distance == 0) { // Found exact match.
114 break;
115 }
116 }
117 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000118 return best_scale;
119}
120
121// Find the closest scale factor.
122float VideoAdapter::FindClosestScale(int width, int height,
123 int target_num_pixels) {
124 return FindScale(kScaleFactors, kUpBias,
125 width, height, target_num_pixels);
126}
127
128// Find the closest view scale factor.
129float VideoAdapter::FindClosestViewScale(int width, int height,
130 int target_num_pixels) {
131 return FindScale(GetViewScaleFactors(), kUpBias,
132 width, height, target_num_pixels);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000133}
134
135// Finds the scale factor that, when applied to width and height, produces
136// fewer than num_pixels.
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000137static const float kUpAvoidBias = -1000000000.f;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000138float VideoAdapter::FindLowerScale(int width, int height,
139 int target_num_pixels) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000140 return FindScale(GetViewScaleFactors(), kUpAvoidBias,
141 width, height, target_num_pixels);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000142}
143
144// There are several frame sizes used by Adapter. This explains them
145// input_format - set once by server to frame size expected from the camera.
146// output_format - size that output would like to be. Includes framerate.
147// output_num_pixels - size that output should be constrained to. Used to
148// compute output_format from in_frame.
149// in_frame - actual camera captured frame size, which is typically the same
150// as input_format. This can also be rotated or cropped for aspect ratio.
151// out_frame - actual frame output by adapter. Should be a direct scale of
152// in_frame maintaining rotation and aspect ratio.
153// OnOutputFormatRequest - server requests you send this resolution based on
154// view requests.
155// OnEncoderResolutionRequest - encoder requests you send this resolution based
156// on bandwidth
157// OnCpuLoadUpdated - cpu monitor requests you send this resolution based on
158// cpu load.
159
160///////////////////////////////////////////////////////////////////////
161// Implementation of VideoAdapter
162VideoAdapter::VideoAdapter()
163 : output_num_pixels_(INT_MAX),
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000164 scale_third_(false),
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000165 frames_in_(0),
166 frames_out_(0),
167 frames_scaled_(0),
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000168 adaption_changes_(0),
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000169 previous_width_(0),
170 previous_height_(0),
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000171 black_output_(false),
172 is_black_(false),
173 interval_next_frame_(0) {
174}
175
176VideoAdapter::~VideoAdapter() {
177}
178
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000179void VideoAdapter::SetInputFormat(const VideoFormat& format) {
180 talk_base::CritScope cs(&critical_section_);
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000181 int64 old_input_interval = input_format_.interval;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000182 input_format_ = format;
183 output_format_.interval = talk_base::_max(
184 output_format_.interval, input_format_.interval);
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000185 if (old_input_interval != input_format_.interval) {
wu@webrtc.orgb9a088b2014-02-13 23:18:49 +0000186 LOG(LS_INFO) << "VAdapt input interval changed from "
187 << old_input_interval << " to " << input_format_.interval;
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000188 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000189}
190
mallinath@webrtc.org1b15f422013-09-06 22:56:28 +0000191void CoordinatedVideoAdapter::SetInputFormat(const VideoFormat& format) {
192 int previous_width = input_format().width;
193 int previous_height = input_format().height;
194 bool is_resolution_change = previous_width > 0 && format.width > 0 &&
195 (previous_width != format.width ||
196 previous_height != format.height);
197 VideoAdapter::SetInputFormat(format);
198 if (is_resolution_change) {
199 int width, height;
200 // Trigger the adaptation logic again, to potentially reset the adaptation
201 // state for things like view requests that may not longer be capping
202 // output (or may now cap output).
203 AdaptToMinimumFormat(&width, &height);
204 LOG(LS_INFO) << "VAdapt Input Resolution Change: "
205 << "Previous input resolution: "
206 << previous_width << "x" << previous_height
207 << " New input resolution: "
208 << format.width << "x" << format.height
209 << " New output resolution: "
210 << width << "x" << height;
211 }
212}
213
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000214void VideoAdapter::SetOutputFormat(const VideoFormat& format) {
215 talk_base::CritScope cs(&critical_section_);
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000216 int64 old_output_interval = output_format_.interval;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000217 output_format_ = format;
218 output_num_pixels_ = output_format_.width * output_format_.height;
219 output_format_.interval = talk_base::_max(
220 output_format_.interval, input_format_.interval);
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000221 if (old_output_interval != output_format_.interval) {
wu@webrtc.orgb9a088b2014-02-13 23:18:49 +0000222 LOG(LS_INFO) << "VAdapt output interval changed from "
223 << old_output_interval << " to " << output_format_.interval;
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000224 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000225}
226
227const VideoFormat& VideoAdapter::input_format() {
228 talk_base::CritScope cs(&critical_section_);
229 return input_format_;
230}
231
232const VideoFormat& VideoAdapter::output_format() {
233 talk_base::CritScope cs(&critical_section_);
234 return output_format_;
235}
236
237void VideoAdapter::SetBlackOutput(bool black) {
238 talk_base::CritScope cs(&critical_section_);
239 black_output_ = black;
240}
241
242// Constrain output resolution to this many pixels overall
243void VideoAdapter::SetOutputNumPixels(int num_pixels) {
244 output_num_pixels_ = num_pixels;
245}
246
247int VideoAdapter::GetOutputNumPixels() const {
248 return output_num_pixels_;
249}
250
251// TODO(fbarchard): Add AdaptFrameRate function that only drops frames but
252// not resolution.
253bool VideoAdapter::AdaptFrame(const VideoFrame* in_frame,
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000254 VideoFrame** out_frame) {
sergeyu@chromium.org4b26e2e2014-01-15 23:15:54 +0000255 talk_base::CritScope cs(&critical_section_);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000256 if (!in_frame || !out_frame) {
257 return false;
258 }
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000259 ++frames_in_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000260
261 // Update input to actual frame dimensions.
mallinath@webrtc.orgab5a0912013-09-07 00:12:57 +0000262 VideoFormat format(static_cast<int>(in_frame->GetWidth()),
263 static_cast<int>(in_frame->GetHeight()),
mallinath@webrtc.org1b15f422013-09-06 22:56:28 +0000264 input_format_.interval, input_format_.fourcc);
265 SetInputFormat(format);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000266
267 // Drop the input frame if necessary.
268 bool should_drop = false;
269 if (!output_num_pixels_) {
270 // Drop all frames as the output format is 0x0.
271 should_drop = true;
272 } else {
273 // Drop some frames based on input fps and output fps.
274 // Normally output fps is less than input fps.
275 // TODO(fbarchard): Consider adjusting interval to reflect the adjusted
276 // interval between frames after dropping some frames.
277 interval_next_frame_ += input_format_.interval;
278 if (output_format_.interval > 0) {
279 if (interval_next_frame_ >= output_format_.interval) {
280 interval_next_frame_ %= output_format_.interval;
281 } else {
282 should_drop = true;
283 }
284 }
285 }
286 if (should_drop) {
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000287 // Show VAdapt log every 90 frames dropped. (3 seconds)
wu@webrtc.orgb9a088b2014-02-13 23:18:49 +0000288 if ((frames_in_ - frames_out_) % 90 == 0) {
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000289 // TODO(fbarchard): Reduce to LS_VERBOSE when adapter info is not needed
290 // in default calls.
wu@webrtc.orgb9a088b2014-02-13 23:18:49 +0000291 LOG(LS_INFO) << "VAdapt Drop Frame: scaled " << frames_scaled_
292 << " / out " << frames_out_
293 << " / in " << frames_in_
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000294 << " Changes: " << adaption_changes_
295 << " Input: " << in_frame->GetWidth()
296 << "x" << in_frame->GetHeight()
297 << " i" << input_format_.interval
298 << " Output: i" << output_format_.interval;
299 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000300 *out_frame = NULL;
301 return true;
302 }
303
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000304 float scale = 1.f;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000305 if (output_num_pixels_) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000306 scale = VideoAdapter::FindClosestViewScale(
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000307 static_cast<int>(in_frame->GetWidth()),
308 static_cast<int>(in_frame->GetHeight()),
309 output_num_pixels_);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000310 output_format_.width = static_cast<int>(in_frame->GetWidth() * scale + .5f);
311 output_format_.height = static_cast<int>(in_frame->GetHeight() * scale +
312 .5f);
313 }
314
315 if (!StretchToOutputFrame(in_frame)) {
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000316 LOG(LS_VERBOSE) << "VAdapt Stretch Failed.";
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000317 return false;
318 }
319
320 *out_frame = output_frame_.get();
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000321
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000322 ++frames_out_;
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000323 if (in_frame->GetWidth() != (*out_frame)->GetWidth() ||
324 in_frame->GetHeight() != (*out_frame)->GetHeight()) {
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000325 ++frames_scaled_;
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000326 }
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000327 // Show VAdapt log every 90 frames output. (3 seconds)
328 // TODO(fbarchard): Consider GetLogSeverity() to change interval to less
329 // for LS_VERBOSE and more for LS_INFO.
330 bool show = (frames_out_) % 90 == 0;
331
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000332 // TODO(fbarchard): LOG the previous output resolution and track input
333 // resolution changes as well. Consider dropping the statistics into their
334 // own class which could be queried publically.
335 bool changed = false;
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000336 if (previous_width_ && (previous_width_ != (*out_frame)->GetWidth() ||
337 previous_height_ != (*out_frame)->GetHeight())) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000338 show = true;
339 ++adaption_changes_;
340 changed = true;
341 }
342 if (show) {
343 // TODO(fbarchard): Reduce to LS_VERBOSE when adapter info is not needed
344 // in default calls.
wu@webrtc.orgb9a088b2014-02-13 23:18:49 +0000345 LOG(LS_INFO) << "VAdapt Frame: scaled " << frames_scaled_
346 << " / out " << frames_out_
347 << " / in " << frames_in_
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000348 << " Changes: " << adaption_changes_
349 << " Input: " << in_frame->GetWidth()
350 << "x" << in_frame->GetHeight()
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000351 << " i" << input_format_.interval
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000352 << " Scale: " << scale
353 << " Output: " << (*out_frame)->GetWidth()
354 << "x" << (*out_frame)->GetHeight()
sergeyu@chromium.org9cf037b2014-02-07 19:03:26 +0000355 << " i" << output_format_.interval
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000356 << " Changed: " << (changed ? "true" : "false");
357 }
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000358 previous_width_ = (*out_frame)->GetWidth();
359 previous_height_ = (*out_frame)->GetHeight();
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000360
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000361 return true;
362}
363
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000364// Scale or Blacken the frame. Returns true if successful.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000365bool VideoAdapter::StretchToOutputFrame(const VideoFrame* in_frame) {
366 int output_width = output_format_.width;
367 int output_height = output_format_.height;
368
369 // Create and stretch the output frame if it has not been created yet or its
370 // size is not same as the expected.
371 bool stretched = false;
372 if (!output_frame_ ||
373 output_frame_->GetWidth() != static_cast<size_t>(output_width) ||
374 output_frame_->GetHeight() != static_cast<size_t>(output_height)) {
375 output_frame_.reset(
376 in_frame->Stretch(output_width, output_height, true, true));
377 if (!output_frame_) {
378 LOG(LS_WARNING) << "Adapter failed to stretch frame to "
379 << output_width << "x" << output_height;
380 return false;
381 }
382 stretched = true;
383 is_black_ = false;
384 }
385
386 if (!black_output_) {
387 if (!stretched) {
388 // The output frame does not need to be blacken and has not been stretched
389 // from the input frame yet, stretch the input frame. This is the most
390 // common case.
391 in_frame->StretchToFrame(output_frame_.get(), true, true);
392 }
393 is_black_ = false;
394 } else {
395 if (!is_black_) {
396 output_frame_->SetToBlack();
397 is_black_ = true;
398 }
399 output_frame_->SetElapsedTime(in_frame->GetElapsedTime());
400 output_frame_->SetTimeStamp(in_frame->GetTimeStamp());
401 }
402
403 return true;
404}
405
406///////////////////////////////////////////////////////////////////////
407// Implementation of CoordinatedVideoAdapter
408CoordinatedVideoAdapter::CoordinatedVideoAdapter()
wu@webrtc.org9caf2762013-12-11 18:25:07 +0000409 : cpu_adaptation_(true),
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000410 cpu_smoothing_(false),
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000411 gd_adaptation_(true),
412 view_adaptation_(true),
413 view_switch_(false),
414 cpu_downgrade_count_(0),
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000415 cpu_load_min_samples_(kCpuLoadMinSamples),
416 cpu_load_num_samples_(0),
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000417 high_system_threshold_(kHighSystemCpuThreshold),
418 low_system_threshold_(kLowSystemCpuThreshold),
419 process_threshold_(kProcessCpuThreshold),
420 view_desired_num_pixels_(INT_MAX),
421 view_desired_interval_(0),
422 encoder_desired_num_pixels_(INT_MAX),
423 cpu_desired_num_pixels_(INT_MAX),
xians@webrtc.orgef221512014-02-21 10:31:29 +0000424 adapt_reason_(0),
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000425 system_load_average_(kCpuLoadInitialAverage) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000426}
427
428// Helper function to UPGRADE or DOWNGRADE a number of pixels
429void CoordinatedVideoAdapter::StepPixelCount(
430 CoordinatedVideoAdapter::AdaptRequest request,
431 int* num_pixels) {
432 switch (request) {
433 case CoordinatedVideoAdapter::DOWNGRADE:
434 *num_pixels /= 2;
435 break;
436
437 case CoordinatedVideoAdapter::UPGRADE:
438 *num_pixels *= 2;
439 break;
440
441 default: // No change in pixel count
442 break;
443 }
444 return;
445}
446
447// Find the adaptation request of the cpu based on the load. Return UPGRADE if
448// the load is low, DOWNGRADE if the load is high, and KEEP otherwise.
449CoordinatedVideoAdapter::AdaptRequest CoordinatedVideoAdapter::FindCpuRequest(
450 int current_cpus, int max_cpus,
451 float process_load, float system_load) {
452 // Downgrade if system is high and plugin is at least more than midrange.
453 if (system_load >= high_system_threshold_ * max_cpus &&
454 process_load >= process_threshold_ * current_cpus) {
455 return CoordinatedVideoAdapter::DOWNGRADE;
456 // Upgrade if system is low.
457 } else if (system_load < low_system_threshold_ * max_cpus) {
458 return CoordinatedVideoAdapter::UPGRADE;
459 }
460 return CoordinatedVideoAdapter::KEEP;
461}
462
463// A remote view request for a new resolution.
464void CoordinatedVideoAdapter::OnOutputFormatRequest(const VideoFormat& format) {
465 talk_base::CritScope cs(&request_critical_section_);
466 if (!view_adaptation_) {
467 return;
468 }
469 // Set output for initial aspect ratio in mediachannel unittests.
470 int old_num_pixels = GetOutputNumPixels();
471 SetOutputFormat(format);
472 SetOutputNumPixels(old_num_pixels);
473 view_desired_num_pixels_ = format.width * format.height;
474 view_desired_interval_ = format.interval;
475 int new_width, new_height;
476 bool changed = AdaptToMinimumFormat(&new_width, &new_height);
477 LOG(LS_INFO) << "VAdapt View Request: "
478 << format.width << "x" << format.height
479 << " Pixels: " << view_desired_num_pixels_
480 << " Changed: " << (changed ? "true" : "false")
481 << " To: " << new_width << "x" << new_height;
482}
483
484// A Bandwidth GD request for new resolution
485void CoordinatedVideoAdapter::OnEncoderResolutionRequest(
486 int width, int height, AdaptRequest request) {
487 talk_base::CritScope cs(&request_critical_section_);
488 if (!gd_adaptation_) {
489 return;
490 }
491 int old_encoder_desired_num_pixels = encoder_desired_num_pixels_;
492 if (KEEP != request) {
493 int new_encoder_desired_num_pixels = width * height;
494 int old_num_pixels = GetOutputNumPixels();
495 if (new_encoder_desired_num_pixels != old_num_pixels) {
496 LOG(LS_VERBOSE) << "VAdapt GD resolution stale. Ignored";
497 } else {
498 // Update the encoder desired format based on the request.
499 encoder_desired_num_pixels_ = new_encoder_desired_num_pixels;
500 StepPixelCount(request, &encoder_desired_num_pixels_);
501 }
502 }
503 int new_width, new_height;
504 bool changed = AdaptToMinimumFormat(&new_width, &new_height);
505
506 // Ignore up or keep if no change.
507 if (DOWNGRADE != request && view_switch_ && !changed) {
508 encoder_desired_num_pixels_ = old_encoder_desired_num_pixels;
509 LOG(LS_VERBOSE) << "VAdapt ignoring GD request.";
510 }
511
512 LOG(LS_INFO) << "VAdapt GD Request: "
513 << (DOWNGRADE == request ? "down" :
514 (UPGRADE == request ? "up" : "keep"))
515 << " From: " << width << "x" << height
516 << " Pixels: " << encoder_desired_num_pixels_
517 << " Changed: " << (changed ? "true" : "false")
518 << " To: " << new_width << "x" << new_height;
519}
520
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000521// A Bandwidth GD request for new resolution
522void CoordinatedVideoAdapter::OnCpuResolutionRequest(AdaptRequest request) {
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000523 talk_base::CritScope cs(&request_critical_section_);
524 if (!cpu_adaptation_) {
525 return;
526 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000527 // Update how many times we have downgraded due to the cpu load.
528 switch (request) {
529 case DOWNGRADE:
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000530 // Ignore downgrades if we have downgraded the maximum times.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000531 if (cpu_downgrade_count_ < kMaxCpuDowngrades) {
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000532 ++cpu_downgrade_count_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000533 } else {
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000534 LOG(LS_VERBOSE) << "VAdapt CPU load high but do not downgrade "
535 "because maximum downgrades reached";
536 SignalCpuAdaptationUnable();
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000537 }
538 break;
539 case UPGRADE:
540 if (cpu_downgrade_count_ > 0) {
541 bool is_min = IsMinimumFormat(cpu_desired_num_pixels_);
542 if (is_min) {
543 --cpu_downgrade_count_;
544 } else {
545 LOG(LS_VERBOSE) << "VAdapt CPU load low but do not upgrade "
546 "because cpu is not limiting resolution";
547 }
548 } else {
549 LOG(LS_VERBOSE) << "VAdapt CPU load low but do not upgrade "
550 "because minimum downgrades reached";
551 }
552 break;
553 case KEEP:
554 default:
555 break;
556 }
557 if (KEEP != request) {
558 // TODO(fbarchard): compute stepping up/down from OutputNumPixels but
559 // clamp to inputpixels / 4 (2 steps)
560 cpu_desired_num_pixels_ = cpu_downgrade_count_ == 0 ? INT_MAX :
561 static_cast<int>(input_format().width * input_format().height >>
562 cpu_downgrade_count_);
563 }
564 int new_width, new_height;
565 bool changed = AdaptToMinimumFormat(&new_width, &new_height);
566 LOG(LS_INFO) << "VAdapt CPU Request: "
567 << (DOWNGRADE == request ? "down" :
568 (UPGRADE == request ? "up" : "keep"))
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000569 << " Steps: " << cpu_downgrade_count_
570 << " Changed: " << (changed ? "true" : "false")
571 << " To: " << new_width << "x" << new_height;
572}
573
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000574// A CPU request for new resolution
575// TODO(fbarchard): Move outside adapter.
576void CoordinatedVideoAdapter::OnCpuLoadUpdated(
577 int current_cpus, int max_cpus, float process_load, float system_load) {
578 talk_base::CritScope cs(&request_critical_section_);
579 if (!cpu_adaptation_) {
580 return;
581 }
582 // Update the moving average of system load. Even if we aren't smoothing,
583 // we'll still calculate this information, in case smoothing is later enabled.
584 system_load_average_ = kCpuLoadWeightCoefficient * system_load +
585 (1.0f - kCpuLoadWeightCoefficient) * system_load_average_;
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000586 ++cpu_load_num_samples_;
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000587 if (cpu_smoothing_) {
588 system_load = system_load_average_;
589 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000590 AdaptRequest request = FindCpuRequest(current_cpus, max_cpus,
591 process_load, system_load);
592 // Make sure we're not adapting too quickly.
593 if (request != KEEP) {
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000594 if (cpu_load_num_samples_ < cpu_load_min_samples_) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000595 LOG(LS_VERBOSE) << "VAdapt CPU load high/low but do not adapt until "
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000596 << (cpu_load_min_samples_ - cpu_load_num_samples_)
597 << " more samples";
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000598 request = KEEP;
599 }
600 }
601
602 OnCpuResolutionRequest(request);
603}
604
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000605// Called by cpu adapter on up requests.
606bool CoordinatedVideoAdapter::IsMinimumFormat(int pixels) {
607 // Find closest scale factor that matches input resolution to min_num_pixels
608 // and set that for output resolution. This is not needed for VideoAdapter,
609 // but provides feedback to unittests and users on expected resolution.
610 // Actual resolution is based on input frame.
611 VideoFormat new_output = output_format();
612 VideoFormat input = input_format();
613 if (input_format().IsSize0x0()) {
614 input = new_output;
615 }
616 float scale = 1.0f;
617 if (!input.IsSize0x0()) {
618 scale = FindClosestScale(input.width,
619 input.height,
620 pixels);
621 }
622 new_output.width = static_cast<int>(input.width * scale + .5f);
623 new_output.height = static_cast<int>(input.height * scale + .5f);
624 int new_pixels = new_output.width * new_output.height;
625 int num_pixels = GetOutputNumPixels();
626 return new_pixels <= num_pixels;
627}
628
629// Called by all coordinators when there is a change.
630bool CoordinatedVideoAdapter::AdaptToMinimumFormat(int* new_width,
631 int* new_height) {
632 VideoFormat new_output = output_format();
633 VideoFormat input = input_format();
634 if (input_format().IsSize0x0()) {
635 input = new_output;
636 }
637 int old_num_pixels = GetOutputNumPixels();
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000638 int min_num_pixels = INT_MAX;
xians@webrtc.orgef221512014-02-21 10:31:29 +0000639 adapt_reason_ = 0;
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000640
641 // Reduce resolution based on encoder bandwidth (GD).
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000642 if (encoder_desired_num_pixels_ &&
643 (encoder_desired_num_pixels_ < min_num_pixels)) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000644 adapt_reason_ |= ADAPTREASON_BANDWIDTH;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000645 min_num_pixels = encoder_desired_num_pixels_;
646 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000647 // Reduce resolution based on CPU.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000648 if (cpu_adaptation_ && cpu_desired_num_pixels_ &&
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000649 (cpu_desired_num_pixels_ <= min_num_pixels)) {
650 if (cpu_desired_num_pixels_ < min_num_pixels) {
651 adapt_reason_ = ADAPTREASON_CPU;
652 } else {
653 adapt_reason_ |= ADAPTREASON_CPU;
654 }
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000655 min_num_pixels = cpu_desired_num_pixels_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000656 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000657 // Round resolution for GD or CPU to allow 1/2 to map to 9/16.
658 if (!input.IsSize0x0() && min_num_pixels != INT_MAX) {
659 float scale = FindClosestScale(input.width, input.height, min_num_pixels);
660 min_num_pixels = static_cast<int>(input.width * scale + .5f) *
661 static_cast<int>(input.height * scale + .5f);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000662 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000663 // Reduce resolution based on View Request.
664 if (view_desired_num_pixels_ <= min_num_pixels) {
665 if (view_desired_num_pixels_ < min_num_pixels) {
666 adapt_reason_ = ADAPTREASON_VIEW;
667 } else {
668 adapt_reason_ |= ADAPTREASON_VIEW;
669 }
670 min_num_pixels = view_desired_num_pixels_;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000671 }
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000672 // Snap to a scale factor.
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000673 float scale = 1.0f;
674 if (!input.IsSize0x0()) {
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000675 scale = FindLowerScale(input.width, input.height, min_num_pixels);
676 min_num_pixels = static_cast<int>(input.width * scale + .5f) *
677 static_cast<int>(input.height * scale + .5f);
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000678 }
679 if (scale == 1.0f) {
xians@webrtc.orgef221512014-02-21 10:31:29 +0000680 adapt_reason_ = 0;
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000681 }
682 *new_width = new_output.width = static_cast<int>(input.width * scale + .5f);
683 *new_height = new_output.height = static_cast<int>(input.height * scale +
684 .5f);
wu@webrtc.orgcadf9042013-08-30 21:24:16 +0000685 SetOutputNumPixels(min_num_pixels);
686
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000687 new_output.interval = view_desired_interval_;
688 SetOutputFormat(new_output);
689 int new_num_pixels = GetOutputNumPixels();
690 bool changed = new_num_pixels != old_num_pixels;
691
692 static const char* kReasons[8] = {
693 "None",
694 "CPU",
695 "BANDWIDTH",
696 "CPU+BANDWIDTH",
697 "VIEW",
698 "CPU+VIEW",
699 "BANDWIDTH+VIEW",
700 "CPU+BANDWIDTH+VIEW",
701 };
702
703 LOG(LS_VERBOSE) << "VAdapt Status View: " << view_desired_num_pixels_
704 << " GD: " << encoder_desired_num_pixels_
705 << " CPU: " << cpu_desired_num_pixels_
706 << " Pixels: " << min_num_pixels
707 << " Input: " << input.width
708 << "x" << input.height
709 << " Scale: " << scale
710 << " Resolution: " << new_output.width
711 << "x" << new_output.height
712 << " Changed: " << (changed ? "true" : "false")
713 << " Reason: " << kReasons[adapt_reason_];
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000714
715 if (changed) {
716 // When any adaptation occurs, historic CPU load levels are no longer
717 // accurate. Clear out our state so we can re-learn at the new normal.
mallinath@webrtc.org67ee6b92014-02-03 16:57:16 +0000718 cpu_load_num_samples_ = 0;
henrike@webrtc.org28654cb2013-07-22 21:07:49 +0000719 system_load_average_ = kCpuLoadInitialAverage;
720 }
721
henrike@webrtc.org28e20752013-07-10 00:45:36 +0000722 return changed;
723}
724
725} // namespace cricket