Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(252)

Side by Side Diff: webrtc/video/video_quality_test.cc

Issue 1469013002: Move ThreadWrapper to ProcessThread in base. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: removed comment Created 5 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « webrtc/video/video_capture_input.cc ('k') | webrtc/video/video_send_stream_tests.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source 5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 #include <stdio.h> 10 #include <stdio.h>
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after
84 static const uint32_t kMaxComparisonThreads = 8; 84 static const uint32_t kMaxComparisonThreads = 8;
85 85
86 if (num_cores <= kMinCoresLeft) { 86 if (num_cores <= kMinCoresLeft) {
87 num_cores = 1; 87 num_cores = 1;
88 } else { 88 } else {
89 num_cores -= kMinCoresLeft; 89 num_cores -= kMinCoresLeft;
90 num_cores = std::min(num_cores, kMaxComparisonThreads); 90 num_cores = std::min(num_cores, kMaxComparisonThreads);
91 } 91 }
92 92
93 for (uint32_t i = 0; i < num_cores; ++i) { 93 for (uint32_t i = 0; i < num_cores; ++i) {
94 rtc::scoped_ptr<ThreadWrapper> thread = 94 rtc::scoped_ptr<PlatformThread> thread = PlatformThread::CreateThread(
95 ThreadWrapper::CreateThread(&FrameComparisonThread, this, "Analyzer"); 95 &FrameComparisonThread, this, "Analyzer");
96 EXPECT_TRUE(thread->Start()); 96 EXPECT_TRUE(thread->Start());
97 comparison_thread_pool_.push_back(thread.release()); 97 comparison_thread_pool_.push_back(thread.release());
98 } 98 }
99 99
100 stats_polling_thread_ = 100 stats_polling_thread_ =
101 ThreadWrapper::CreateThread(&PollStatsThread, this, "StatsPoller"); 101 PlatformThread::CreateThread(&PollStatsThread, this, "StatsPoller");
102 } 102 }
103 103
104 ~VideoAnalyzer() { 104 ~VideoAnalyzer() {
105 for (ThreadWrapper* thread : comparison_thread_pool_) { 105 for (PlatformThread* thread : comparison_thread_pool_) {
106 EXPECT_TRUE(thread->Stop()); 106 EXPECT_TRUE(thread->Stop());
107 delete thread; 107 delete thread;
108 } 108 }
109 } 109 }
110 110
111 virtual void SetReceiver(PacketReceiver* receiver) { receiver_ = receiver; } 111 virtual void SetReceiver(PacketReceiver* receiver) { receiver_ = receiver; }
112 112
113 DeliveryStatus DeliverPacket(MediaType media_type, 113 DeliveryStatus DeliverPacket(MediaType media_type,
114 const uint8_t* packet, 114 const uint8_t* packet,
115 size_t length, 115 size_t length,
(...skipping 479 matching lines...) Expand 10 before | Expand all | Expand 10 after
595 std::deque<VideoFrame> frames_ GUARDED_BY(crit_); 595 std::deque<VideoFrame> frames_ GUARDED_BY(crit_);
596 VideoFrame last_rendered_frame_ GUARDED_BY(crit_); 596 VideoFrame last_rendered_frame_ GUARDED_BY(crit_);
597 std::map<uint32_t, int64_t> send_times_ GUARDED_BY(crit_); 597 std::map<uint32_t, int64_t> send_times_ GUARDED_BY(crit_);
598 std::map<uint32_t, int64_t> recv_times_ GUARDED_BY(crit_); 598 std::map<uint32_t, int64_t> recv_times_ GUARDED_BY(crit_);
599 std::map<uint32_t, size_t> encoded_frame_sizes_ GUARDED_BY(crit_); 599 std::map<uint32_t, size_t> encoded_frame_sizes_ GUARDED_BY(crit_);
600 VideoFrame first_send_frame_ GUARDED_BY(crit_); 600 VideoFrame first_send_frame_ GUARDED_BY(crit_);
601 const double avg_psnr_threshold_; 601 const double avg_psnr_threshold_;
602 const double avg_ssim_threshold_; 602 const double avg_ssim_threshold_;
603 603
604 rtc::CriticalSection comparison_lock_; 604 rtc::CriticalSection comparison_lock_;
605 std::vector<ThreadWrapper*> comparison_thread_pool_; 605 std::vector<PlatformThread*> comparison_thread_pool_;
606 rtc::scoped_ptr<ThreadWrapper> stats_polling_thread_; 606 rtc::scoped_ptr<PlatformThread> stats_polling_thread_;
607 const rtc::scoped_ptr<EventWrapper> comparison_available_event_; 607 const rtc::scoped_ptr<EventWrapper> comparison_available_event_;
608 std::deque<FrameComparison> comparisons_ GUARDED_BY(comparison_lock_); 608 std::deque<FrameComparison> comparisons_ GUARDED_BY(comparison_lock_);
609 const rtc::scoped_ptr<EventWrapper> done_; 609 const rtc::scoped_ptr<EventWrapper> done_;
610 }; 610 };
611 611
612 VideoQualityTest::VideoQualityTest() : clock_(Clock::GetRealTimeClock()) {} 612 VideoQualityTest::VideoQualityTest() : clock_(Clock::GetRealTimeClock()) {}
613 613
614 void VideoQualityTest::TestBody() {} 614 void VideoQualityTest::TestBody() {}
615 615
616 std::string VideoQualityTest::GenerateGraphTitle() const { 616 std::string VideoQualityTest::GenerateGraphTitle() const {
(...skipping 448 matching lines...) Expand 10 before | Expand all | Expand 10 after
1065 send_stream_->Stop(); 1065 send_stream_->Stop();
1066 receive_stream->Stop(); 1066 receive_stream->Stop();
1067 1067
1068 call->DestroyVideoReceiveStream(receive_stream); 1068 call->DestroyVideoReceiveStream(receive_stream);
1069 call->DestroyVideoSendStream(send_stream_); 1069 call->DestroyVideoSendStream(send_stream_);
1070 1070
1071 transport.StopSending(); 1071 transport.StopSending();
1072 } 1072 }
1073 1073
1074 } // namespace webrtc 1074 } // namespace webrtc
OLDNEW
« no previous file with comments | « webrtc/video/video_capture_input.cc ('k') | webrtc/video/video_send_stream_tests.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698