OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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 "content/browser/renderer_host/media/video_capture_buffer_pool.h" | 5 #include "content/browser/renderer_host/media/video_capture_buffer_pool.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/memory/scoped_ptr.h" | 8 #include "base/memory/scoped_ptr.h" |
9 #include "base/memory/scoped_vector.h" | 9 #include "base/memory/scoped_vector.h" |
10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
57 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) | 57 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) |
58 const base::SharedMemoryHandle handle_; | 58 const base::SharedMemoryHandle handle_; |
59 #endif | 59 #endif |
60 }; | 60 }; |
61 | 61 |
62 // A holder of a GpuMemoryBuffer-backed buffer. Holds weak references to | 62 // A holder of a GpuMemoryBuffer-backed buffer. Holds weak references to |
63 // GpuMemoryBuffer-backed buffers and provides accessors to their data. | 63 // GpuMemoryBuffer-backed buffers and provides accessors to their data. |
64 class GpuMemoryBufferBufferHandle final | 64 class GpuMemoryBufferBufferHandle final |
65 : public VideoCaptureBufferPool::BufferHandle { | 65 : public VideoCaptureBufferPool::BufferHandle { |
66 public: | 66 public: |
67 GpuMemoryBufferBufferHandle(const std::vector<void*>& data, | 67 GpuMemoryBufferBufferHandle(const gfx::Size& dimensions, |
68 const gfx::Size& dimensions, | |
69 ScopedVector<gfx::GpuMemoryBuffer>* gmbs) | 68 ScopedVector<gfx::GpuMemoryBuffer>* gmbs) |
70 : data_(data), dimensions_(dimensions), gmbs_(gmbs) { | 69 : dimensions_(dimensions), gmbs_(gmbs) { |
71 #ifndef NDEBUG | 70 DCHECK(gmbs); |
72 DCHECK_EQ(data.size(), gmbs->size()); | |
73 for (const auto& gmb : *gmbs) | |
74 DCHECK(gmb); | |
75 for (const auto& data_ptr : data) | |
76 DCHECK(data_ptr); | |
77 #endif | |
78 } | 71 } |
79 ~GpuMemoryBufferBufferHandle() override {} | 72 ~GpuMemoryBufferBufferHandle() override {} |
80 | 73 |
81 gfx::Size dimensions() const override { return dimensions_; } | 74 gfx::Size dimensions() const override { return dimensions_; } |
82 size_t mapped_size() const override { return dimensions_.GetArea(); } | 75 size_t mapped_size() const override { return dimensions_.GetArea(); } |
83 void* data(int plane) override { | 76 void* data(int plane) override { |
84 DCHECK_GE(plane, media::VideoFrame::kYPlane); | 77 DCHECK_GE(plane, 0); |
85 DCHECK_LT(plane, static_cast<int>(data_.size())); | 78 DCHECK_LT(plane, static_cast<int>(gmbs_->size())); |
86 return data_.at(plane); | 79 DCHECK((*gmbs_)[plane]); |
| 80 return (*gmbs_)[plane]->memory(0); |
87 } | 81 } |
88 ClientBuffer AsClientBuffer(int plane) override { | 82 ClientBuffer AsClientBuffer(int plane) override { |
89 DCHECK_GE(plane, media::VideoFrame::kYPlane); | 83 DCHECK_GE(plane, 0); |
90 DCHECK_LT(plane, static_cast<int>(gmbs_->size())); | 84 DCHECK_LT(plane, static_cast<int>(gmbs_->size())); |
91 return (*gmbs_)[plane]->AsClientBuffer(); | 85 return (*gmbs_)[plane]->AsClientBuffer(); |
92 } | 86 } |
93 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) | 87 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) |
94 base::FileDescriptor AsPlatformFile() override { | 88 base::FileDescriptor AsPlatformFile() override { |
95 NOTREACHED(); | 89 NOTREACHED(); |
96 return base::FileDescriptor(); | 90 return base::FileDescriptor(); |
97 } | 91 } |
98 #endif | 92 #endif |
99 | 93 |
100 private: | 94 private: |
101 const std::vector<void*> data_; | |
102 const gfx::Size dimensions_; | 95 const gfx::Size dimensions_; |
103 ScopedVector<gfx::GpuMemoryBuffer>* const gmbs_; | 96 ScopedVector<gfx::GpuMemoryBuffer>* const gmbs_; |
104 }; | 97 }; |
105 | 98 |
106 // Tracker specifics for SharedMemory. | 99 // Tracker specifics for SharedMemory. |
107 class VideoCaptureBufferPool::SharedMemTracker final : public Tracker { | 100 class VideoCaptureBufferPool::SharedMemTracker final : public Tracker { |
108 public: | 101 public: |
109 SharedMemTracker(); | 102 SharedMemTracker(); |
110 bool Init(media::VideoPixelFormat format, | 103 bool Init(media::VideoPixelFormat format, |
111 media::VideoPixelStorage storage_type, | 104 media::VideoPixelStorage storage_type, |
(...skipping 26 matching lines...) Expand all Loading... |
138 class VideoCaptureBufferPool::GpuMemoryBufferTracker final : public Tracker { | 131 class VideoCaptureBufferPool::GpuMemoryBufferTracker final : public Tracker { |
139 public: | 132 public: |
140 GpuMemoryBufferTracker(); | 133 GpuMemoryBufferTracker(); |
141 bool Init(media::VideoPixelFormat format, | 134 bool Init(media::VideoPixelFormat format, |
142 media::VideoPixelStorage storage_type, | 135 media::VideoPixelStorage storage_type, |
143 const gfx::Size& dimensions, | 136 const gfx::Size& dimensions, |
144 base::Lock* lock) override; | 137 base::Lock* lock) override; |
145 ~GpuMemoryBufferTracker() override; | 138 ~GpuMemoryBufferTracker() override; |
146 | 139 |
147 scoped_ptr<BufferHandle> GetBufferHandle() override { | 140 scoped_ptr<BufferHandle> GetBufferHandle() override { |
148 std::vector<void*> data; | |
149 DCHECK_EQ(gpu_memory_buffers_.size(), | 141 DCHECK_EQ(gpu_memory_buffers_.size(), |
150 media::VideoFrame::NumPlanes(pixel_format())); | 142 media::VideoFrame::NumPlanes(pixel_format())); |
151 for (const auto& gmb : gpu_memory_buffers_) | 143 return make_scoped_ptr( |
152 data.push_back(gmb->memory(0)); | 144 new GpuMemoryBufferBufferHandle(dimensions_, &gpu_memory_buffers_)); |
153 return make_scoped_ptr(new GpuMemoryBufferBufferHandle( | |
154 data, dimensions_, &gpu_memory_buffers_)); | |
155 } | 145 } |
156 bool ShareToProcess(base::ProcessHandle process_handle, | 146 bool ShareToProcess(base::ProcessHandle process_handle, |
157 base::SharedMemoryHandle* new_handle) override { | 147 base::SharedMemoryHandle* new_handle) override { |
158 NOTREACHED(); | 148 NOTREACHED(); |
159 return false; | 149 return false; |
160 } | 150 } |
161 bool ShareToProcess2(int plane, | 151 bool ShareToProcess2(int plane, |
162 base::ProcessHandle process_handle, | 152 base::ProcessHandle process_handle, |
163 gfx::GpuMemoryBufferHandle* new_handle) override; | 153 gfx::GpuMemoryBufferHandle* new_handle) override; |
164 | 154 |
(...skipping 300 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
465 return buffer_id; | 455 return buffer_id; |
466 } | 456 } |
467 | 457 |
468 VideoCaptureBufferPool::Tracker* VideoCaptureBufferPool::GetTracker( | 458 VideoCaptureBufferPool::Tracker* VideoCaptureBufferPool::GetTracker( |
469 int buffer_id) { | 459 int buffer_id) { |
470 TrackerMap::const_iterator it = trackers_.find(buffer_id); | 460 TrackerMap::const_iterator it = trackers_.find(buffer_id); |
471 return (it == trackers_.end()) ? NULL : it->second; | 461 return (it == trackers_.end()) ? NULL : it->second; |
472 } | 462 } |
473 | 463 |
474 } // namespace content | 464 } // namespace content |
OLD | NEW |