simMutex

runtime/vm/simulator_mips.cc

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #include <setjmp.h>  // NOLINT
 #include <stdlib.h>
 
 #include "vm/globals.h"
 #if defined(TARGET_ARCH_MIPS)
 
@@ skipping 1084 matching lines @@
     double* ptr = reinterpret_cast<double*>(addr);
     *ptr = value;
     return;
   }
   UnalignedAccess("double-precision floating point write", addr, instr);
 }
 
 
 // Synchronization primitives support.
 void Simulator::SetExclusiveAccess(uword addr) {
-  Isolate* isolate = Isolate::Current();
-  ASSERT(isolate != NULL);
-  DEBUG_ASSERT(exclusive_access_lock_->Owner() == isolate);
+  Thread* thread = Thread::Current();
+  ASSERT(thread != NULL);
+  DEBUG_ASSERT(exclusive_access_lock_->IsOwnedByCurrentThread());
   int i = 0;
-  // Find an entry for this isolate in the exclusive access state.
+  // Find an entry for this thread in the exclusive access state.
   while ((i < kNumAddressTags) &&
-         (exclusive_access_state_[i].isolate != isolate)) {
+         (exclusive_access_state_[i].thread != thread)) {
     i++;
   }
   // Round-robin replacement of previously used entries.
   if (i == kNumAddressTags) {
     i = next_address_tag_;
     if (++next_address_tag_ == kNumAddressTags) {
       next_address_tag_ = 0;
     }
-    exclusive_access_state_[i].isolate = isolate;
+    exclusive_access_state_[i].thread = thread;
   }
   // Remember the address being reserved.
   exclusive_access_state_[i].addr = addr;
 }
 
 
 bool Simulator::HasExclusiveAccessAndOpen(uword addr) {
-  Isolate* isolate = Isolate::Current();
-  ASSERT(isolate != NULL);
+  Thread* thread = Thread::Current();
+  ASSERT(thread != NULL);
   ASSERT(addr != 0);
-  DEBUG_ASSERT(exclusive_access_lock_->Owner() == isolate);
+  DEBUG_ASSERT(exclusive_access_lock_->IsOwnedByCurrentThread());
   bool result = false;
   for (int i = 0; i < kNumAddressTags; i++) {
-    if (exclusive_access_state_[i].isolate == isolate) {
-      // Check whether the current isolate's address reservation matches.
+    if (exclusive_access_state_[i].thread == thread) {
+      // Check whether the current thread's address reservation matches.
       if (exclusive_access_state_[i].addr == addr) {
         result = true;
       }
       exclusive_access_state_[i].addr = 0;
     } else if (exclusive_access_state_[i].addr == addr) {
-      // Other isolates with matching address lose their reservations.
+      // Other threads with matching address lose their reservations.
       exclusive_access_state_[i].addr = 0;
     }
   }
   return result;
 }
 
 
 void Simulator::ClearExclusive() {
   MutexLocker ml(exclusive_access_lock_);
-  // Remove the reservation for this isolate.
+  // Remove the reservation for this thread.
   SetExclusiveAccess(NULL);
 }
 
 
 intptr_t Simulator::ReadExclusiveW(uword addr, Instr* instr) {
   MutexLocker ml(exclusive_access_lock_);
   SetExclusiveAccess(addr);
   return ReadW(addr, instr);
 }
 
 
 intptr_t Simulator::WriteExclusiveW(uword addr, intptr_t value, Instr* instr) {
   MutexLocker ml(exclusive_access_lock_);
   bool write_allowed = HasExclusiveAccessAndOpen(addr);
   if (write_allowed) {
     WriteW(addr, value, instr);
     return 0;  // Success.
   }
   return 1;  // Failure.
 }
 
 
 uword Simulator::CompareExchange(uword* address,
                                  uword compare_value,
                                  uword new_value) {
   MutexLocker ml(exclusive_access_lock_);
   // We do not get a reservation as it would be guaranteed to be found when
-  // writing below. No other isolate is able to make a reservation while we
+  // writing below. No other thread is able to make a reservation while we
   // hold the lock.
   uword value = *address;
   if (value == compare_value) {
     *address = new_value;
     // Same effect on exclusive access state as a successful SC.
     HasExclusiveAccessAndOpen(reinterpret_cast<uword>(address));
   } else {
     // Same effect on exclusive access state as an LL.
     SetExclusiveAccess(reinterpret_cast<uword>(address));
   }
@@ skipping 1297 matching lines @@
   set_register(kExceptionObjectReg, bit_cast<int32_t>(raw_exception));
   set_register(kStackTraceObjectReg, bit_cast<int32_t>(raw_stacktrace));
   buf->Longjmp();
 }
 
 }  // namespace dart
 
 #endif  // !defined(HOST_ARCH_MIPS)
 
 #endif  // defined TARGET_ARCH_MIPS