Speculatively use memory barriers for loading and storing g_context,

rlz/lib/financial_ping.cc

 // Copyright (c) 2012 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.
 //
 // Library functions related to the Financial Server ping.
 
 #include "rlz/lib/financial_ping.h"
 
 #include "base/atomicops.h"
 #include "base/basictypes.h"
@@ skipping 170 matching lines @@
 }
 
 #if defined(RLZ_NETWORK_IMPLEMENTATION_CHROME_NET)
 // The pointer to URLRequestContextGetter used by FinancialPing::PingServer().
 // It is atomic pointer because it can be accessed and modified by multiple
 // threads.
 AtomicWord g_context;
 
 bool FinancialPing::SetURLRequestContext(
     net::URLRequestContextGetter* context) {
-  base::subtle::NoBarrier_Store(
+  base::subtle::Release_Store(
       &g_context, reinterpret_cast<AtomicWord>(context));
   return true;
 }
 
 namespace {
 
 class FinancialPingUrlFetcherDelegate : public net::URLFetcherDelegate {
  public:
   FinancialPingUrlFetcherDelegate(const base::Closure& callback)
       : callback_(callback) {
   }
   virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE;
 
  private:
   base::Closure callback_;
 };
 
 void FinancialPingUrlFetcherDelegate::OnURLFetchComplete(
     const net::URLFetcher* source) {
   callback_.Run();
 }
 
 bool send_financial_ping_interrupted_for_test = false;
 
 }  // namespace
 
 void ShutdownCheck(base::WeakPtr<base::RunLoop> weak) {
   if (!weak.get())
     return;
-  if (!base::subtle::NoBarrier_Load(&g_context)) {
+  if (!base::subtle::Acquire_Load(&g_context)) {
     send_financial_ping_interrupted_for_test = true;
     weak->QuitClosure().Run();
     return;
   }
   // How frequently the financial ping thread should check
   // the shutdown condition?
   const base::TimeDelta kInterval = base::TimeDelta::FromMilliseconds(500);
   base::MessageLoop::current()->PostDelayedTask(
       FROM_HERE,
       base::Bind(&ShutdownCheck, weak),
@@ skipping 56 matching lines @@
     bytes_read = 0;
   };
 
   return true;
 #else
   // Copy the pointer to stack because g_context may be set to NULL
   // in different thread. The instance is guaranteed to exist while
   // the method is running.
   net::URLRequestContextGetter* context =
       reinterpret_cast<net::URLRequestContextGetter*>(
-          base::subtle::NoBarrier_Load(&g_context));
+          base::subtle::Acquire_Load(&g_context));
 
   // Browser shutdown will cause the context to be reset to NULL.
   if (!context)
     return false;
 
   // Run a blocking event loop to match the win inet implementation.
   scoped_ptr<base::MessageLoop> message_loop;
   // Ensure that we have a MessageLoop.
   if (!base::MessageLoop::current())
     message_loop.reset(new base::MessageLoop);
@@ skipping 95 matching lines @@
 }
 
 bool WasSendFinancialPingInterrupted() {
   return send_financial_ping_interrupted_for_test;
 }
 
 }  // namespace test
 #endif
 
 }  // namespace rlz_lib