diff options
author | Ian Rogers <irogers@google.com> | 2014-08-15 11:09:28 -0700 |
---|---|---|
committer | Ian Rogers <irogers@google.com> | 2014-08-15 11:35:38 -0700 |
commit | 43c69cc4cea794cd4d89d9d0680b1e25c6d02acc (patch) | |
tree | fdfabd74408bc13e4b73674e881ab0ebbfb39d0f /runtime/monitor.cc | |
parent | 37f048b19da5ac245a6b2a8473b326d2167cc692 (diff) | |
download | art-43c69cc4cea794cd4d89d9d0680b1e25c6d02acc.tar.gz art-43c69cc4cea794cd4d89d9d0680b1e25c6d02acc.tar.bz2 art-43c69cc4cea794cd4d89d9d0680b1e25c6d02acc.zip |
Make Monitor::Wait more robust to spurious Inflate failures.
Bug: 17062710
Change-Id: Ife5f6b335caacc70cab543cd568676d277d3beb6
(cherry picked from commit 6f22fc166ed6c11cad229bff442c064e704de101)
Diffstat (limited to 'runtime/monitor.cc')
-rw-r--r-- | runtime/monitor.cc | 49 |
1 files changed, 23 insertions, 26 deletions
diff --git a/runtime/monitor.cc b/runtime/monitor.cc index 433c1b2d6d..4c780ee9e6 100644 --- a/runtime/monitor.cc +++ b/runtime/monitor.cc @@ -641,11 +641,6 @@ bool Monitor::Deflate(Thread* self, mirror::Object* obj) { return true; } -/* - * Changes the shape of a monitor from thin to fat, preserving the internal lock state. The calling - * thread must own the lock or the owner must be suspended. There's a race with other threads - * inflating the lock and so the caller should read the monitor following the call. - */ void Monitor::Inflate(Thread* self, Thread* owner, mirror::Object* obj, int32_t hash_code) { DCHECK(self != nullptr); DCHECK(obj != nullptr); @@ -831,30 +826,32 @@ void Monitor::Wait(Thread* self, mirror::Object *obj, int64_t ms, int32_t ns, DCHECK(self != nullptr); DCHECK(obj != nullptr); LockWord lock_word = obj->GetLockWord(true); - switch (lock_word.GetState()) { - case LockWord::kHashCode: - // Fall-through. - case LockWord::kUnlocked: - ThrowIllegalMonitorStateExceptionF("object not locked by thread before wait()"); - return; // Failure. - case LockWord::kThinLocked: { - uint32_t thread_id = self->GetThreadId(); - uint32_t owner_thread_id = lock_word.ThinLockOwner(); - if (owner_thread_id != thread_id) { + while (lock_word.GetState() != LockWord::kFatLocked) { + switch (lock_word.GetState()) { + case LockWord::kHashCode: + // Fall-through. + case LockWord::kUnlocked: ThrowIllegalMonitorStateExceptionF("object not locked by thread before wait()"); return; // Failure. - } else { - // We own the lock, inflate to enqueue ourself on the Monitor. - Inflate(self, self, obj, 0); - lock_word = obj->GetLockWord(true); + case LockWord::kThinLocked: { + uint32_t thread_id = self->GetThreadId(); + uint32_t owner_thread_id = lock_word.ThinLockOwner(); + if (owner_thread_id != thread_id) { + ThrowIllegalMonitorStateExceptionF("object not locked by thread before wait()"); + return; // Failure. + } else { + // We own the lock, inflate to enqueue ourself on the Monitor. May fail spuriously so + // re-load. + Inflate(self, self, obj, 0); + lock_word = obj->GetLockWord(true); + } + break; + } + case LockWord::kFatLocked: // Unreachable given the loop condition above. Fall-through. + default: { + LOG(FATAL) << "Invalid monitor state " << lock_word.GetState(); + return; } - break; - } - case LockWord::kFatLocked: - break; // Already set for a wait. - default: { - LOG(FATAL) << "Invalid monitor state " << lock_word.GetState(); - return; } } Monitor* mon = lock_word.FatLockMonitor(); |