Chromium Code Reviews| Index: media/base/video_frame.cc |
| diff --git a/media/base/video_frame.cc b/media/base/video_frame.cc |
| index 423c9b1c3f1c2ee392675c8fe46c86fbfcec8e81..b75b561e09a890fa7e20a885472823ea9873a48f 100644 |
| --- a/media/base/video_frame.cc |
| +++ b/media/base/video_frame.cc |
| @@ -650,6 +650,7 @@ VideoFrame::VideoFrame(VideoFrame::Format format, |
| mailbox_holder_(mailbox_holder.Pass()), |
| shared_memory_handle_(base::SharedMemory::NULLHandle()), |
| timestamp_(timestamp), |
| + release_sync_point_(0), |
| end_of_stream_(end_of_stream) { |
| DCHECK(IsValidConfig(format_, coded_size_, visible_rect_, natural_size_)); |
| @@ -659,12 +660,13 @@ VideoFrame::VideoFrame(VideoFrame::Format format, |
| VideoFrame::~VideoFrame() { |
| if (!mailbox_holder_release_cb_.is_null()) { |
| - std::vector<uint32> release_sync_points; |
| + uint32 release_sync_point; |
| { |
| + // To ensure |release_sync_point_| is visible on this thread. |
| base::AutoLock locker(release_sync_point_lock_); |
|
no sievers
2014/07/10 18:52:29
Why do we need a lock in the destructor? Somebody
danakj
2014/07/10 19:15:57
Thread barrier, someone may have changed the value
dshwang
2014/07/10 19:23:11
Thank you for answer!
no sievers
2014/07/10 19:27:47
Ah thanks. I guess the comment says that already.
|
| - release_sync_points_.swap(release_sync_points); |
| + release_sync_point = release_sync_point_; |
| } |
| - base::ResetAndReturn(&mailbox_holder_release_cb_).Run(release_sync_points); |
| + base::ResetAndReturn(&mailbox_holder_release_cb_).Run(release_sync_point); |
| } |
| if (!no_longer_needed_cb_.is_null()) |
| base::ResetAndReturn(&no_longer_needed_cb_).Run(); |
| @@ -816,12 +818,15 @@ base::SharedMemoryHandle VideoFrame::shared_memory_handle() const { |
| return shared_memory_handle_; |
| } |
| -void VideoFrame::AppendReleaseSyncPoint(uint32 sync_point) { |
| +void VideoFrame::UpdateReleaseSyncPoint(SyncPointClient* client) { |
| DCHECK_EQ(format_, NATIVE_TEXTURE); |
| - if (!sync_point) |
| - return; |
| base::AutoLock locker(release_sync_point_lock_); |
| - release_sync_points_.push_back(sync_point); |
| + // Must wait the previous sync point before inserting a new sync point so that |
| + // |mailbox_holder_release_cb_| guarantees the previous sync point occurred |
| + // when it waits |release_sync_point_|. |
| + if (release_sync_point_) |
| + client->WaitSyncPoint(release_sync_point_); |
| + release_sync_point_ = client->InsertSyncPoint(); |
| } |
| #if defined(OS_POSIX) |