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