Replace Acquire_Store calls with Release_Store as these stores should have the release ordering/sem…

chromecast/media/cma/ipc/media_message_fifo.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chromecast/media/cma/ipc/media_message_fifo.h"
 
 #include "base/atomicops.h"
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
@@ skipping 105 matching lines @@
   rd_offset_ = reinterpret_cast<AtomicSize*>(&(desc->rd_offset));
   wr_offset_ = reinterpret_cast<AtomicSize*>(&(desc->wr_offset));
 
   size_t max_size = mem_->size() -
       (static_cast<char*>(base_) - static_cast<char*>(mem_->data()));
   if (init) {
     size_ = max_size;
     desc->size = size_;
     internal_rd_offset_ = 0;
     internal_wr_offset_ = 0;
-    base::subtle::Acquire_Store(rd_offset_, 0);
-    base::subtle::Acquire_Store(wr_offset_, 0);
+    base::subtle::Release_Store(rd_offset_, 0);
+    base::subtle::Release_Store(wr_offset_, 0);
   } else {
     size_ = desc->size;
     CHECK_LE(size_, max_size);
     internal_rd_offset_ = current_rd_offset();
     internal_wr_offset_ = current_wr_offset();
   }
   CMALOG(kLogControl)
       << "MediaMessageFifo:" << " init=" << init << " size=" << size_;
   CHECK_GT(size_, 0) << size_;
 
@@ skipping 225 matching lines @@
   size_t wr_offset = base::subtle::Acquire_Load(wr_offset_);
   CHECK_LT(wr_offset, size_);
   return wr_offset;
 }
 
 void MediaMessageFifo::CommitRead(size_t new_rd_offset) {
   // Add a memory fence to ensure the message content is completely read
   // before updating the read offset.
   base::subtle::Release_Store(rd_offset_, new_rd_offset);
 
-  // Make sure the read pointer has been updated before sending a notification.
+  // Since rd_offset_ is updated by a release_store above, any thread that
+  // does acquire_load is guaranteed to see the new rd_offset_ set above.
+  // So it is safe to send the notification.
   if (!read_event_cb_.is_null()) {
-    base::subtle::MemoryBarrier();
     read_event_cb_.Run();
   }
 }
 
 void MediaMessageFifo::CommitWrite(size_t new_wr_offset) {
   // Add a memory fence to ensure the message content is written
   // before updating the write offset.
   base::subtle::Release_Store(wr_offset_, new_wr_offset);
 
-  // Make sure the write pointer has been updated before sending a notification.
+  // Since wr_offset_ is updated by a release_store above, any thread that
+  // does acquire_load is guaranteed to see the new wr_offset_ set above.
+  // So it is safe to send the notification.
   if (!write_event_cb_.is_null()) {
-    base::subtle::MemoryBarrier();
     write_event_cb_.Run();
   }
 }
 
 void MediaMessageFifo::CommitInternalRead(size_t new_rd_offset) {
   internal_rd_offset_ = new_rd_offset;
 }
 
 void MediaMessageFifo::CommitInternalWrite(size_t new_wr_offset) {
   internal_wr_offset_ = new_wr_offset;
 }
 
 }  // namespace media
 }  // namespace chromecast