remoting/host/capture_scheduler_unittest.cc

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "remoting/host/capture_scheduler.h"
   6 #include "testing/gtest/include/gtest/gtest.h"
   7
   8 namespace remoting {
   9
  10 static const int kTestInputs[] = { 100, 50, 30, 20, 10, 30, 60, 80 };
  11 static const int kMinumumFrameIntervalMs = 50;
  12
  13 TEST(CaptureSchedulerTest, SingleSampleSameTimes) {
  14   const int kTestResults[][arraysize(kTestInputs)] = {
  15     { 400, 200, 120, 80, 50, 120, 240, 320 }, // One core.
  16     { 200, 100, 60, 50, 50, 60, 120, 160 },   // Two cores.
  17     { 100, 50, 50, 50, 50, 50, 60, 80 },      // Four cores.
  18     { 50, 50, 50, 50, 50, 50, 50, 50 }        // Eight cores.
  19   };
  20
  21   for (size_t i = 0; i < arraysize(kTestResults); ++i) {
  22     for (size_t j = 0; j < arraysize(kTestInputs); ++j) {
  23       CaptureScheduler scheduler;
  24       scheduler.SetNumOfProcessorsForTest(1 << i);
  25       scheduler.set_minimum_interval(
  26           base::TimeDelta::FromMilliseconds(kMinumumFrameIntervalMs));
  27       scheduler.RecordCaptureTime(
  28           base::TimeDelta::FromMilliseconds(kTestInputs[j]));
  29       scheduler.RecordEncodeTime(
  30           base::TimeDelta::FromMilliseconds(kTestInputs[j]));
  31       EXPECT_EQ(kTestResults[i][j],
  32                 scheduler.NextCaptureDelay().InMilliseconds()) << i  << " "<< j;
  33     }
  34   }
  35 }
  36
  37 TEST(CaptureSchedulerTest, SingleSampleDifferentTimes) {
  38   const int kTestResults[][arraysize(kTestInputs)] = {
  39     { 360, 220, 120, 60, 60, 120, 220, 360 }, // One core.
  40     { 180, 110, 60, 50, 50, 60, 110, 180 },   // Two cores.
  41     { 90, 55, 50, 50, 50, 50, 55, 90 },       // Four cores.
  42     { 50, 50, 50, 50, 50, 50, 50, 50 }        // Eight cores.
  43   };
  44
  45   for (size_t i = 0; i < arraysize(kTestResults); ++i) {
  46     for (size_t j = 0; j < arraysize(kTestInputs); ++j) {
  47       CaptureScheduler scheduler;
  48       scheduler.SetNumOfProcessorsForTest(1 << i);
  49       scheduler.set_minimum_interval(
  50           base::TimeDelta::FromMilliseconds(kMinumumFrameIntervalMs));
  51       scheduler.RecordCaptureTime(
  52           base::TimeDelta::FromMilliseconds(kTestInputs[j]));
  53       scheduler.RecordEncodeTime(
  54           base::TimeDelta::FromMilliseconds(
  55               kTestInputs[arraysize(kTestInputs) - 1 - j]));
  56       EXPECT_EQ(kTestResults[i][j],
  57                 scheduler.NextCaptureDelay().InMilliseconds());
  58     }
  59   }
  60 }
  61
  62 TEST(CaptureSchedulerTest, RollingAverageDifferentTimes) {
  63   const int kTestResults[][arraysize(kTestInputs)] = {
  64     { 360, 290, 233, 133, 80, 80, 133, 233 }, // One core.
  65     { 180, 145, 116, 66, 50, 50, 66, 116 },   // Two cores.
  66     { 90, 72, 58, 50, 50, 50, 50, 58 },       // Four cores.
  67     { 50, 50, 50, 50, 50, 50, 50, 50 }        // Eight cores.
  68   };
  69
  70   for (size_t i = 0; i < arraysize(kTestResults); ++i) {
  71     CaptureScheduler scheduler;
  72     scheduler.SetNumOfProcessorsForTest(1 << i);
  73     scheduler.set_minimum_interval(
  74         base::TimeDelta::FromMilliseconds(kMinumumFrameIntervalMs));
  75     for (size_t j = 0; j < arraysize(kTestInputs); ++j) {
  76       scheduler.RecordCaptureTime(
  77           base::TimeDelta::FromMilliseconds(kTestInputs[j]));
  78       scheduler.RecordEncodeTime(
  79           base::TimeDelta::FromMilliseconds(
  80               kTestInputs[arraysize(kTestInputs) - 1 - j]));
  81       EXPECT_EQ(kTestResults[i][j],
  82                 scheduler.NextCaptureDelay().InMilliseconds());
  83     }
  84   }
  85 }
  86
  87 }  // namespace remoting