OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "gpu/command_buffer/service/query_manager.h" | 5 #include "gpu/command_buffer/service/query_manager.h" |
6 | 6 |
7 #include "base/atomicops.h" | 7 #include "base/atomicops.h" |
8 #include "base/bind.h" | 8 #include "base/bind.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/memory/shared_memory.h" | 10 #include "base/memory/shared_memory.h" |
| 11 #include "base/numerics/safe_math.h" |
11 #include "base/synchronization/lock.h" | 12 #include "base/synchronization/lock.h" |
12 #include "base/time/time.h" | 13 #include "base/time/time.h" |
13 #include "gpu/command_buffer/common/gles2_cmd_format.h" | 14 #include "gpu/command_buffer/common/gles2_cmd_format.h" |
14 #include "gpu/command_buffer/service/async_pixel_transfer_manager.h" | 15 #include "gpu/command_buffer/service/async_pixel_transfer_manager.h" |
15 #include "gpu/command_buffer/service/error_state.h" | 16 #include "gpu/command_buffer/service/error_state.h" |
16 #include "gpu/command_buffer/service/feature_info.h" | 17 #include "gpu/command_buffer/service/feature_info.h" |
17 #include "gpu/command_buffer/service/gles2_cmd_decoder.h" | 18 #include "gpu/command_buffer/service/gles2_cmd_decoder.h" |
18 | 19 |
19 namespace gpu { | 20 namespace gpu { |
20 namespace gles2 { | 21 namespace gles2 { |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
88 AsyncMemoryParams mem_params; | 89 AsyncMemoryParams mem_params; |
89 // Get the real shared memory since it might need to be duped to prevent | 90 // Get the real shared memory since it might need to be duped to prevent |
90 // use-after-free of the memory. | 91 // use-after-free of the memory. |
91 Buffer buffer = manager()->decoder()->GetSharedMemoryBuffer(shm_id()); | 92 Buffer buffer = manager()->decoder()->GetSharedMemoryBuffer(shm_id()); |
92 if (!buffer.shared_memory) | 93 if (!buffer.shared_memory) |
93 return false; | 94 return false; |
94 mem_params.shared_memory = buffer.shared_memory; | 95 mem_params.shared_memory = buffer.shared_memory; |
95 mem_params.shm_size = buffer.size; | 96 mem_params.shm_size = buffer.size; |
96 mem_params.shm_data_offset = shm_offset(); | 97 mem_params.shm_data_offset = shm_offset(); |
97 mem_params.shm_data_size = sizeof(QuerySync); | 98 mem_params.shm_data_size = sizeof(QuerySync); |
98 uint32 end = mem_params.shm_data_offset + mem_params.shm_data_size; | 99 base::CheckedNumeric<uint32> end = mem_params.shm_data_offset; |
99 if (end > mem_params.shm_size || end < mem_params.shm_data_offset) | 100 end += mem_params.shm_data_size; |
| 101 if (!end.IsValid() || end.ValueOrDie() > mem_params.shm_size) |
100 return false; | 102 return false; |
101 | 103 |
102 observer_ = new AsyncPixelTransferCompletionObserverImpl(submit_count); | 104 observer_ = new AsyncPixelTransferCompletionObserverImpl(submit_count); |
103 | 105 |
104 // Ask AsyncPixelTransferDelegate to run completion callback after all | 106 // Ask AsyncPixelTransferDelegate to run completion callback after all |
105 // previous async transfers are done. No guarantee that callback is run | 107 // previous async transfers are done. No guarantee that callback is run |
106 // on the current thread. | 108 // on the current thread. |
107 manager()->decoder()->GetAsyncPixelTransferManager() | 109 manager()->decoder()->GetAsyncPixelTransferManager() |
108 ->AsyncNotifyCompletion(mem_params, observer_); | 110 ->AsyncNotifyCompletion(mem_params, observer_); |
109 | 111 |
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
297 QueryManager* manager, GLenum target, int32 shm_id, uint32 shm_offset); | 299 QueryManager* manager, GLenum target, int32 shm_id, uint32 shm_offset); |
298 | 300 |
299 virtual bool Begin() OVERRIDE; | 301 virtual bool Begin() OVERRIDE; |
300 virtual bool End(base::subtle::Atomic32 submit_count) OVERRIDE; | 302 virtual bool End(base::subtle::Atomic32 submit_count) OVERRIDE; |
301 virtual bool Process() OVERRIDE; | 303 virtual bool Process() OVERRIDE; |
302 virtual void Destroy(bool have_context) OVERRIDE; | 304 virtual void Destroy(bool have_context) OVERRIDE; |
303 | 305 |
304 protected: | 306 protected: |
305 void Complete(); | 307 void Complete(); |
306 virtual ~AsyncReadPixelsCompletedQuery(); | 308 virtual ~AsyncReadPixelsCompletedQuery(); |
| 309 |
| 310 private: |
| 311 bool completed_; |
| 312 bool complete_result_; |
307 }; | 313 }; |
308 | 314 |
309 AsyncReadPixelsCompletedQuery::AsyncReadPixelsCompletedQuery( | 315 AsyncReadPixelsCompletedQuery::AsyncReadPixelsCompletedQuery( |
310 QueryManager* manager, GLenum target, int32 shm_id, uint32 shm_offset) | 316 QueryManager* manager, GLenum target, int32 shm_id, uint32 shm_offset) |
311 : Query(manager, target, shm_id, shm_offset) { | 317 : Query(manager, target, shm_id, shm_offset), |
| 318 completed_(false), |
| 319 complete_result_(false) { |
312 } | 320 } |
313 | 321 |
314 bool AsyncReadPixelsCompletedQuery::Begin() { | 322 bool AsyncReadPixelsCompletedQuery::Begin() { |
315 return true; | 323 return true; |
316 } | 324 } |
317 | 325 |
318 bool AsyncReadPixelsCompletedQuery::End(base::subtle::Atomic32 submit_count) { | 326 bool AsyncReadPixelsCompletedQuery::End(base::subtle::Atomic32 submit_count) { |
319 if (!AddToPendingQueue(submit_count)) { | 327 if (!AddToPendingQueue(submit_count)) { |
320 return false; | 328 return false; |
321 } | 329 } |
322 manager()->decoder()->WaitForReadPixels( | 330 manager()->decoder()->WaitForReadPixels( |
323 base::Bind(&AsyncReadPixelsCompletedQuery::Complete, | 331 base::Bind(&AsyncReadPixelsCompletedQuery::Complete, |
324 AsWeakPtr())); | 332 AsWeakPtr())); |
325 | 333 |
326 return true; | 334 return Process(); |
327 } | 335 } |
328 | 336 |
329 void AsyncReadPixelsCompletedQuery::Complete() { | 337 void AsyncReadPixelsCompletedQuery::Complete() { |
330 MarkAsCompleted(1); | 338 completed_ = true; |
| 339 complete_result_ = MarkAsCompleted(1); |
331 } | 340 } |
332 | 341 |
333 bool AsyncReadPixelsCompletedQuery::Process() { | 342 bool AsyncReadPixelsCompletedQuery::Process() { |
334 return true; | 343 return !completed_ || complete_result_; |
335 } | 344 } |
336 | 345 |
337 void AsyncReadPixelsCompletedQuery::Destroy(bool /* have_context */) { | 346 void AsyncReadPixelsCompletedQuery::Destroy(bool /* have_context */) { |
338 if (!IsDeleted()) { | 347 if (!IsDeleted()) { |
339 MarkAsDeleted(); | 348 MarkAsDeleted(); |
340 } | 349 } |
341 } | 350 } |
342 | 351 |
343 AsyncReadPixelsCompletedQuery::~AsyncReadPixelsCompletedQuery() { | 352 AsyncReadPixelsCompletedQuery::~AsyncReadPixelsCompletedQuery() { |
344 } | 353 } |
(...skipping 326 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
671 bool QueryManager::EndQuery(Query* query, base::subtle::Atomic32 submit_count) { | 680 bool QueryManager::EndQuery(Query* query, base::subtle::Atomic32 submit_count) { |
672 DCHECK(query); | 681 DCHECK(query); |
673 if (!RemovePendingQuery(query)) { | 682 if (!RemovePendingQuery(query)) { |
674 return false; | 683 return false; |
675 } | 684 } |
676 return query->End(submit_count); | 685 return query->End(submit_count); |
677 } | 686 } |
678 | 687 |
679 } // namespace gles2 | 688 } // namespace gles2 |
680 } // namespace gpu | 689 } // namespace gpu |
OLD | NEW |