15f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes/* 25f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * Copyright (C) 2008 The Android Open Source Project 35f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 45f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * Licensed under the Apache License, Version 2.0 (the "License"); 55f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * you may not use this file except in compliance with the License. 65f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * You may obtain a copy of the License at 75f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 85f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * http://www.apache.org/licenses/LICENSE-2.0 95f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 105f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * Unless required by applicable law or agreed to in writing, software 115f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * distributed under the License is distributed on an "AS IS" BASIS, 125f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 135f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * See the License for the specific language governing permissions and 145f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * limitations under the License. 155f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes */ 165f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1754e7df1896a4066cbb9fe6f72249829f0b8c49c6Elliott Hughes#include "monitor.h" 185f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1908fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes#include <vector> 2008fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes 21e401d146407d61eeb99f8d6176b2ac13c4df1e33Mathieu Chartier#include "art_method-inl.h" 2276b6167407c2b6f5d40ad895b2793a6b037f54b2Elliott Hughes#include "base/mutex.h" 231aa246dec5abe212f699de1413a0c4a191ca364aElliott Hughes#include "base/stl_util.h" 2432ce2adefb8a3d0eda59a29f5e87c1eb43eef796Mathieu Chartier#include "base/systrace.h" 2580afd02024d20e60b197d3adfbb43cc303cf29e0Vladimir Marko#include "base/time_utils.h" 2633dc7717cd16592bcc825350bea6305be9eb2ea1jeffhao#include "class_linker.h" 274f6ad8ab428038129b2d0d6c40b7fd625cca15e1Ian Rogers#include "dex_file-inl.h" 280f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz#include "dex_instruction-inl.h" 29d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers#include "lock_word-inl.h" 304f6ad8ab428038129b2d0d6c40b7fd625cca15e1Ian Rogers#include "mirror/class-inl.h" 3105f3057d6a4d23d712092ccd36a531590bff323bIan Rogers#include "mirror/object-inl.h" 322dd0e2cea360bc9206eb88ecc40d259e796c239dIan Rogers#include "mirror/object_array-inl.h" 3300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers#include "scoped_thread_state_change.h" 345f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes#include "thread.h" 358e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes#include "thread_list.h" 3608fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes#include "verifier/method_verifier.h" 37044288fb8f69e154862763a6b3bfea2bac1b397eElliott Hughes#include "well_known_classes.h" 385f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 395f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesnamespace art { 405f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 41b9001abff3a45f1ae90536da7dd1ec28a6ae0174Mathieu Chartierstatic constexpr uint64_t kLongWaitMs = 100; 42b9001abff3a45f1ae90536da7dd1ec28a6ae0174Mathieu Chartier 435f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes/* 44d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * Every Object has a monitor associated with it, but not every Object is actually locked. Even 45d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * the ones that are locked do not need a full-fledged monitor until a) there is actual contention 46d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * or b) wait() is called on the Object. 475f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 48d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * For Android, we have implemented a scheme similar to the one described in Bacon et al.'s 49d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * "Thin locks: featherweight synchronization for Java" (ACM 1998). Things are even easier for us, 50d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * though, because we have a full 32 bits to work with. 515f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 52d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * The two states of an Object's lock are referred to as "thin" and "fat". A lock may transition 53d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * from the "thin" state to the "fat" state and this transition is referred to as inflation. Once 54d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * a lock has been inflated it remains in the "fat" state indefinitely. 555f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 56d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * The lock value itself is stored in mirror::Object::monitor_ and the representation is described 57d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * in the LockWord value type. 5854e7df1896a4066cbb9fe6f72249829f0b8c49c6Elliott Hughes * 595f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * Monitors provide: 605f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * - mutually exclusive access to resources 615f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * - a way for multiple threads to wait for notification 625f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 635f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * In effect, they fill the role of both mutexes and condition variables. 645f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 65d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * Only one thread can own the monitor at any time. There may be several threads waiting on it 66d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * (the wait call unlocks it). One or more waiting threads may be getting interrupted or notified 67d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers * at any given time. 685f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes */ 6954e7df1896a4066cbb9fe6f72249829f0b8c49c6Elliott Hughes 70fc86162ce2a3467acb690e18cc8bd9b3daafc606Elliott Hughesuint32_t Monitor::lock_profiling_threshold_ = 0; 7132d6e1e5654433d7eadede89e1c770b2c839aee9Elliott Hughes 72b2771b41a956b50266d4d83fbb067f99faf7b7dcCalin Juravlevoid Monitor::Init(uint32_t lock_profiling_threshold) { 73fc86162ce2a3467acb690e18cc8bd9b3daafc606Elliott Hughes lock_profiling_threshold_ = lock_profiling_threshold; 7432d6e1e5654433d7eadede89e1c770b2c839aee9Elliott Hughes} 7532d6e1e5654433d7eadede89e1c770b2c839aee9Elliott Hughes 76ef7d42fca18c16fbaf103822ad16f23246e2905dIan RogersMonitor::Monitor(Thread* self, Thread* owner, mirror::Object* obj, int32_t hash_code) 7700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers : monitor_lock_("a monitor lock", kMonitorLock), 78d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_contenders_("monitor contenders", monitor_lock_), 7946bc778f1feed02b20d25e3d03470c93ca2c0506Mathieu Chartier num_waiters_(0), 8000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers owner_(owner), 815f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes lock_count_(0), 8294f7b49578b6aaa80de8ffed230648d601393905Hiroshi Yamauchi obj_(GcRoot<mirror::Object>(obj)), 832cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier wait_set_(nullptr), 84ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier hash_code_(hash_code), 852cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier locking_method_(nullptr), 86ef7d42fca18c16fbaf103822ad16f23246e2905dIan Rogers locking_dex_pc_(0), 8774240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe monitor_id_(MonitorPool::ComputeMonitorId(this, self)) { 8874240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe#ifdef __LP64__ 8974240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe DCHECK(false) << "Should not be reached in 64b"; 9074240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe next_free_ = nullptr; 9174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe#endif 9274240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe // We should only inflate a lock if the owner is ourselves or suspended. This avoids a race 9374240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe // with the owner unlocking the thin-lock. 9474240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe CHECK(owner == nullptr || owner == self || owner->IsSuspended()); 9574240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe // The identity hash code is set for the life time of the monitor. 9674240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe} 9774240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe 9874240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas GampeMonitor::Monitor(Thread* self, Thread* owner, mirror::Object* obj, int32_t hash_code, 9974240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe MonitorId id) 10074240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe : monitor_lock_("a monitor lock", kMonitorLock), 10174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe monitor_contenders_("monitor contenders", monitor_lock_), 10274240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe num_waiters_(0), 10374240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe owner_(owner), 10474240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe lock_count_(0), 10594f7b49578b6aaa80de8ffed230648d601393905Hiroshi Yamauchi obj_(GcRoot<mirror::Object>(obj)), 1062cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier wait_set_(nullptr), 10774240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe hash_code_(hash_code), 1082cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier locking_method_(nullptr), 10974240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe locking_dex_pc_(0), 11074240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe monitor_id_(id) { 11174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe#ifdef __LP64__ 11274240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe next_free_ = nullptr; 11374240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe#endif 114d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // We should only inflate a lock if the owner is ourselves or suspended. This avoids a race 115d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // with the owner unlocking the thin-lock. 116ef7d42fca18c16fbaf103822ad16f23246e2905dIan Rogers CHECK(owner == nullptr || owner == self || owner->IsSuspended()); 117ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // The identity hash code is set for the life time of the monitor. 118d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers} 119d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers 1204e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartierint32_t Monitor::GetHashCode() { 1214e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier while (!HasHashCode()) { 1223e5cf305db800b2989ad57b7cde8fb3cc9fa1b9eIan Rogers if (hash_code_.CompareExchangeWeakRelaxed(0, mirror::Object::GenerateIdentityHashCode())) { 1234e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier break; 1244e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier } 1254e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier } 1264e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier DCHECK(HasHashCode()); 1273e5cf305db800b2989ad57b7cde8fb3cc9fa1b9eIan Rogers return hash_code_.LoadRelaxed(); 1284e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier} 1294e6a31eb97f22f4480827474b30b9e64f396eaceMathieu Chartier 130d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogersbool Monitor::Install(Thread* self) { 131d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MutexLock mu(self, monitor_lock_); // Uncontended mutex acquisition as monitor isn't yet public. 132ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier CHECK(owner_ == nullptr || owner_ == self || owner_->IsSuspended()); 13300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // Propagate the lock state. 1344cba0d979a11f955e6ec3c0f1bf61478af7aa810Hiroshi Yamauchi LockWord lw(GetObject()->GetLockWord(false)); 135ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier switch (lw.GetState()) { 136ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kThinLocked: { 137ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier CHECK_EQ(owner_->GetThreadId(), lw.ThinLockOwner()); 138ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier lock_count_ = lw.ThinLockCount(); 139ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier break; 140ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 141ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kHashCode: { 1423e5cf305db800b2989ad57b7cde8fb3cc9fa1b9eIan Rogers CHECK_EQ(hash_code_.LoadRelaxed(), static_cast<int32_t>(lw.GetHashCode())); 143ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier break; 144ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 145ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kFatLocked: { 146ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // The owner_ is suspended but another thread beat us to install a monitor. 147ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier return false; 148ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 149ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kUnlocked: { 150ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier LOG(FATAL) << "Inflating unlocked lock word"; 151ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier break; 152ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 153590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier default: { 154590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier LOG(FATAL) << "Invalid monitor state " << lw.GetState(); 155590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier return false; 156590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 157d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 158e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord fat(this, lw.ReadBarrierState()); 159d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Publish the updated lock word, which may race with other threads. 160228602f562f1d130d06e60a98752d99c2d467d6aIan Rogers bool success = GetObject()->CasLockWordWeakSequentiallyConsistent(lw, fat); 16100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // Lock profiling. 1629728f91a63016136261231ff5213bde703bd27b6Mathieu Chartier if (success && owner_ != nullptr && lock_profiling_threshold_ != 0) { 1636ec8ebd178ed39aa09e4c7fad194900114c4121aAndreas Gampe // Do not abort on dex pc errors. This can easily happen when we want to dump a stack trace on 1646ec8ebd178ed39aa09e4c7fad194900114c4121aAndreas Gampe // abort. 1656ec8ebd178ed39aa09e4c7fad194900114c4121aAndreas Gampe locking_method_ = owner_->GetCurrentMethod(&locking_dex_pc_, false); 16600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers } 167d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return success; 1685f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 1695f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1705f79133a435ebcb20000370d56046fe01201dd80Elliott HughesMonitor::~Monitor() { 171590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // Deflated monitors have a null object. 1725f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 1735f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1745f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesvoid Monitor::AppendToWaitSet(Thread* thread) { 1755f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes DCHECK(owner_ == Thread::Current()); 1762cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(thread != nullptr); 177dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers DCHECK(thread->GetWaitNext() == nullptr) << thread->GetWaitNext(); 1782cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (wait_set_ == nullptr) { 1795f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes wait_set_ = thread; 1805f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 1815f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 1825f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1835f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // push_back. 1845f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes Thread* t = wait_set_; 185dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers while (t->GetWaitNext() != nullptr) { 186dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers t = t->GetWaitNext(); 1875f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 188dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers t->SetWaitNext(thread); 1895f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 1905f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1915f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesvoid Monitor::RemoveFromWaitSet(Thread *thread) { 1925f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes DCHECK(owner_ == Thread::Current()); 1932cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(thread != nullptr); 1942cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (wait_set_ == nullptr) { 1955f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 1965f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 1975f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes if (wait_set_ == thread) { 198dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers wait_set_ = thread->GetWaitNext(); 199dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers thread->SetWaitNext(nullptr); 2005f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 2015f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 2025f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 2035f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes Thread* t = wait_set_; 2042cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier while (t->GetWaitNext() != nullptr) { 205dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers if (t->GetWaitNext() == thread) { 206dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers t->SetWaitNext(thread->GetWaitNext()); 207dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers thread->SetWaitNext(nullptr); 2085f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 2095f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 210dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers t = t->GetWaitNext(); 2115f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 2125f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 2135f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 2146aa3df965395566ed6a4fec4af37c2b7577992e9Mathieu Chartiervoid Monitor::SetObject(mirror::Object* object) { 21594f7b49578b6aaa80de8ffed230648d601393905Hiroshi Yamauchi obj_ = GcRoot<mirror::Object>(object); 2166aa3df965395566ed6a4fec4af37c2b7577992e9Mathieu Chartier} 2176aa3df965395566ed6a4fec4af37c2b7577992e9Mathieu Chartier 218fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe// Note: Adapted from CurrentMethodVisitor in thread.cc. We must not resolve here. 219fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 220fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampestruct NthCallerWithDexPcVisitor FINAL : public StackVisitor { 221fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe explicit NthCallerWithDexPcVisitor(Thread* thread, size_t frame) 222fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe SHARED_REQUIRES(Locks::mutator_lock_) 223fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe : StackVisitor(thread, nullptr, StackVisitor::StackWalkKind::kIncludeInlinedFramesNoResolve), 224fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe method_(nullptr), 225fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe dex_pc_(0), 226fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe current_frame_number_(0), 227fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe wanted_frame_number_(frame) {} 228fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe bool VisitFrame() OVERRIDE SHARED_REQUIRES(Locks::mutator_lock_) { 229fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe ArtMethod* m = GetMethod(); 230fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe if (m == nullptr || m->IsRuntimeMethod()) { 231fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // Runtime method, upcall, or resolution issue. Skip. 232fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe return true; 233fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe } 234fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 235fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // Is this the requested frame? 236fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe if (current_frame_number_ == wanted_frame_number_) { 237fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe method_ = m; 238fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe dex_pc_ = GetDexPc(false /* abort_on_error*/); 239fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe return false; 240fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe } 241fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 242fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // Look for more. 243fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe current_frame_number_++; 244fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe return true; 245fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe } 246fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 247fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe ArtMethod* method_; 248fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe uint32_t dex_pc_; 249fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 250fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe private: 251fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe size_t current_frame_number_; 252fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe const size_t wanted_frame_number_; 253fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe}; 254fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 255fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe// This function is inlined and just helps to not have the VLOG and ATRACE check at all the 256fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe// potential tracing points. 257fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampevoid Monitor::AtraceMonitorLock(Thread* self, mirror::Object* obj, bool is_wait) { 258fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe if (UNLIKELY(VLOG_IS_ON(systrace_lock_logging) && ATRACE_ENABLED())) { 259fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorLockImpl(self, obj, is_wait); 260fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe } 261fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe} 262fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 263fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampevoid Monitor::AtraceMonitorLockImpl(Thread* self, mirror::Object* obj, bool is_wait) { 264fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // Wait() requires a deeper call stack to be useful. Otherwise you'll see "Waiting at 265fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // Object.java". Assume that we'll wait a nontrivial amount, so it's OK to do a longer 266fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // stack walk than if !is_wait. 267fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe NthCallerWithDexPcVisitor visitor(self, is_wait ? 1U : 0U); 268fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe visitor.WalkStack(false); 269fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe const char* prefix = is_wait ? "Waiting on " : "Locking "; 270fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 271fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe const char* filename; 272fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe int32_t line_number; 273fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe TranslateLocation(visitor.method_, visitor.dex_pc_, &filename, &line_number); 274fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 275fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // It would be nice to have a stable "ID" for the object here. However, the only stable thing 276fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // would be the identity hashcode. But we cannot use IdentityHashcode here: For one, there are 277fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // times when it is unsafe to make that call (see stack dumping for an explanation). More 278fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // importantly, we would have to give up on thin-locking when adding systrace locks, as the 279fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // identity hashcode is stored in the lockword normally (so can't be used with thin-locks). 280fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // 281fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // Because of thin-locks we also cannot use the monitor id (as there is no monitor). Monitor ids 282fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // also do not have to be stable, as the monitor may be deflated. 283fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe std::string tmp = StringPrintf("%s %d at %s:%d", 284fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe prefix, 285fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe (obj == nullptr ? -1 : static_cast<int32_t>(reinterpret_cast<uintptr_t>(obj))), 286fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe (filename != nullptr ? filename : "null"), 287fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe line_number); 288fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe ATRACE_BEGIN(tmp.c_str()); 289fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe} 290fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 291fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampevoid Monitor::AtraceMonitorUnlock() { 292fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe if (UNLIKELY(VLOG_IS_ON(systrace_lock_logging))) { 293fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe ATRACE_END(); 294fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe } 295fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe} 296fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 297dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartierstd::string Monitor::PrettyContentionInfo(const std::string& owner_name, 298dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier pid_t owner_tid, 299dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier ArtMethod* owners_method, 300dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier uint32_t owners_dex_pc, 301dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier size_t num_waiters) { 302dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier const char* owners_filename; 303dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier int32_t owners_line_number; 304dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier if (owners_method != nullptr) { 305dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier TranslateLocation(owners_method, owners_dex_pc, &owners_filename, &owners_line_number); 306dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier } 307dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier std::ostringstream oss; 308dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier oss << "monitor contention with owner " << owner_name << " (" << owner_tid << ")"; 309dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier if (owners_method != nullptr) { 3108f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier oss << " at " << PrettyMethod(owners_method); 3118f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier oss << "(" << owners_filename << ":" << owners_line_number << ")"; 312dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier } 313dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier oss << " waiters=" << num_waiters; 314dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier return oss.str(); 315dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier} 316dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier 31723da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartierbool Monitor::TryLockLocked(Thread* self) { 31823da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier if (owner_ == nullptr) { // Unowned. 31923da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier owner_ = self; 32023da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier CHECK_EQ(lock_count_, 0); 32123da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier // When debugging, save the current monitor holder for future 32223da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier // acquisition failures to use in sampled logging. 32323da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier if (lock_profiling_threshold_ != 0) { 32423da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier locking_method_ = self->GetCurrentMethod(&locking_dex_pc_); 32523da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } 32623da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } else if (owner_ == self) { // Recursive. 32723da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier lock_count_++; 32823da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } else { 32923da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return false; 33023da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } 33123da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier AtraceMonitorLock(self, GetObject(), false /* is_wait */); 33223da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return true; 33323da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier} 33423da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier 33523da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartierbool Monitor::TryLock(Thread* self) { 33623da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier MutexLock mu(self, monitor_lock_); 33723da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return TryLockLocked(self); 33823da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier} 33923da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier 3405f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesvoid Monitor::Lock(Thread* self) { 341d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MutexLock mu(self, monitor_lock_); 342d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers while (true) { 34323da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier if (TryLockLocked(self)) { 34423da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return; 345fc86162ce2a3467acb690e18cc8bd9b3daafc606Elliott Hughes } 346d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Contended. 347d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers const bool log_contention = (lock_profiling_threshold_ != 0); 348b894a19dfd668b6779de939cf5265b7e409d8809Xin Guan uint64_t wait_start_ms = log_contention ? MilliTime() : 0; 349e401d146407d61eeb99f8d6176b2ac13c4df1e33Mathieu Chartier ArtMethod* owners_method = locking_method_; 350d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t owners_dex_pc = locking_dex_pc_; 351440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier // Do this before releasing the lock so that we don't get deflated. 352b9001abff3a45f1ae90536da7dd1ec28a6ae0174Mathieu Chartier size_t num_waiters = num_waiters_; 353440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier ++num_waiters_; 354d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_lock_.Unlock(self); // Let go of locks in order. 355a6e7f0872c42009ecbee82d7fbe452deef9ae65bMathieu Chartier self->SetMonitorEnterObject(GetObject()); 356d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers { 35781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint32_t original_owner_thread_id = 0u; 358d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers ScopedThreadStateChange tsc(self, kBlocked); // Change to blocked and give up mutator_lock_. 35981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier { 36081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // Reacquire monitor_lock_ without mutator_lock_ for Wait. 36181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier MutexLock mu2(self, monitor_lock_); 36281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (owner_ != nullptr) { // Did the owner_ give the lock up? 36381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier original_owner_thread_id = owner_->GetThreadId(); 36481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (ATRACE_ENABLED()) { 36581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier std::ostringstream oss; 366dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier std::string name; 367dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier owner_->GetThreadName(name); 368dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier oss << PrettyContentionInfo(name, 369dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier owner_->GetTid(), 370dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier owners_method, 371dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier owners_dex_pc, 372dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier num_waiters); 37381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // Add info for contending thread. 37481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint32_t pc; 37581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier ArtMethod* m = self->GetCurrentMethod(&pc); 37681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier const char* filename; 37781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier int32_t line_number; 37881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier TranslateLocation(m, pc, &filename, &line_number); 3798f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier oss << " blocking from " 3808f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier << PrettyMethod(m) << "(" << (filename != nullptr ? filename : "null") << ":" 3818f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier << line_number << ")"; 38281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier ATRACE_BEGIN(oss.str().c_str()); 38381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } 38481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier monitor_contenders_.Wait(self); // Still contended so wait. 385f0dc8b5519102b3d3e738aed846975ae4239421eMathieu Chartier } 38681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } 38781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (original_owner_thread_id != 0u) { 388d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Woken from contention. 389d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (log_contention) { 390dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier uint32_t original_owner_tid = 0; 391dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier std::string original_owner_name; 392dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier { 393dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier MutexLock mu2(Thread::Current(), *Locks::thread_list_lock_); 394dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier // Re-find the owner in case the thread got killed. 395dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier Thread* original_owner = Runtime::Current()->GetThreadList()->FindThreadByThreadId( 396dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier original_owner_thread_id); 397dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier // Do not do any work that requires the mutator lock. 398dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier if (original_owner != nullptr) { 399dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier original_owner_tid = original_owner->GetTid(); 400dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier original_owner->GetThreadName(original_owner_name); 401dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier } 402dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier } 403dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier 404dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier if (original_owner_tid != 0u) { 40581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint64_t wait_ms = MilliTime() - wait_start_ms; 40681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint32_t sample_percent; 40781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (wait_ms >= lock_profiling_threshold_) { 40881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier sample_percent = 100; 40981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } else { 41081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier sample_percent = 100 * wait_ms / lock_profiling_threshold_; 41181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } 41281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (sample_percent != 0 && (static_cast<uint32_t>(rand() % 100) < sample_percent)) { 41381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (wait_ms > kLongWaitMs && owners_method != nullptr) { 4148f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier uint32_t pc; 4158f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier ArtMethod* m = self->GetCurrentMethod(&pc); 41681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // TODO: We should maybe check that original_owner is still a live thread. 41781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier LOG(WARNING) << "Long " 418dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier << PrettyContentionInfo(original_owner_name, 419dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier original_owner_tid, 42081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier owners_method, 42181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier owners_dex_pc, 42281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier num_waiters) 4238f26411287cddd983df6f1d00dbc3841767c123dMathieu Chartier << " in " << PrettyMethod(m) << " for " << PrettyDuration(MsToNs(wait_ms)); 42481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } 42581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier const char* owners_filename; 42681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier int32_t owners_line_number; 42781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier TranslateLocation(owners_method, 42881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier owners_dex_pc, 42981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier &owners_filename, 43081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier &owners_line_number); 43181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier LogContentionEvent(self, 43281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier wait_ms, 43381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier sample_percent, 43481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier owners_filename, 43581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier owners_line_number); 436dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier } 437d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 438d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 439f0dc8b5519102b3d3e738aed846975ae4239421eMathieu Chartier ATRACE_END(); 440fc86162ce2a3467acb690e18cc8bd9b3daafc606Elliott Hughes } 4415f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 442a6e7f0872c42009ecbee82d7fbe452deef9ae65bMathieu Chartier self->SetMonitorEnterObject(nullptr); 443d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_lock_.Lock(self); // Reacquire locks in order. 444440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier --num_waiters_; 445fc86162ce2a3467acb690e18cc8bd9b3daafc606Elliott Hughes } 4465f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 4475f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 4486d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogersstatic void ThrowIllegalMonitorStateExceptionF(const char* fmt, ...) 4496d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers __attribute__((format(printf, 1, 2))); 4506d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers 45100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersstatic void ThrowIllegalMonitorStateExceptionF(const char* fmt, ...) 45290443477f9a0061581c420775ce3b7eeae7468bcMathieu Chartier SHARED_REQUIRES(Locks::mutator_lock_) { 4536d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers va_list args; 4546d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers va_start(args, fmt); 45562d6c772205b8859f0ebf7ad105402ec4c3e2e01Ian Rogers Thread* self = Thread::Current(); 4560aa50ce2fb75bfc2e815a0c33adf9b049561923bNicolas Geoffray self->ThrowNewExceptionV("Ljava/lang/IllegalMonitorStateException;", fmt, args); 457d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (!Runtime::Current()->IsStarted() || VLOG_IS_ON(monitor)) { 45864277f38032208a0c1081ff9e466c04009b96383Brian Carlstrom std::ostringstream ss; 45962d6c772205b8859f0ebf7ad105402ec4c3e2e01Ian Rogers self->Dump(ss); 460d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers LOG(Runtime::Current()->IsStarted() ? INFO : ERROR) 46114691c5e786e8c2c5734f687e4c96217340771beNicolas Geoffray << self->GetException()->Dump() << "\n" << ss.str(); 46264277f38032208a0c1081ff9e466c04009b96383Brian Carlstrom } 4636d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers va_end(args); 4646d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers} 4656d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers 466d423741f91526cada9d081c64ee295ec9863032dElliott Hughesstatic std::string ThreadToString(Thread* thread) { 4672cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (thread == nullptr) { 4682cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier return "nullptr"; 469d423741f91526cada9d081c64ee295ec9863032dElliott Hughes } 470d423741f91526cada9d081c64ee295ec9863032dElliott Hughes std::ostringstream oss; 471d423741f91526cada9d081c64ee295ec9863032dElliott Hughes // TODO: alternatively, we could just return the thread's name. 472d423741f91526cada9d081c64ee295ec9863032dElliott Hughes oss << *thread; 473d423741f91526cada9d081c64ee295ec9863032dElliott Hughes return oss.str(); 474d423741f91526cada9d081c64ee295ec9863032dElliott Hughes} 475d423741f91526cada9d081c64ee295ec9863032dElliott Hughes 47681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartiervoid Monitor::FailedUnlock(mirror::Object* o, 47781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint32_t expected_owner_thread_id, 47881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint32_t found_owner_thread_id, 479ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes Monitor* monitor) { 48081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // Acquire thread list lock so threads won't disappear from under us. 481ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes std::string current_owner_string; 482ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes std::string expected_owner_string; 483ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes std::string found_owner_string; 48481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier uint32_t current_owner_thread_id = 0u; 485ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes { 48650b35e2fd1a68cd1240e4a9d9f363e11764957d1Ian Rogers MutexLock mu(Thread::Current(), *Locks::thread_list_lock_); 48781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier ThreadList* const thread_list = Runtime::Current()->GetThreadList(); 48881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier Thread* expected_owner = thread_list->FindThreadByThreadId(expected_owner_thread_id); 48981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier Thread* found_owner = thread_list->FindThreadByThreadId(found_owner_thread_id); 49081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier 491ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes // Re-read owner now that we hold lock. 49281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier Thread* current_owner = (monitor != nullptr) ? monitor->GetOwner() : nullptr; 49381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (current_owner != nullptr) { 49481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier current_owner_thread_id = current_owner->GetThreadId(); 49581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } 496ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes // Get short descriptions of the threads involved. 497ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes current_owner_string = ThreadToString(current_owner); 49881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier expected_owner_string = expected_owner != nullptr ? ThreadToString(expected_owner) : "unnamed"; 49981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier found_owner_string = found_owner != nullptr ? ThreadToString(found_owner) : "unnamed"; 500ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes } 50181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier 50281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (current_owner_thread_id == 0u) { 50381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (found_owner_thread_id == 0u) { 5046d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("unlock of unowned monitor on object of type '%s'" 5056d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers " on thread '%s'", 506ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes PrettyTypeOf(o).c_str(), 507ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes expected_owner_string.c_str()); 5086d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } else { 5096d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers // Race: the original read found an owner but now there is none 5106d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("unlock of monitor owned by '%s' on object of type '%s'" 5116d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers " (where now the monitor appears unowned) on thread '%s'", 512ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes found_owner_string.c_str(), 513ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes PrettyTypeOf(o).c_str(), 514ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes expected_owner_string.c_str()); 5156d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } 5166d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } else { 51781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (found_owner_thread_id == 0u) { 5186d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers // Race: originally there was no owner, there is now 5196d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("unlock of monitor owned by '%s' on object of type '%s'" 5206d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers " (originally believed to be unowned) on thread '%s'", 521ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes current_owner_string.c_str(), 522ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes PrettyTypeOf(o).c_str(), 523ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes expected_owner_string.c_str()); 5246d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } else { 52581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (found_owner_thread_id != current_owner_thread_id) { 5266d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers // Race: originally found and current owner have changed 5276d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("unlock of monitor originally owned by '%s' (now" 5286d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers " owned by '%s') on object of type '%s' on thread '%s'", 529ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes found_owner_string.c_str(), 530ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes current_owner_string.c_str(), 531ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes PrettyTypeOf(o).c_str(), 532ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes expected_owner_string.c_str()); 5336d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } else { 5346d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("unlock of monitor owned by '%s' on object of type '%s'" 5356d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers " on thread '%s", 536ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes current_owner_string.c_str(), 537ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes PrettyTypeOf(o).c_str(), 538ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes expected_owner_string.c_str()); 5396d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } 5406d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } 5416d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers } 5425f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 5435f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 544d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogersbool Monitor::Unlock(Thread* self) { 5452cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(self != nullptr); 546dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier uint32_t owner_thread_id = 0u; 54781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier { 54881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier MutexLock mu(self, monitor_lock_); 54981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier Thread* owner = owner_; 550dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier if (owner != nullptr) { 551dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier owner_thread_id = owner->GetThreadId(); 552dee19e3caaeb5666055842d656dc0516b901f30cMathieu Chartier } 55381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (owner == self) { 55481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // We own the monitor, so nobody else can be in here. 555fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorUnlock(); 55681c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier if (lock_count_ == 0) { 55781c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier owner_ = nullptr; 55881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier locking_method_ = nullptr; 55981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier locking_dex_pc_ = 0; 56081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // Wake a contender. 56181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier monitor_contenders_.Signal(self); 56281c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } else { 56381c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier --lock_count_; 56481c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier } 56581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier return true; 5665f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 5675f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 56881c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // We don't own this, so we're not allowed to unlock it. 56981c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier // The JNI spec says that we should throw IllegalMonitorStateException in this case. 57081c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier FailedUnlock(GetObject(), self->GetThreadId(), owner_thread_id, this); 57181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier return false; 5725f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 5735f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 5744cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughesvoid Monitor::Wait(Thread* self, int64_t ms, int32_t ns, 5754cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughes bool interruptShouldThrow, ThreadState why) { 5762cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(self != nullptr); 5774cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughes DCHECK(why == kTimedWaiting || why == kWaiting || why == kSleeping); 5785f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 579d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_lock_.Lock(self); 580d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers 5815f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Make sure that we hold the lock. 5825f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes if (owner_ != self) { 583d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_lock_.Unlock(self); 5841af6a1fa35ff7dc0a5c653f19dbc8a91c914aa42Elena Sayapina ThrowIllegalMonitorStateExceptionF("object not locked by thread before wait()"); 5855f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 5865f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 5874cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughes 588df42c4815c30b9df15aacb88070c1e94f41d0226Elliott Hughes // We need to turn a zero-length timed wait into a regular wait because 589df42c4815c30b9df15aacb88070c1e94f41d0226Elliott Hughes // Object.wait(0, 0) is defined as Object.wait(0), which is defined as Object.wait(). 590df42c4815c30b9df15aacb88070c1e94f41d0226Elliott Hughes if (why == kTimedWaiting && (ms == 0 && ns == 0)) { 591df42c4815c30b9df15aacb88070c1e94f41d0226Elliott Hughes why = kWaiting; 592df42c4815c30b9df15aacb88070c1e94f41d0226Elliott Hughes } 593df42c4815c30b9df15aacb88070c1e94f41d0226Elliott Hughes 5945f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Enforce the timeout range. 5955f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes if (ms < 0 || ns < 0 || ns > 999999) { 5961af6a1fa35ff7dc0a5c653f19dbc8a91c914aa42Elena Sayapina monitor_lock_.Unlock(self); 5970aa50ce2fb75bfc2e815a0c33adf9b049561923bNicolas Geoffray self->ThrowNewExceptionF("Ljava/lang/IllegalArgumentException;", 598ef7d42fca18c16fbaf103822ad16f23246e2905dIan Rogers "timeout arguments out of range: ms=%" PRId64 " ns=%d", ms, ns); 5995f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 6005f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 6015f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 6025f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes /* 6035f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * Add ourselves to the set of threads waiting on this monitor, and 6045f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * release our hold. We need to let it go even if we're a few levels 6055f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * deep in a recursive lock, and we need to restore that later. 6065f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * 6075f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * We append to the wait set ahead of clearing the count and owner 6085f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * fields so the subroutine can check that the calling thread owns 6095f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * the monitor. Aside from that, the order of member updates is 6105f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * not order sensitive as we hold the pthread mutex. 6115f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes */ 6125f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes AppendToWaitSet(self); 613440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier ++num_waiters_; 6140399dde18753aa9bd2bd0d7cf60beef154d164a4Ian Rogers int prev_lock_count = lock_count_; 6155f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes lock_count_ = 0; 6162cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier owner_ = nullptr; 617e401d146407d61eeb99f8d6176b2ac13c4df1e33Mathieu Chartier ArtMethod* saved_method = locking_method_; 6182cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier locking_method_ = nullptr; 6190399dde18753aa9bd2bd0d7cf60beef154d164a4Ian Rogers uintptr_t saved_dex_pc = locking_dex_pc_; 6200399dde18753aa9bd2bd0d7cf60beef154d164a4Ian Rogers locking_dex_pc_ = 0; 6215f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 622fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorUnlock(); // For the implict Unlock() just above. This will only end the deepest 623fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // nesting, but that is enough for the visualization, and corresponds to 624fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe // the single Lock() we do afterwards. 625fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorLock(self, GetObject(), true /* is_wait */); 626fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 627b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes bool was_interrupted = false; 62800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers { 629f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier // Update thread state. If the GC wakes up, it'll ignore us, knowing 630f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier // that we won't touch any references in this state, and we'll check 631f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier // our suspend mode before we transition out. 632f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier ScopedThreadSuspension sts(self, why); 633f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier 63400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // Pseudo-atomically wait on self's wait_cond_ and release the monitor lock. 635dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers MutexLock mu(self, *self->GetWaitMutex()); 6365f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 63700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // Set wait_monitor_ to the monitor object we will be waiting on. When wait_monitor_ is 6382cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier // non-null a notifying or interrupting thread must signal the thread's wait_cond_ to wake it 63900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // up. 640dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers DCHECK(self->GetWaitMonitor() == nullptr); 641dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers self->SetWaitMonitor(this); 6425f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 64300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // Release the monitor lock. 644d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_contenders_.Signal(self); 645d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_lock_.Unlock(self); 64600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers 647b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes // Handle the case where the thread was interrupted before we called wait(). 648dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers if (self->IsInterruptedLocked()) { 649b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes was_interrupted = true; 65000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers } else { 65100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers // Wait for a notification or a timeout to occur. 6524cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughes if (why == kWaiting) { 653dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers self->GetWaitConditionVariable()->Wait(self); 65400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers } else { 6554cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughes DCHECK(why == kTimedWaiting || why == kSleeping) << why; 656dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers self->GetWaitConditionVariable()->TimedWait(self, ms, ns); 65700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers } 658328c5dc0d178632125f5a05002051a6adc04766aHans Boehm was_interrupted = self->IsInterruptedLocked(); 65900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers } 6605f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 6615f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 662b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes { 663b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes // We reset the thread's wait_monitor_ field after transitioning back to runnable so 664b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes // that a thread in a waiting/sleeping state has a non-null wait_monitor_ for debugging 665b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes // and diagnostic purposes. (If you reset this earlier, stack dumps will claim that threads 666b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes // are waiting on "null".) 667dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers MutexLock mu(self, *self->GetWaitMutex()); 668dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers DCHECK(self->GetWaitMonitor() != nullptr); 669dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers self->SetWaitMonitor(nullptr); 670b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes } 671b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes 672daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier // Allocate the interrupted exception not holding the monitor lock since it may cause a GC. 673daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier // If the GC requires acquiring the monitor for enqueuing cleared references, this would 674daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier // cause a deadlock if the monitor is held. 675daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier if (was_interrupted && interruptShouldThrow) { 676daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier /* 677daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier * We were interrupted while waiting, or somebody interrupted an 678daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier * un-interruptible thread earlier and we're bailing out immediately. 679daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier * 680daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier * The doc sayeth: "The interrupted status of the current thread is 681daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier * cleared when this exception is thrown." 682daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier */ 683daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier { 684daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier MutexLock mu(self, *self->GetWaitMutex()); 685daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier self->SetInterruptedLocked(false); 686daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier } 687daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier self->ThrowNewException("Ljava/lang/InterruptedException;", nullptr); 688daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier } 689daed5d81e2fdb9d1e03ee6c34567347b92dcfb22Mathieu Chartier 690fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorUnlock(); // End Wait(). 691fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe 692d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Re-acquire the monitor and lock. 69300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers Lock(self); 694d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers monitor_lock_.Lock(self); 695dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers self->GetWaitMutex()->AssertNotHeld(self); 6965f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 6975f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes /* 6985f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * We remove our thread from wait set after restoring the count 6995f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * and owner fields so the subroutine can check that the calling 7005f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * thread owns the monitor. Aside from that, the order of member 7015f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes * updates is not order sensitive as we hold the pthread mutex. 7025f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes */ 7035f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes owner_ = self; 7040399dde18753aa9bd2bd0d7cf60beef154d164a4Ian Rogers lock_count_ = prev_lock_count; 7050399dde18753aa9bd2bd0d7cf60beef154d164a4Ian Rogers locking_method_ = saved_method; 7060399dde18753aa9bd2bd0d7cf60beef154d164a4Ian Rogers locking_dex_pc_ = saved_dex_pc; 707440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier --num_waiters_; 7085f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes RemoveFromWaitSet(self); 7095f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 7101af6a1fa35ff7dc0a5c653f19dbc8a91c914aa42Elena Sayapina monitor_lock_.Unlock(self); 7115f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 7125f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 7135f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesvoid Monitor::Notify(Thread* self) { 7142cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(self != nullptr); 715d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MutexLock mu(self, monitor_lock_); 7165f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Make sure that we hold the lock. 7175f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes if (owner_ != self) { 7186d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("object not locked by thread before notify()"); 7195f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 7205f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 7215f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Signal the first waiting thread in the wait set. 7222cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier while (wait_set_ != nullptr) { 7235f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes Thread* thread = wait_set_; 724dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers wait_set_ = thread->GetWaitNext(); 725dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers thread->SetWaitNext(nullptr); 7265f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 7275f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Check to see if the thread is still waiting. 728277ccbd200ea43590dfc06a93ae184a765327ad0Andreas Gampe MutexLock wait_mu(self, *thread->GetWaitMutex()); 729dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers if (thread->GetWaitMonitor() != nullptr) { 730dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers thread->GetWaitConditionVariable()->Signal(self); 7315f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 7325f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 7335f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 7345f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 7355f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 7365f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesvoid Monitor::NotifyAll(Thread* self) { 7372cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(self != nullptr); 738d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MutexLock mu(self, monitor_lock_); 7395f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Make sure that we hold the lock. 7405f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes if (owner_ != self) { 7416d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("object not locked by thread before notifyAll()"); 7425f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes return; 7435f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 7445f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Signal all threads in the wait set. 7452cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier while (wait_set_ != nullptr) { 7465f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes Thread* thread = wait_set_; 747dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers wait_set_ = thread->GetWaitNext(); 748dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers thread->SetWaitNext(nullptr); 7495f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes thread->Notify(); 7505f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 7515f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 7525f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 753590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartierbool Monitor::Deflate(Thread* self, mirror::Object* obj) { 754590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier DCHECK(obj != nullptr); 7554d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier // Don't need volatile since we only deflate with mutators suspended. 7564d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier LockWord lw(obj->GetLockWord(false)); 757590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // If the lock isn't an inflated monitor, then we don't need to deflate anything. 758590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier if (lw.GetState() == LockWord::kFatLocked) { 759590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier Monitor* monitor = lw.FatLockMonitor(); 760440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier DCHECK(monitor != nullptr); 761590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier MutexLock mu(self, monitor->monitor_lock_); 762440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier // Can't deflate if we have anybody waiting on the CV. 763440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier if (monitor->num_waiters_ > 0) { 764440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier return false; 765440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier } 766590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier Thread* owner = monitor->owner_; 767590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier if (owner != nullptr) { 768590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // Can't deflate if we are locked and have a hash code. 769590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier if (monitor->HasHashCode()) { 770590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier return false; 771590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 772590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // Can't deflate if our lock count is too high. 773590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier if (monitor->lock_count_ > LockWord::kThinLockMaxCount) { 774590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier return false; 775590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 776590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // Deflate to a thin lock. 777e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord new_lw = LockWord::FromThinLockId(owner->GetThreadId(), monitor->lock_count_, 778e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi lw.ReadBarrierState()); 779e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Assume no concurrent read barrier state changes as mutators are suspended. 780e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi obj->SetLockWord(new_lw, false); 7814d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier VLOG(monitor) << "Deflated " << obj << " to thin lock " << owner->GetTid() << " / " 7824d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier << monitor->lock_count_; 783590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } else if (monitor->HasHashCode()) { 784e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord new_lw = LockWord::FromHashCode(monitor->GetHashCode(), lw.ReadBarrierState()); 785e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Assume no concurrent read barrier state changes as mutators are suspended. 786e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi obj->SetLockWord(new_lw, false); 787440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier VLOG(monitor) << "Deflated " << obj << " to hash monitor " << monitor->GetHashCode(); 788590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } else { 789590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // No lock and no hash, just put an empty lock word inside the object. 790e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord new_lw = LockWord::FromDefault(lw.ReadBarrierState()); 791e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Assume no concurrent read barrier state changes as mutators are suspended. 792e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi obj->SetLockWord(new_lw, false); 793440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier VLOG(monitor) << "Deflated" << obj << " to empty lock word"; 794590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 7952cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier // The monitor is deflated, mark the object as null so that we know to delete it during the 796590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // next GC. 79794f7b49578b6aaa80de8ffed230648d601393905Hiroshi Yamauchi monitor->obj_ = GcRoot<mirror::Object>(nullptr); 798590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 799590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier return true; 800590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier} 801590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier 802ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartiervoid Monitor::Inflate(Thread* self, Thread* owner, mirror::Object* obj, int32_t hash_code) { 80374240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe DCHECK(self != nullptr); 80474240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe DCHECK(obj != nullptr); 8055f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes // Allocate and acquire a new monitor. 80674240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe Monitor* m = MonitorPool::CreateMonitor(self, owner, obj, hash_code); 80774240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe DCHECK(m != nullptr); 808d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (m->Install(self)) { 80986ab7912423f63541073af5c487b509e9b2b5420Haifeng Li if (owner != nullptr) { 81086ab7912423f63541073af5c487b509e9b2b5420Haifeng Li VLOG(monitor) << "monitor: thread" << owner->GetThreadId() 81174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe << " created monitor " << m << " for object " << obj; 81286ab7912423f63541073af5c487b509e9b2b5420Haifeng Li } else { 81386ab7912423f63541073af5c487b509e9b2b5420Haifeng Li VLOG(monitor) << "monitor: Inflate with hashcode " << hash_code 81474240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe << " created monitor " << m << " for object " << obj; 81586ab7912423f63541073af5c487b509e9b2b5420Haifeng Li } 81674240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe Runtime::Current()->GetMonitorList()->Add(m); 8174d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier CHECK_EQ(obj->GetLockWord(true).GetState(), LockWord::kFatLocked); 81874240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe } else { 81974240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe MonitorPool::ReleaseMonitor(self, m); 820ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 821ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier} 822ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier 8230cd81352a7c06e381951cea1b104fd73516f4341Mathieu Chartiervoid Monitor::InflateThinLocked(Thread* self, Handle<mirror::Object> obj, LockWord lock_word, 824ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier uint32_t hash_code) { 825ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier DCHECK_EQ(lock_word.GetState(), LockWord::kThinLocked); 826ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier uint32_t owner_thread_id = lock_word.ThinLockOwner(); 827ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier if (owner_thread_id == self->GetThreadId()) { 828ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // We own the monitor, we can easily inflate it. 829eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier Inflate(self, self, obj.Get(), hash_code); 830ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } else { 831ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier ThreadList* thread_list = Runtime::Current()->GetThreadList(); 832ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // Suspend the owner, inflate. First change to blocked and give up mutator_lock_. 833eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier self->SetMonitorEnterObject(obj.Get()); 834a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier bool timed_out; 835f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier Thread* owner; 836f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier { 837f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier ScopedThreadSuspension sts(self, kBlocked); 838f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier owner = thread_list->SuspendThreadByThreadId(owner_thread_id, false, &timed_out); 839f1d666e1b48f8070ef1177fce156c08827f08eb8Mathieu Chartier } 840a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier if (owner != nullptr) { 841a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier // We succeeded in suspending the thread, check the lock's status didn't change. 842a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier lock_word = obj->GetLockWord(true); 843a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier if (lock_word.GetState() == LockWord::kThinLocked && 844a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier lock_word.ThinLockOwner() == owner_thread_id) { 845a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier // Go ahead and inflate the lock. 846a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier Inflate(self, owner, obj.Get(), hash_code); 847ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 848a1ee14fc66a3c99bb7d5744ace881ec93c46f59dMathieu Chartier thread_list->Resume(owner, false); 849ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier } 850dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers self->SetMonitorEnterObject(nullptr); 851d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 8525f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 8535f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 854719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// Fool annotalysis into thinking that the lock on obj is acquired. 855719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogersstatic mirror::Object* FakeLock(mirror::Object* obj) 856719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers EXCLUSIVE_LOCK_FUNCTION(obj) NO_THREAD_SAFETY_ANALYSIS { 857719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers return obj; 858719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers} 859719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers 860719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// Fool annotalysis into thinking that the lock on obj is release. 861719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogersstatic mirror::Object* FakeUnlock(mirror::Object* obj) 862719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers UNLOCK_FUNCTION(obj) NO_THREAD_SAFETY_ANALYSIS { 863719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers return obj; 864719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers} 865719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers 86623da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartiermirror::Object* Monitor::MonitorEnter(Thread* self, mirror::Object* obj, bool trylock) { 8672cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(self != nullptr); 8682cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(obj != nullptr); 8692d096c94fbd3fd2470b8ac1a0da6f577b3f69f42Mathieu Chartier self->AssertThreadSuspensionIsAllowable(); 870719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers obj = FakeLock(obj); 871d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t thread_id = self->GetThreadId(); 872d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers size_t contention_count = 0; 873eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier StackHandleScope<1> hs(self); 874eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier Handle<mirror::Object> h_obj(hs.NewHandle(obj)); 875d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers while (true) { 876eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier LockWord lock_word = h_obj->GetLockWord(true); 877d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers switch (lock_word.GetState()) { 878d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kUnlocked: { 879e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord thin_locked(LockWord::FromThinLockId(thread_id, 0, lock_word.ReadBarrierState())); 880228602f562f1d130d06e60a98752d99c2d467d6aIan Rogers if (h_obj->CasLockWordWeakSequentiallyConsistent(lock_word, thin_locked)) { 881fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorLock(self, h_obj.Get(), false /* is_wait */); 8823035961cb41865b80b927546be0c708b6389cec6Hans Boehm // CasLockWord enforces more than the acquire ordering we need here. 883eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier return h_obj.Get(); // Success! 884d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 885d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers continue; // Go again. 8865f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 887d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kThinLocked: { 888d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t owner_thread_id = lock_word.ThinLockOwner(); 889d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (owner_thread_id == thread_id) { 890d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // We own the lock, increase the recursion count. 891d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t new_count = lock_word.ThinLockCount() + 1; 892d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (LIKELY(new_count <= LockWord::kThinLockMaxCount)) { 893e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord thin_locked(LockWord::FromThinLockId(thread_id, new_count, 894e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi lock_word.ReadBarrierState())); 895e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi if (!kUseReadBarrier) { 896e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi h_obj->SetLockWord(thin_locked, true); 897fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorLock(self, h_obj.Get(), false /* is_wait */); 898e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return h_obj.Get(); // Success! 899e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } else { 900e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Use CAS to preserve the read barrier state. 901e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi if (h_obj->CasLockWordWeakSequentiallyConsistent(lock_word, thin_locked)) { 902fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe AtraceMonitorLock(self, h_obj.Get(), false /* is_wait */); 903e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return h_obj.Get(); // Success! 904e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 905e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 906e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi continue; // Go again. 907d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } else { 908d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // We'd overflow the recursion count, so inflate the monitor. 909eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier InflateThinLocked(self, h_obj, lock_word, 0); 910d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 911d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } else { 91223da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier if (trylock) { 91323da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return nullptr; 91423da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } 915d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Contention. 916d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers contention_count++; 917ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier Runtime* runtime = Runtime::Current(); 918ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier if (contention_count <= runtime->GetMaxSpinsBeforeThinkLockInflation()) { 919b363f666883860d40823d5528df3c98c897f74f4Mathieu Chartier // TODO: Consider switching the thread state to kBlocked when we are yielding. 920251755cd511463260e60be98bf138b6aa1c14bf3Mathieu Chartier // Use sched_yield instead of NanoSleep since NanoSleep can wait much longer than the 921251755cd511463260e60be98bf138b6aa1c14bf3Mathieu Chartier // parameter you pass in. This can cause thread suspension to take excessively long 922b363f666883860d40823d5528df3c98c897f74f4Mathieu Chartier // and make long pauses. See b/16307460. 923251755cd511463260e60be98bf138b6aa1c14bf3Mathieu Chartier sched_yield(); 9245f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } else { 925d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers contention_count = 0; 926eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier InflateThinLocked(self, h_obj, lock_word, 0); 9275f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 9285f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 929d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers continue; // Start from the beginning. 930d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 931d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kFatLocked: { 932d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Monitor* mon = lock_word.FatLockMonitor(); 93323da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier if (trylock) { 93423da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return mon->TryLock(self) ? h_obj.Get() : nullptr; 93523da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } else { 93623da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier mon->Lock(self); 93723da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier return h_obj.Get(); // Success! 93823da026ec7a7fae22833ed2f61a80d9f9bf7e732Mathieu Chartier } 9395f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 940719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers case LockWord::kHashCode: 941ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // Inflate with the existing hashcode. 942eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier Inflate(self, nullptr, h_obj.Get(), lock_word.GetHashCode()); 943719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers continue; // Start from the beginning. 944590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier default: { 945590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier LOG(FATAL) << "Invalid monitor state " << lock_word.GetState(); 946fc6898769ae1ef91ec3e41c0a273401213cb82cdAndreas Gampe UNREACHABLE(); 947590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 9485f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 9495f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 9505f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 9515f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 9522dd0e2cea360bc9206eb88ecc40d259e796c239dIan Rogersbool Monitor::MonitorExit(Thread* self, mirror::Object* obj) { 9532cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(self != nullptr); 9542cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier DCHECK(obj != nullptr); 9552d096c94fbd3fd2470b8ac1a0da6f577b3f69f42Mathieu Chartier self->AssertThreadSuspensionIsAllowable(); 956719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers obj = FakeUnlock(obj); 957eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier StackHandleScope<1> hs(self); 958eb8167a4f4d27fce0530f6724ab8032610cd146bMathieu Chartier Handle<mirror::Object> h_obj(hs.NewHandle(obj)); 959e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi while (true) { 960e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord lock_word = obj->GetLockWord(true); 961e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi switch (lock_word.GetState()) { 962e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi case LockWord::kHashCode: 963e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Fall-through. 964e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi case LockWord::kUnlocked: 96581c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier FailedUnlock(h_obj.Get(), self->GetThreadId(), 0u, nullptr); 966d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return false; // Failure. 967e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi case LockWord::kThinLocked: { 968e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi uint32_t thread_id = self->GetThreadId(); 969e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi uint32_t owner_thread_id = lock_word.ThinLockOwner(); 970e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi if (owner_thread_id != thread_id) { 97181c170fede9af9174aba71428334ac8f366a4b4fMathieu Chartier FailedUnlock(h_obj.Get(), thread_id, owner_thread_id, nullptr); 972e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return false; // Failure. 973d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } else { 974e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // We own the lock, decrease the recursion count. 975e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LockWord new_lw = LockWord::Default(); 976e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi if (lock_word.ThinLockCount() != 0) { 977e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi uint32_t new_count = lock_word.ThinLockCount() - 1; 978e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi new_lw = LockWord::FromThinLockId(thread_id, new_count, lock_word.ReadBarrierState()); 979e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } else { 980e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi new_lw = LockWord::FromDefault(lock_word.ReadBarrierState()); 981e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 982e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi if (!kUseReadBarrier) { 983e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi DCHECK_EQ(new_lw.ReadBarrierState(), 0U); 984e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi h_obj->SetLockWord(new_lw, true); 985825ab1c3f44fd84e5967f023c2dd8d36c6906f08Andreas Gampe AtraceMonitorUnlock(); 986e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Success! 987e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return true; 988e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } else { 989e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Use CAS to preserve the read barrier state. 990e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi if (h_obj->CasLockWordWeakSequentiallyConsistent(lock_word, new_lw)) { 991825ab1c3f44fd84e5967f023c2dd8d36c6906f08Andreas Gampe AtraceMonitorUnlock(); 992e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi // Success! 993e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return true; 994e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 995e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 996e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi continue; // Go again. 997d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 9985f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 999e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi case LockWord::kFatLocked: { 1000e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi Monitor* mon = lock_word.FatLockMonitor(); 1001e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return mon->Unlock(self); 1002e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 1003e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi default: { 1004e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi LOG(FATAL) << "Invalid monitor state " << lock_word.GetState(); 1005e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi return false; 1006e15ea086439b41a805d164d2beb07b4ba96aaa97Hiroshi Yamauchi } 1007590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 10085f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 10095f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 10105f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 10112dd0e2cea360bc9206eb88ecc40d259e796c239dIan Rogersvoid Monitor::Wait(Thread* self, mirror::Object *obj, int64_t ms, int32_t ns, 10124cd121ef0cb35fced70c7d9de378277be7a727d9Elliott Hughes bool interruptShouldThrow, ThreadState why) { 10134d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier DCHECK(self != nullptr); 10144d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier DCHECK(obj != nullptr); 10154d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier LockWord lock_word = obj->GetLockWord(true); 101643c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers while (lock_word.GetState() != LockWord::kFatLocked) { 101743c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers switch (lock_word.GetState()) { 101843c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers case LockWord::kHashCode: 101943c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers // Fall-through. 102043c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers case LockWord::kUnlocked: 1021d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers ThrowIllegalMonitorStateExceptionF("object not locked by thread before wait()"); 1022d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return; // Failure. 102343c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers case LockWord::kThinLocked: { 102443c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers uint32_t thread_id = self->GetThreadId(); 102543c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers uint32_t owner_thread_id = lock_word.ThinLockOwner(); 102643c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers if (owner_thread_id != thread_id) { 102743c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers ThrowIllegalMonitorStateExceptionF("object not locked by thread before wait()"); 102843c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers return; // Failure. 102943c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers } else { 103043c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers // We own the lock, inflate to enqueue ourself on the Monitor. May fail spuriously so 103143c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers // re-load. 103243c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers Inflate(self, self, obj, 0); 103343c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers lock_word = obj->GetLockWord(true); 103443c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers } 103543c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers break; 103643c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers } 103743c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers case LockWord::kFatLocked: // Unreachable given the loop condition above. Fall-through. 103843c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers default: { 103943c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers LOG(FATAL) << "Invalid monitor state " << lock_word.GetState(); 104043c69cc4cea794cd4d89d9d0680b1e25c6d02accIan Rogers return; 1041d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 1042590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 10435f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 1044d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Monitor* mon = lock_word.FatLockMonitor(); 1045d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers mon->Wait(self, ms, ns, interruptShouldThrow, why); 10465f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 10475f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 104813c479e7e9b62115fe0409e5273c1e976a1c09f9Ian Rogersvoid Monitor::DoNotify(Thread* self, mirror::Object* obj, bool notify_all) { 10494d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier DCHECK(self != nullptr); 10504d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier DCHECK(obj != nullptr); 10514d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier LockWord lock_word = obj->GetLockWord(true); 1052d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers switch (lock_word.GetState()) { 1053ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kHashCode: 1054ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // Fall-through. 1055d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kUnlocked: 10566d0b13e931fb73d5e964d14b0a7ecd1f3f5db547Ian Rogers ThrowIllegalMonitorStateExceptionF("object not locked by thread before notify()"); 1057d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return; // Failure. 1058d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kThinLocked: { 1059d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t thread_id = self->GetThreadId(); 1060d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t owner_thread_id = lock_word.ThinLockOwner(); 1061d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (owner_thread_id != thread_id) { 1062d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers ThrowIllegalMonitorStateExceptionF("object not locked by thread before notify()"); 1063d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return; // Failure. 1064d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } else { 1065d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // We own the lock but there's no Monitor and therefore no waiters. 1066d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return; // Success. 1067d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 1068d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 1069d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kFatLocked: { 1070d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Monitor* mon = lock_word.FatLockMonitor(); 1071d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (notify_all) { 1072d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers mon->NotifyAll(self); 1073d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } else { 1074d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers mon->Notify(self); 1075d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 1076d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return; // Success. 10775f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 1078590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier default: { 1079590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier LOG(FATAL) << "Invalid monitor state " << lock_word.GetState(); 1080590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier return; 1081590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 10825f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 10835f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 10845f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 1085d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogersuint32_t Monitor::GetLockOwnerThreadId(mirror::Object* obj) { 10864d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier DCHECK(obj != nullptr); 10874d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier LockWord lock_word = obj->GetLockWord(true); 1088d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers switch (lock_word.GetState()) { 1089ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kHashCode: 1090ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // Fall-through. 1091d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kUnlocked: 1092d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return ThreadList::kInvalidThreadId; 1093d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kThinLocked: 1094d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return lock_word.ThinLockOwner(); 1095d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kFatLocked: { 1096d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Monitor* mon = lock_word.FatLockMonitor(); 1097d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return mon->GetOwnerThreadId(); 10985f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 1099590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier default: { 1100d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers LOG(FATAL) << "Unreachable"; 11012c4257be8191c5eefde744e8965fcefc80a0a97dIan Rogers UNREACHABLE(); 1102590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier } 11035f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes } 11045f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} 11055f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes 11068e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughesvoid Monitor::DescribeWait(std::ostream& os, const Thread* thread) { 1107d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers // Determine the wait message and object we're waiting or blocked upon. 1108d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers mirror::Object* pretty_object = nullptr; 1109d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers const char* wait_message = nullptr; 1110d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers uint32_t lock_owner = ThreadList::kInvalidThreadId; 1111d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers ThreadState state = thread->GetState(); 1112b4e94fd380a84c755264e8668a16052442c7ec32Elliott Hughes if (state == kWaiting || state == kTimedWaiting || state == kSleeping) { 1113d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers wait_message = (state == kSleeping) ? " - sleeping on " : " - waiting on "; 1114d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers Thread* self = Thread::Current(); 1115d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers MutexLock mu(self, *thread->GetWaitMutex()); 1116d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers Monitor* monitor = thread->GetWaitMonitor(); 1117d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers if (monitor != nullptr) { 11184cba0d979a11f955e6ec3c0f1bf61478af7aa810Hiroshi Yamauchi pretty_object = monitor->GetObject(); 11198e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes } 112034e069606d6f1698cd3c33b39e72b79ae27e1c7bElliott Hughes } else if (state == kBlocked) { 1121d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers wait_message = " - waiting to lock "; 1122d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers pretty_object = thread->GetMonitorEnterObject(); 1123d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers if (pretty_object != nullptr) { 1124d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers lock_owner = pretty_object->GetLockOwnerThreadId(); 11258e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes } 11268e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes } 11278e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes 1128d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers if (wait_message != nullptr) { 1129d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers if (pretty_object == nullptr) { 1130d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers os << wait_message << "an unknown object"; 1131d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers } else { 11324d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier if ((pretty_object->GetLockWord(true).GetState() == LockWord::kThinLocked) && 1133d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers Locks::mutator_lock_->IsExclusiveHeld(Thread::Current())) { 1134d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers // Getting the identity hashcode here would result in lock inflation and suspension of the 1135d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers // current thread, which isn't safe if this is the only runnable thread. 1136d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers os << wait_message << StringPrintf("<@addr=0x%" PRIxPTR "> (a %s)", 1137d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers reinterpret_cast<intptr_t>(pretty_object), 1138d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers PrettyTypeOf(pretty_object).c_str()); 1139d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers } else { 1140d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers // - waiting on <0x6008c468> (a java.lang.Class<java.lang.ref.ReferenceQueue>) 11414936159997132d7706d9700c646f35ef0283df4bMathieu Chartier // Call PrettyTypeOf before IdentityHashCode since IdentityHashCode can cause thread 11424936159997132d7706d9700c646f35ef0283df4bMathieu Chartier // suspension and move pretty_object. 11434936159997132d7706d9700c646f35ef0283df4bMathieu Chartier const std::string pretty_type(PrettyTypeOf(pretty_object)); 1144d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers os << wait_message << StringPrintf("<0x%08x> (a %s)", pretty_object->IdentityHashCode(), 11454936159997132d7706d9700c646f35ef0283df4bMathieu Chartier pretty_type.c_str()); 1146d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers } 1147d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers } 1148d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers // - waiting to lock <0x613f83d8> (a java.lang.Object) held by thread 5 1149d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers if (lock_owner != ThreadList::kInvalidThreadId) { 1150d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers os << " held by thread " << lock_owner; 1151d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers } 1152d803bc7ce255be6c16eaf6a8a58a742515e9da9fIan Rogers os << "\n"; 11538e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes } 11548e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes} 11558e4aac52962d54cb4be2078b9cd95685e067133aElliott Hughes 11562dd0e2cea360bc9206eb88ecc40d259e796c239dIan Rogersmirror::Object* Monitor::GetContendedMonitor(Thread* thread) { 1157f9501700f51586cb6ba7cc0ffcb5a920bd64adf1Elliott Hughes // This is used to implement JDWP's ThreadReference.CurrentContendedMonitor, and has a bizarre 1158f9501700f51586cb6ba7cc0ffcb5a920bd64adf1Elliott Hughes // definition of contended that includes a monitor a thread is trying to enter... 1159dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers mirror::Object* result = thread->GetMonitorEnterObject(); 11602cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (result == nullptr) { 1161d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // ...but also a monitor that the thread is waiting on. 1162dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers MutexLock mu(Thread::Current(), *thread->GetWaitMutex()); 1163dd7624d2b9e599d57762d12031b10b89defc9807Ian Rogers Monitor* monitor = thread->GetWaitMonitor(); 11642cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (monitor != nullptr) { 1165d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers result = monitor->GetObject(); 1166f9501700f51586cb6ba7cc0ffcb5a920bd64adf1Elliott Hughes } 1167f9501700f51586cb6ba7cc0ffcb5a920bd64adf1Elliott Hughes } 1168d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return result; 1169f9501700f51586cb6ba7cc0ffcb5a920bd64adf1Elliott Hughes} 1170f9501700f51586cb6ba7cc0ffcb5a920bd64adf1Elliott Hughes 11712dd0e2cea360bc9206eb88ecc40d259e796c239dIan Rogersvoid Monitor::VisitLocks(StackVisitor* stack_visitor, void (*callback)(mirror::Object*, void*), 1172760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe void* callback_context, bool abort_on_failure) { 1173e401d146407d61eeb99f8d6176b2ac13c4df1e33Mathieu Chartier ArtMethod* m = stack_visitor->GetMethod(); 11742cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier CHECK(m != nullptr); 117508fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes 117608fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes // Native methods are an easy special case. 117708fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes // TODO: use the JNI implementation's table of explicit MonitorEnter calls and dump those too. 117808fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes if (m->IsNative()) { 117908fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes if (m->IsSynchronized()) { 1180e401d146407d61eeb99f8d6176b2ac13c4df1e33Mathieu Chartier mirror::Object* jni_this = 1181e401d146407d61eeb99f8d6176b2ac13c4df1e33Mathieu Chartier stack_visitor->GetCurrentHandleScope(sizeof(void*))->GetReference(0); 11824993bbc8eda377804e585efd918f8ab9d9eab7d4Elliott Hughes callback(jni_this, callback_context); 118308fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes } 118408fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes return; 118508fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes } 118608fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes 118761f916cc4757610ce308bfdea9a00cf29afd2b02jeffhao // Proxy methods should not be synchronized. 118861f916cc4757610ce308bfdea9a00cf29afd2b02jeffhao if (m->IsProxyMethod()) { 118961f916cc4757610ce308bfdea9a00cf29afd2b02jeffhao CHECK(!m->IsSynchronized()); 119061f916cc4757610ce308bfdea9a00cf29afd2b02jeffhao return; 119161f916cc4757610ce308bfdea9a00cf29afd2b02jeffhao } 119261f916cc4757610ce308bfdea9a00cf29afd2b02jeffhao 119308fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes // Is there any reason to believe there's any synchronization in this method? 1194bfd9a4378eacaf2dc2bbe05ad48c5164fc93c9feMathieu Chartier const DexFile::CodeItem* code_item = m->GetCodeItem(); 11952cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier CHECK(code_item != nullptr) << PrettyMethod(m); 119608fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes if (code_item->tries_size_ == 0) { 11977934ac288acfb2552bb0b06ec1f61e5820d924a4Brian Carlstrom return; // No "tries" implies no synchronization, so no held locks to report. 119808fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes } 119908fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes 1200760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe // Get the dex pc. If abort_on_failure is false, GetDexPc will not abort in the case it cannot 1201760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe // find the dex pc, and instead return kDexNoIndex. Then bail out, as it indicates we have an 1202760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe // inconsistent stack anyways. 1203760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe uint32_t dex_pc = stack_visitor->GetDexPc(abort_on_failure); 1204760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe if (!abort_on_failure && dex_pc == DexFile::kDexNoIndex) { 1205760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe LOG(ERROR) << "Could not find dex_pc for " << PrettyMethod(m); 1206760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe return; 1207760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe } 1208760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe 120980537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes // Ask the verifier for the dex pcs of all the monitor-enter instructions corresponding to 121080537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes // the locks held in this stack frame. 121180537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes std::vector<uint32_t> monitor_enter_dex_pcs; 1212760172c3ccd6e75f6f1a89d8006934e8ffb1303eAndreas Gampe verifier::MethodVerifier::FindLocksAtDexPc(m, dex_pc, &monitor_enter_dex_pcs); 1213e6a8eec3a5db28de7d5db6d78e38033b80740e49Mathieu Chartier for (uint32_t monitor_dex_pc : monitor_enter_dex_pcs) { 121480537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes // The verifier works in terms of the dex pcs of the monitor-enter instructions. 121580537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes // We want the registers used by those instructions (so we can read the values out of them). 12160f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz const Instruction* monitor_enter_instruction = 12170f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz Instruction::At(&code_item->insns_[monitor_dex_pc]); 121808fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes 121980537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes // Quick sanity check. 12200f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz CHECK_EQ(monitor_enter_instruction->Opcode(), Instruction::MONITOR_ENTER) 12210f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz << "expected monitor-enter @" << monitor_dex_pc << "; was " 12220f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz << reinterpret_cast<const void*>(monitor_enter_instruction); 122380537bb742dff4ccdf6d04b1c0bb7d2179acc8cbElliott Hughes 12240f7c93322e50ff53eeba6b9ae13cf73eb0617587Sebastien Hertz uint16_t monitor_register = monitor_enter_instruction->VRegA(); 122515b9d5274399736ac09705f0507df24fac4f00c1Nicolas Geoffray uint32_t value; 122615b9d5274399736ac09705f0507df24fac4f00c1Nicolas Geoffray bool success = stack_visitor->GetVReg(m, monitor_register, kReferenceVReg, &value); 122715b9d5274399736ac09705f0507df24fac4f00c1Nicolas Geoffray CHECK(success) << "Failed to read v" << monitor_register << " of kind " 122815b9d5274399736ac09705f0507df24fac4f00c1Nicolas Geoffray << kReferenceVReg << " in method " << PrettyMethod(m); 122915b9d5274399736ac09705f0507df24fac4f00c1Nicolas Geoffray mirror::Object* o = reinterpret_cast<mirror::Object*>(value); 12304993bbc8eda377804e585efd918f8ab9d9eab7d4Elliott Hughes callback(o, callback_context); 123108fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes } 123208fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes} 123308fc03ae5dded4adc9b45b7014a4b9dfedbe95a6Elliott Hughes 1234d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogersbool Monitor::IsValidLockWord(LockWord lock_word) { 1235d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers switch (lock_word.GetState()) { 1236d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kUnlocked: 1237d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Nothing to check. 1238d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return true; 1239d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kThinLocked: 1240d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Basic sanity check of owner. 1241d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return lock_word.ThinLockOwner() != ThreadList::kInvalidThreadId; 1242d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kFatLocked: { 1243d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Check the monitor appears in the monitor list. 1244d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Monitor* mon = lock_word.FatLockMonitor(); 1245d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MonitorList* list = Runtime::Current()->GetMonitorList(); 1246d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MutexLock mu(Thread::Current(), list->monitor_list_lock_); 1247d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers for (Monitor* list_mon : list->list_) { 1248d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers if (mon == list_mon) { 1249d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return true; // Found our monitor. 1250d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 12517dfb28c066159e6cde8181720f0c451a700ef966Ian Rogers } 1252d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return false; // Fail - unowned monitor in an object. 12537dfb28c066159e6cde8181720f0c451a700ef966Ian Rogers } 1254ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kHashCode: 1255ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier return true; 1256d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers default: 1257d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers LOG(FATAL) << "Unreachable"; 12582c4257be8191c5eefde744e8965fcefc80a0a97dIan Rogers UNREACHABLE(); 12597dfb28c066159e6cde8181720f0c451a700ef966Ian Rogers } 12607dfb28c066159e6cde8181720f0c451a700ef966Ian Rogers} 12617dfb28c066159e6cde8181720f0c451a700ef966Ian Rogers 126290443477f9a0061581c420775ce3b7eeae7468bcMathieu Chartierbool Monitor::IsLocked() SHARED_REQUIRES(Locks::mutator_lock_) { 1263ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier MutexLock mu(Thread::Current(), monitor_lock_); 1264ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier return owner_ != nullptr; 1265ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier} 1266ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier 1267dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartiervoid Monitor::TranslateLocation(ArtMethod* method, 1268dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier uint32_t dex_pc, 1269dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier const char** source_file, 1270dc3c630ffdb3487bc46d878bf89c886f8ee69ef3Mathieu Chartier int32_t* line_number) { 127133dc7717cd16592bcc825350bea6305be9eb2ea1jeffhao // If method is null, location is unknown 12722cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (method == nullptr) { 1273d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers *source_file = ""; 1274d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers *line_number = 0; 127533dc7717cd16592bcc825350bea6305be9eb2ea1jeffhao return; 127633dc7717cd16592bcc825350bea6305be9eb2ea1jeffhao } 1277bfd9a4378eacaf2dc2bbe05ad48c5164fc93c9feMathieu Chartier *source_file = method->GetDeclaringClassSourceFile(); 12782cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (*source_file == nullptr) { 1279d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers *source_file = ""; 1280d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 1281bfd9a4378eacaf2dc2bbe05ad48c5164fc93c9feMathieu Chartier *line_number = method->GetLineNumFromDexPC(dex_pc); 1282d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers} 1283d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers 1284d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogersuint32_t Monitor::GetOwnerThreadId() { 1285d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers MutexLock mu(Thread::Current(), monitor_lock_); 1286d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Thread* owner = owner_; 12872cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier if (owner != nullptr) { 1288d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return owner->GetThreadId(); 1289d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } else { 1290d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers return ThreadList::kInvalidThreadId; 129112c51e3e5a8b5655351539618f1cf2331f52d1abElliott Hughes } 129233dc7717cd16592bcc825350bea6305be9eb2ea1jeffhao} 129333dc7717cd16592bcc825350bea6305be9eb2ea1jeffhao 1294c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu ChartierMonitorList::MonitorList() 1295440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier : allow_new_monitors_(true), monitor_list_lock_("MonitorList lock", kMonitorListLock), 1296c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier monitor_add_condition_("MonitorList disallow condition", monitor_list_lock_) { 1297c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes} 1298c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes 1299c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott HughesMonitorList::~MonitorList() { 130074240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe Thread* self = Thread::Current(); 130174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe MutexLock mu(self, monitor_list_lock_); 130274240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe // Release all monitors to the pool. 130374240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe // TODO: Is it an invariant that *all* open monitors are in the list? Then we could 130474240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe // clear faster in the pool. 130574240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe MonitorPool::ReleaseMonitors(self, &list_); 1306c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes} 1307c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes 1308c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartiervoid MonitorList::DisallowNewMonitors() { 1309fdbd13c7af91a042eda753e436eeebf0e1937250Hiroshi Yamauchi CHECK(!kUseReadBarrier); 131050b35e2fd1a68cd1240e4a9d9f363e11764957d1Ian Rogers MutexLock mu(Thread::Current(), monitor_list_lock_); 1311c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier allow_new_monitors_ = false; 1312c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier} 1313c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier 1314c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartiervoid MonitorList::AllowNewMonitors() { 1315fdbd13c7af91a042eda753e436eeebf0e1937250Hiroshi Yamauchi CHECK(!kUseReadBarrier); 1316c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier Thread* self = Thread::Current(); 1317c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier MutexLock mu(self, monitor_list_lock_); 1318c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier allow_new_monitors_ = true; 1319c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier monitor_add_condition_.Broadcast(self); 1320c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier} 1321c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier 13220b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchivoid MonitorList::BroadcastForNewMonitors() { 13230b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi CHECK(kUseReadBarrier); 13240b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi Thread* self = Thread::Current(); 13250b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi MutexLock mu(self, monitor_list_lock_); 13260b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi monitor_add_condition_.Broadcast(self); 13270b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi} 13280b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi 1329c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartiervoid MonitorList::Add(Monitor* m) { 1330c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier Thread* self = Thread::Current(); 1331c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier MutexLock mu(self, monitor_list_lock_); 13320b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi while (UNLIKELY((!kUseReadBarrier && !allow_new_monitors_) || 13330b71357fb52be9bb06d35396a3042b4381b01041Hiroshi Yamauchi (kUseReadBarrier && !self->GetWeakRefAccessEnabled()))) { 1334c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier monitor_add_condition_.WaitHoldingLocks(self); 1335c11d9b8870de5f860b13c84003ade7b3f3125a52Mathieu Chartier } 1336c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes list_.push_front(m); 1337c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes} 1338c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes 133997509954404d031594b2ecbda607314d169d512eMathieu Chartiervoid MonitorList::SweepMonitorList(IsMarkedVisitor* visitor) { 134074240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe Thread* self = Thread::Current(); 134174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe MutexLock mu(self, monitor_list_lock_); 134202e25119b15a6f619f17db99f5d05124a5807ff3Mathieu Chartier for (auto it = list_.begin(); it != list_.end(); ) { 1343c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes Monitor* m = *it; 13444cba0d979a11f955e6ec3c0f1bf61478af7aa810Hiroshi Yamauchi // Disable the read barrier in GetObject() as this is called by GC. 13454cba0d979a11f955e6ec3c0f1bf61478af7aa810Hiroshi Yamauchi mirror::Object* obj = m->GetObject<kWithoutReadBarrier>(); 1346590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // The object of a monitor can be null if we have deflated it. 134797509954404d031594b2ecbda607314d169d512eMathieu Chartier mirror::Object* new_obj = obj != nullptr ? visitor->IsMarked(obj) : nullptr; 13486aa3df965395566ed6a4fec4af37c2b7577992e9Mathieu Chartier if (new_obj == nullptr) { 13496aa3df965395566ed6a4fec4af37c2b7577992e9Mathieu Chartier VLOG(monitor) << "freeing monitor " << m << " belonging to unmarked object " 13504cba0d979a11f955e6ec3c0f1bf61478af7aa810Hiroshi Yamauchi << obj; 135174240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe MonitorPool::ReleaseMonitor(self, m); 1352c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes it = list_.erase(it); 1353c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes } else { 13546aa3df965395566ed6a4fec4af37c2b7577992e9Mathieu Chartier m->SetObject(new_obj); 1355c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes ++it; 1356c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes } 1357c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes } 1358c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes} 1359c33a32bccc4c66ed82ce3a580b16636399385cb4Elliott Hughes 136097509954404d031594b2ecbda607314d169d512eMathieu Chartierclass MonitorDeflateVisitor : public IsMarkedVisitor { 136197509954404d031594b2ecbda607314d169d512eMathieu Chartier public: 136297509954404d031594b2ecbda607314d169d512eMathieu Chartier MonitorDeflateVisitor() : self_(Thread::Current()), deflate_count_(0) {} 136397509954404d031594b2ecbda607314d169d512eMathieu Chartier 136497509954404d031594b2ecbda607314d169d512eMathieu Chartier virtual mirror::Object* IsMarked(mirror::Object* object) OVERRIDE 136590443477f9a0061581c420775ce3b7eeae7468bcMathieu Chartier SHARED_REQUIRES(Locks::mutator_lock_) { 136697509954404d031594b2ecbda607314d169d512eMathieu Chartier if (Monitor::Deflate(self_, object)) { 136797509954404d031594b2ecbda607314d169d512eMathieu Chartier DCHECK_NE(object->GetLockWord(true).GetState(), LockWord::kFatLocked); 136897509954404d031594b2ecbda607314d169d512eMathieu Chartier ++deflate_count_; 136997509954404d031594b2ecbda607314d169d512eMathieu Chartier // If we deflated, return null so that the monitor gets removed from the array. 137097509954404d031594b2ecbda607314d169d512eMathieu Chartier return nullptr; 137197509954404d031594b2ecbda607314d169d512eMathieu Chartier } 137297509954404d031594b2ecbda607314d169d512eMathieu Chartier return object; // Monitor was not deflated. 1373440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier } 137497509954404d031594b2ecbda607314d169d512eMathieu Chartier 137597509954404d031594b2ecbda607314d169d512eMathieu Chartier Thread* const self_; 137697509954404d031594b2ecbda607314d169d512eMathieu Chartier size_t deflate_count_; 137797509954404d031594b2ecbda607314d169d512eMathieu Chartier}; 1378440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier 137948ab687d1f864fec93c2682de6fdc44ab784e2f8Mathieu Chartiersize_t MonitorList::DeflateMonitors() { 138097509954404d031594b2ecbda607314d169d512eMathieu Chartier MonitorDeflateVisitor visitor; 138197509954404d031594b2ecbda607314d169d512eMathieu Chartier Locks::mutator_lock_->AssertExclusiveHeld(visitor.self_); 138297509954404d031594b2ecbda607314d169d512eMathieu Chartier SweepMonitorList(&visitor); 138397509954404d031594b2ecbda607314d169d512eMathieu Chartier return visitor.deflate_count_; 1384440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier} 1385440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier 13862cebb24bfc3247d3e9be138a3350106737455918Mathieu ChartierMonitorInfo::MonitorInfo(mirror::Object* obj) : owner_(nullptr), entry_count_(0) { 13874d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier DCHECK(obj != nullptr); 13884d7f61d44a732cfbc8573e5d93364983fd746888Mathieu Chartier LockWord lock_word = obj->GetLockWord(true); 1389d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers switch (lock_word.GetState()) { 1390d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kUnlocked: 1391ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier // Fall-through. 1392590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier case LockWord::kForwardingAddress: 1393590fee9e8972f872301c2d16a575d579ee564beeMathieu Chartier // Fall-through. 1394ad2541a59c00c2c69e8973088891a2b5257c9780Mathieu Chartier case LockWord::kHashCode: 1395d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers break; 1396d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kThinLocked: 1397d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers owner_ = Runtime::Current()->GetThreadList()->FindThreadByThreadId(lock_word.ThinLockOwner()); 1398d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers entry_count_ = 1 + lock_word.ThinLockCount(); 1399d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers // Thin locks have no waiters. 1400d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers break; 1401d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers case LockWord::kFatLocked: { 1402d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers Monitor* mon = lock_word.FatLockMonitor(); 1403d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers owner_ = mon->owner_; 1404d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers entry_count_ = 1 + mon->lock_count_; 14052cebb24bfc3247d3e9be138a3350106737455918Mathieu Chartier for (Thread* waiter = mon->wait_set_; waiter != nullptr; waiter = waiter->GetWaitNext()) { 1406d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers waiters_.push_back(waiter); 1407d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers } 1408d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogers break; 1409f327e07b37e349b1ec5eaad6dc294a9b7a081d20Elliott Hughes } 1410f327e07b37e349b1ec5eaad6dc294a9b7a081d20Elliott Hughes } 1411f327e07b37e349b1ec5eaad6dc294a9b7a081d20Elliott Hughes} 1412f327e07b37e349b1ec5eaad6dc294a9b7a081d20Elliott Hughes 14135f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes} // namespace art 1414