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

Side by Side Diff: webrtc/common_video/i420_buffer_pool.cc

Issue 2009193002: Delete IsMutable and IsExclusive methods. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Delete redundant RefCountedObject wrapping. Created 4 years, 7 months 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 | « no previous file | webrtc/common_video/i420_buffer_pool_unittest.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 10
11 #include "webrtc/common_video/include/i420_buffer_pool.h" 11 #include "webrtc/common_video/include/i420_buffer_pool.h"
12 12
13 #include "webrtc/base/checks.h" 13 #include "webrtc/base/checks.h"
14 14
15 namespace {
16
17 // One extra indirection is needed to make |HasOneRef| work.
18 class PooledI420Buffer : public webrtc::VideoFrameBuffer {
19 public:
20 explicit PooledI420Buffer(
21 const rtc::scoped_refptr<webrtc::I420Buffer>& buffer)
22 : buffer_(buffer) {}
23
24 private:
25 ~PooledI420Buffer() override {}
26
27 int width() const override { return buffer_->width(); }
28 int height() const override { return buffer_->height(); }
29 const uint8_t* DataY() const override { return buffer_->DataY(); }
30 const uint8_t* DataU() const override { return buffer_->DataU(); }
31 const uint8_t* DataV() const override { return buffer_->DataV(); }
32
33 bool IsMutable() override { return HasOneRef(); }
34 // Make the IsMutable() check here instead of in |buffer_|, because the pool
35 // also has a reference to |buffer_|.
36 uint8_t* MutableDataY() override {
37 RTC_DCHECK(IsMutable());
38 return const_cast<uint8_t*>(buffer_->DataY());
39 }
40 uint8_t* MutableDataU() override {
41 RTC_DCHECK(IsMutable());
42 return const_cast<uint8_t*>(buffer_->DataU());
43 }
44 uint8_t* MutableDataV() override {
45 RTC_DCHECK(IsMutable());
46 return const_cast<uint8_t*>(buffer_->DataV());
47 }
48 int StrideY() const override { return buffer_->StrideY(); }
49 int StrideU() const override { return buffer_->StrideU(); }
50 int StrideV() const override { return buffer_->StrideV(); }
51 void* native_handle() const override { return nullptr; }
52
53 rtc::scoped_refptr<VideoFrameBuffer> NativeToI420Buffer() override {
54 RTC_NOTREACHED();
55 return nullptr;
56 }
57
58 friend class rtc::RefCountedObject<PooledI420Buffer>;
59 rtc::scoped_refptr<webrtc::I420Buffer> buffer_;
60 };
61
62 } // namespace
63
64 namespace webrtc { 15 namespace webrtc {
65 16
66 I420BufferPool::I420BufferPool(bool zero_initialize) 17 I420BufferPool::I420BufferPool(bool zero_initialize)
67 : zero_initialize_(zero_initialize) { 18 : zero_initialize_(zero_initialize) {
68 Release(); 19 thread_checker_.DetachFromThread();
69 } 20 }
70 21
71 void I420BufferPool::Release() { 22 void I420BufferPool::Release() {
72 thread_checker_.DetachFromThread(); 23 thread_checker_.DetachFromThread();
73 buffers_.clear(); 24 buffers_.clear();
74 } 25 }
75 26
76 rtc::scoped_refptr<VideoFrameBuffer> I420BufferPool::CreateBuffer(int width, 27 rtc::scoped_refptr<I420Buffer> I420BufferPool::CreateBuffer(int width,
77 int height) { 28 int height) {
78 RTC_DCHECK(thread_checker_.CalledOnValidThread()); 29 RTC_DCHECK(thread_checker_.CalledOnValidThread());
79 // Release buffers with wrong resolution. 30 // Release buffers with wrong resolution.
80 for (auto it = buffers_.begin(); it != buffers_.end();) { 31 for (auto it = buffers_.begin(); it != buffers_.end();) {
81 if ((*it)->width() != width || (*it)->height() != height) 32 if ((*it)->width() != width || (*it)->height() != height)
82 it = buffers_.erase(it); 33 it = buffers_.erase(it);
83 else 34 else
84 ++it; 35 ++it;
85 } 36 }
86 // Look for a free buffer. 37 // Look for a free buffer.
87 for (const rtc::scoped_refptr<I420Buffer>& buffer : buffers_) { 38 for (const rtc::scoped_refptr<PooledI420Buffer>& buffer : buffers_) {
88 // If the buffer is in use, the ref count will be 2, one from the list we 39 // If the buffer is in use, the ref count will be >= 2, one from the list we
89 // are looping over and one from a PooledI420Buffer returned from 40 // are looping over and one from the application. If the ref count is 1,
90 // CreateBuffer that has not been released yet. If the ref count is 1 41 // then the list we are looping over holds the only reference and it's safe
91 // (HasOneRef), then the list we are looping over holds the only reference 42 // to reuse.
92 // and it's safe to reuse. 43 if (buffer->HasOneRef())
93 if (buffer->IsMutable()) 44 return buffer;
94 return new rtc::RefCountedObject<PooledI420Buffer>(buffer);
95 } 45 }
96 // Allocate new buffer. 46 // Allocate new buffer.
97 rtc::scoped_refptr<I420Buffer> buffer = new rtc::RefCountedObject<I420Buffer>( 47 rtc::scoped_refptr<PooledI420Buffer> buffer =
98 width, height); 48 new PooledI420Buffer(width, height);
99 if (zero_initialize_) 49 if (zero_initialize_)
100 buffer->InitializeData(); 50 buffer->InitializeData();
101 buffers_.push_back(buffer); 51 buffers_.push_back(buffer);
102 return new rtc::RefCountedObject<PooledI420Buffer>(buffers_.back()); 52 return buffer;
103 } 53 }
104 54
105 } // namespace webrtc 55 } // namespace webrtc
OLDNEW
« no previous file with comments | « no previous file | webrtc/common_video/i420_buffer_pool_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698