mutex.h revision 2435a43f6c851c23922d8508fb17c6079248201c
18daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes/*
28daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * Copyright (C) 2011 The Android Open Source Project
38daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes *
48daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * Licensed under the Apache License, Version 2.0 (the "License");
58daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * you may not use this file except in compliance with the License.
68daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * You may obtain a copy of the License at
78daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes *
88daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes *      http://www.apache.org/licenses/LICENSE-2.0
98daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes *
108daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * Unless required by applicable law or agreed to in writing, software
118daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * distributed under the License is distributed on an "AS IS" BASIS,
128daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
138daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * See the License for the specific language governing permissions and
148daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes * limitations under the License.
158daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes */
168daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
17fc0e3219edc9a5bf81b166e82fd5db2796eb6a0dBrian Carlstrom#ifndef ART_RUNTIME_BASE_MUTEX_H_
18fc0e3219edc9a5bf81b166e82fd5db2796eb6a0dBrian Carlstrom#define ART_RUNTIME_BASE_MUTEX_H_
198daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
208daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes#include <pthread.h>
21cd74c4b3a6893c876c6e03fd99a1264249653d80Brian Carlstrom#include <stdint.h>
22ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes
23ffb465f23d9549dd591e6aa62e9250523cb00233Elliott Hughes#include <iosfwd>
248daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes#include <string>
258daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
26ef7d42fca18c16fbaf103822ad16f23246e2905dIan Rogers#include "atomic.h"
2707ed66b5ae659c452cbe1ab20c3dbf1d6f546461Elliott Hughes#include "base/logging.h"
28761600567d73b23324ae0251e871c15d6849ffd8Elliott Hughes#include "base/macros.h"
2900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers#include "globals.h"
3081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers
31ab47016374d340011680e9cd970ee7d6225d6704Ian Rogers#if defined(__APPLE__)
3281d425b0b232962441616f8b14f73620bffef5e5Ian Rogers#define ART_USE_FUTEXES 0
33ab47016374d340011680e9cd970ee7d6225d6704Ian Rogers#else
34c01417898a6e4f8a5663d6c0556982488c133cdfChris Dearman#define ART_USE_FUTEXES 1
35ab47016374d340011680e9cd970ee7d6225d6704Ian Rogers#endif
368daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
3766aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers// Currently Darwin doesn't support locks with timeouts.
3866aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#if !defined(__APPLE__)
3966aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#define HAVE_TIMED_RWLOCK 1
4066aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#else
4166aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#define HAVE_TIMED_RWLOCK 0
4266aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#endif
4366aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers
448daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughesnamespace art {
458daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
46719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogersclass LOCKABLE ReaderWriterMutex;
4756edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogersclass ScopedContentionRecorder;
4850b35e2fd1a68cd1240e4a9d9f363e11764957d1Ian Rogersclass Thread;
4950b35e2fd1a68cd1240e4a9d9f363e11764957d1Ian Rogers
50719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// LockLevel is used to impose a lock hierarchy [1] where acquisition of a Mutex at a higher or
51719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// equal level to a lock a thread holds is invalid. The lock hierarchy achieves a cycle free
52719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// partial ordering and thereby cause deadlock situations to fail checks.
53719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers//
54719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// [1] http://www.drdobbs.com/parallel/use-lock-hierarchies-to-avoid-deadlock/204801163
55719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogersenum LockLevel {
56719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kLoggingLock = 0,
573eed93dd5be03e5539827bebf0f414251a12e15eHiroshi Yamauchi  kMemMapsLock,
587de77dd4f2d3cbb0615ee001589eb99ae82c3dccRaghu Gandham  kSwapMutexesLock,
59719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kUnexpectedSignalLock,
60719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kThreadSuspendCountLock,
61719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kAbortLock,
62719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kJdwpSocketLock,
632cd334ae2d4287216523882f0d298cf3901b7ab1Hiroshi Yamauchi  kRegionSpaceRegionLock,
64a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  kReferenceQueueSoftReferencesLock,
65a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  kReferenceQueuePhantomReferencesLock,
66a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  kReferenceQueueFinalizerReferencesLock,
67a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  kReferenceQueueWeakReferencesLock,
68a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  kReferenceQueueClearedReferencesLock,
69a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  kReferenceProcessorLock,
70e5f13e57ff8fa36342beb33830b3ec5942a61ccaMathieu Chartier  kJitCodeCacheLock,
71719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kRosAllocGlobalLock,
72719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kRosAllocBracketLock,
73719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kRosAllocBulkFreeLock,
74719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kAllocSpaceLock,
752cd334ae2d4287216523882f0d298cf3901b7ab1Hiroshi Yamauchi  kBumpPointerSpaceBlockLock,
76719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kDexFileMethodInlinerLock,
77719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kDexFileToMethodInlinerMapLock,
78719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kMarkSweepMarkStackLock,
79719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kTransactionLogLock,
80719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kInternTableLock,
813f5838d7d0b9fc63db0ccc35c2ea05ed29264986Vladimir Marko  kOatFileSecondaryLookupLock,
82719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kDefaultMutexLevel,
83719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kMarkSweepLargeObjectLock,
84719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kPinTableLock,
85719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kJdwpObjectRegistryLock,
869e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  kModifyLdtLock,
879e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  kAllocatedThreadIdsLock,
8874240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe  kMonitorPoolLock,
892435a43f6c851c23922d8508fb17c6079248201cbowen_lai  kMethodVerifiersLock,
90719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kClassLinkerClassesLock,
91719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kBreakpointLock,
92719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kMonitorLock,
93440e4ceb310349ee8eb569495bc04d3d7fbe71cbMathieu Chartier  kMonitorListLock,
9468d8b42ddec39ec0174162d90d4abaa004d1983eIan Rogers  kJniLoadLibraryLock,
95719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kThreadListLock,
96719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kBreakpointInvokeLock,
97306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  kAllocTrackerLock,
98719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kDeoptimizationLock,
99719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kProfilerLock,
100719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kJdwpEventListLock,
101719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kJdwpAttachLock,
102719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kJdwpStartLock,
103719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kRuntimeShutdownLock,
10469dbec6d9d55eeb2867949c2791d01dc9aa916c8Jeff Hao  kTraceLock,
105719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kHeapBitmapLock,
106719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kMutatorLock,
1079ef78b59da51080882e47505896b420977fd79aeMathieu Chartier  kInstrumentEntrypointsLock,
108719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kZygoteCreationLock,
109719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
110719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  kLockLevelCount  // Must come last.
111719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers};
112719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogersstd::ostream& operator<<(std::ostream& os, const LockLevel& rhs);
113719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
1142e250c826b3c405d675017efe79e5db3651c9ee6Brian Carlstromconst bool kDebugLocking = kIsDebugBuild;
11525fd14b87cced64a179dee885573113be5e11944Ian Rogers
1161afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi// Record Log contention information, dumpable via SIGQUIT.
1171afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi#ifdef ART_USE_FUTEXES
11808f2e7b59fab9df108d3d91e6eeb4bbccbb325d1Jeff Hao// To enable lock contention logging, set this to true.
11908f2e7b59fab9df108d3d91e6eeb4bbccbb325d1Jeff Haoconst bool kLogLockContentions = false;
1201afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi#else
1211afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi// Keep this false as lock contention logging is supported only with
1221afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi// futex.
1231afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchiconst bool kLogLockContentions = false;
1241afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi#endif
125d9c4fc94fa618617f94e1de9af5f034549100753Ian Rogersconst size_t kContentionLogSize = 4;
1261afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchiconst size_t kContentionLogDataSize = kLogLockContentions ? 1 : 0;
1271afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchiconst size_t kAllMutexDataSize = kLogLockContentions ? 1 : 0;
1281afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi
12900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Base class for all Mutex implementations
13000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersclass BaseMutex {
13100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers public:
132bab74963db2484ea5f10a82ea26e8a99722bfefeIan Rogers  const char* GetName() const {
13300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    return name_;
13400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
13500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
13600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  virtual bool IsMutex() const { return false; }
13700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  virtual bool IsReaderWriterMutex() const { return false; }
13800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
13956edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  virtual void Dump(std::ostream& os) const = 0;
14056edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers
14156edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  static void DumpAll(std::ostream& os);
14256edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers
14300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers protected:
14400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  friend class ConditionVariable;
14500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
14681d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  BaseMutex(const char* name, LockLevel level);
14756edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  virtual ~BaseMutex();
14881d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void RegisterAsLocked(Thread* self);
14981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void RegisterAsUnlocked(Thread* self);
15081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void CheckSafeToWait(Thread* self);
15100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
15256edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  friend class ScopedContentionRecorder;
15356edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers
1541afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi  void RecordContention(uint64_t blocked_tid, uint64_t owner_tid, uint64_t nano_time_blocked);
15556edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  void DumpContention(std::ostream& os) const;
15656edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers
15781d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  const LockLevel level_;  // Support for lock hierarchy.
158bab74963db2484ea5f10a82ea26e8a99722bfefeIan Rogers  const char* const name_;
1591afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi
16056edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  // A log entry that records contention but makes no guarantee that either tid will be held live.
16156edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  struct ContentionLogEntry {
16256edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers    ContentionLogEntry() : blocked_tid(0), owner_tid(0) {}
16356edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers    uint64_t blocked_tid;
16456edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers    uint64_t owner_tid;
16556edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers    AtomicInteger count;
16656edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  };
1671afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi  struct ContentionLogData {
1681afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    ContentionLogEntry contention_log[kContentionLogSize];
1691afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    // The next entry in the contention log to be updated. Value ranges from 0 to
1701afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    // kContentionLogSize - 1.
1711afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    AtomicInteger cur_content_log_entry;
1721afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    // Number of times the Mutex has been contended.
1731afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    AtomicInteger contention_count;
1741afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    // Sum of time waited by all contenders in ns.
17537f3c968ecd04e77802fe17bb82dabc07de21ca1Ian Rogers    Atomic<uint64_t> wait_time;
1761afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    void AddToWaitTime(uint64_t value);
1771afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    ContentionLogData() : wait_time(0) {}
1781afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi  };
1793e5cf305db800b2989ad57b7cde8fb3cc9fa1b9eIan Rogers  ContentionLogData contention_log_data_[kContentionLogDataSize];
1801afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi
1811afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi public:
1821afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi  bool HasEverContended() const {
1831afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    if (kLogLockContentions) {
1843e5cf305db800b2989ad57b7cde8fb3cc9fa1b9eIan Rogers      return contention_log_data_->contention_count.LoadSequentiallyConsistent() > 0;
1851afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    }
1861afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi    return false;
1871afde13b36cc1d67528104c2b1395495f669cd3fHiroshi Yamauchi  }
18800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers};
18900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
19000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// A Mutex is used to achieve mutual exclusion between threads. A Mutex can be used to gain
19100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// exclusive access to what it guards. A Mutex can be in one of two states:
19200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// - Free - not owned by any thread,
19300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// - Exclusive - owned by a single thread.
19400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers//
19500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// The effect of locking and unlocking operations on the state is:
19600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// State     | ExclusiveLock | ExclusiveUnlock
19700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// -------------------------------------------
19800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Free      | Exclusive     | error
19900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Exclusive | Block*        | Free
20000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// * Mutex is not reentrant and so an attempt to ExclusiveLock on the same thread will result in
20100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers//   an error. Being non-reentrant simplifies Waiting on ConditionVariables.
20201ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogersstd::ostream& operator<<(std::ostream& os, const Mutex& mu);
20300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersclass LOCKABLE Mutex : public BaseMutex {
20400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers public:
20581d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  explicit Mutex(const char* name, LockLevel level = kDefaultMutexLevel, bool recursive = false);
20600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ~Mutex();
20700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
20800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  virtual bool IsMutex() const { return true; }
20900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
21000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Block until mutex is free then acquire exclusive access.
21181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void ExclusiveLock(Thread* self) EXCLUSIVE_LOCK_FUNCTION();
21281d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void Lock(Thread* self) EXCLUSIVE_LOCK_FUNCTION() {  ExclusiveLock(self); }
21300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
21400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Returns true if acquires exclusive access, false otherwise.
21581d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  bool ExclusiveTryLock(Thread* self) EXCLUSIVE_TRYLOCK_FUNCTION(true);
21681d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  bool TryLock(Thread* self) EXCLUSIVE_TRYLOCK_FUNCTION(true) { return ExclusiveTryLock(self); }
21700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
21800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Release exclusive access.
21981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void ExclusiveUnlock(Thread* self) UNLOCK_FUNCTION();
22081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void Unlock(Thread* self) UNLOCK_FUNCTION() {  ExclusiveUnlock(self); }
22100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
22200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Is the current thread the exclusive holder of the Mutex.
22381d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  bool IsExclusiveHeld(const Thread* self) const;
2248daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
22500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Assert that the Mutex is exclusively held by the current thread.
22681d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertExclusiveHeld(const Thread* self) {
227db978719dbcb73fc6acfd193561445c4462786b8Nicolas Geoffray    if (kDebugLocking && (gAborting == 0)) {
22801ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogers      CHECK(IsExclusiveHeld(self)) << *this;
22900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    }
23000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
23181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertHeld(const Thread* self) { AssertExclusiveHeld(self); }
23200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
23300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Assert that the Mutex is not held by the current thread.
23481d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertNotHeldExclusive(const Thread* self) {
235db978719dbcb73fc6acfd193561445c4462786b8Nicolas Geoffray    if (kDebugLocking && (gAborting == 0)) {
23601ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogers      CHECK(!IsExclusiveHeld(self)) << *this;
23700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    }
23800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
23981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertNotHeld(const Thread* self) { AssertNotHeldExclusive(self); }
24000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
241c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // Id associated with exclusive owner. No memory ordering semantics if called from a thread other
242c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // than the owner.
24300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  uint64_t GetExclusiveOwnerTid() const;
24400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
24500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Returns how many times this Mutex has been locked, it is better to use AssertHeld/NotHeld.
24600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  unsigned int GetDepth() const {
24700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    return recursion_count_;
24800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
24900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
25056edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  virtual void Dump(std::ostream& os) const;
25101ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogers
25200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers private:
253c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers#if ART_USE_FUTEXES
254c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // 0 is unheld, 1 is held.
255c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  AtomicInteger state_;
256c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // Exclusive owner.
257c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  volatile uint64_t exclusive_owner_;
258c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // Number of waiting contenders.
259b122a4bbed34ab22b4c1541ee25e5cf22f12a926Ian Rogers  AtomicInteger num_contenders_;
260c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers#else
26100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  pthread_mutex_t mutex_;
262c5f17732d8144491c642776b6b48c85dfadf4b52Ian Rogers  volatile uint64_t exclusive_owner_;  // Guarded by mutex_.
263c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers#endif
26400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  const bool recursive_;  // Can the lock be recursively held?
26500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  unsigned int recursion_count_;
266f1498437b0d6beb9f4f91980b98cbeb0b5c773ceElliott Hughes  friend class ConditionVariable;
2678daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes  DISALLOW_COPY_AND_ASSIGN(Mutex);
2688daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes};
2698daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
27000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// A ReaderWriterMutex is used to achieve mutual exclusion between threads, similar to a Mutex.
27100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Unlike a Mutex a ReaderWriterMutex can be used to gain exclusive (writer) or shared (reader)
27200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// access to what it guards. A flaw in relation to a Mutex is that it cannot be used with a
27300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// condition variable. A ReaderWriterMutex can be in one of three states:
27400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// - Free - not owned by any thread,
27500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// - Exclusive - owned by a single thread,
27600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// - Shared(n) - shared amongst n threads.
27700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers//
27800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// The effect of locking and unlocking operations on the state is:
27900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers//
28000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// State     | ExclusiveLock | ExclusiveUnlock | SharedLock       | SharedUnlock
28100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// ----------------------------------------------------------------------------
28200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Free      | Exclusive     | error           | SharedLock(1)    | error
28300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Exclusive | Block         | Free            | Block            | error
28400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Shared(n) | Block         | error           | SharedLock(n+1)* | Shared(n-1) or Free
28500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// * for large values of n the SharedLock may block.
28601ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogersstd::ostream& operator<<(std::ostream& os, const ReaderWriterMutex& mu);
28700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersclass LOCKABLE ReaderWriterMutex : public BaseMutex {
2888daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes public:
28981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  explicit ReaderWriterMutex(const char* name, LockLevel level = kDefaultMutexLevel);
29000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ~ReaderWriterMutex();
29100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
29200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  virtual bool IsReaderWriterMutex() const { return true; }
29300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
29400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Block until ReaderWriterMutex is free then acquire exclusive access.
29581d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void ExclusiveLock(Thread* self) EXCLUSIVE_LOCK_FUNCTION();
29681d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void WriterLock(Thread* self) EXCLUSIVE_LOCK_FUNCTION() {  ExclusiveLock(self); }
29700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
29800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Release exclusive access.
29981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void ExclusiveUnlock(Thread* self) UNLOCK_FUNCTION();
30081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void WriterUnlock(Thread* self) UNLOCK_FUNCTION() {  ExclusiveUnlock(self); }
30100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
30200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Block until ReaderWriterMutex is free and acquire exclusive access. Returns true on success
30300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // or false if timeout is reached.
30466aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#if HAVE_TIMED_RWLOCK
305c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  bool ExclusiveLockWithTimeout(Thread* self, int64_t ms, int32_t ns)
30681d425b0b232962441616f8b14f73620bffef5e5Ian Rogers      EXCLUSIVE_TRYLOCK_FUNCTION(true);
30766aee5cd571cf4739d2735769304202ea5051fb8Ian Rogers#endif
30800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
30900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Block until ReaderWriterMutex is shared or free then acquire a share on the access.
3101ffa32f0be7becec4907b26ead353e4b17e1219cIan Rogers  void SharedLock(Thread* self) SHARED_LOCK_FUNCTION() ALWAYS_INLINE;
31181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void ReaderLock(Thread* self) SHARED_LOCK_FUNCTION() { SharedLock(self); }
31200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
31300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Try to acquire share of ReaderWriterMutex.
31481d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  bool SharedTryLock(Thread* self) EXCLUSIVE_TRYLOCK_FUNCTION(true);
31500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
31600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Release a share of the access.
3171ffa32f0be7becec4907b26ead353e4b17e1219cIan Rogers  void SharedUnlock(Thread* self) UNLOCK_FUNCTION() ALWAYS_INLINE;
31881d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void ReaderUnlock(Thread* self) UNLOCK_FUNCTION() { SharedUnlock(self); }
31900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
32000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Is the current thread the exclusive holder of the ReaderWriterMutex.
32181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  bool IsExclusiveHeld(const Thread* self) const;
32200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
32300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Assert the current thread has exclusive access to the ReaderWriterMutex.
32481d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertExclusiveHeld(const Thread* self) {
325db978719dbcb73fc6acfd193561445c4462786b8Nicolas Geoffray    if (kDebugLocking && (gAborting == 0)) {
32601ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogers      CHECK(IsExclusiveHeld(self)) << *this;
32700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    }
3288daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes  }
32981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertWriterHeld(const Thread* self) { AssertExclusiveHeld(self); }
3308daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
33100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Assert the current thread doesn't have exclusive access to the ReaderWriterMutex.
33281d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertNotExclusiveHeld(const Thread* self) {
333db978719dbcb73fc6acfd193561445c4462786b8Nicolas Geoffray    if (kDebugLocking && (gAborting == 0)) {
334e3359f7ad7671c5816f17145ca3a01516512e8d6Ian Rogers      CHECK(!IsExclusiveHeld(self)) << *this;
33500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    }
33600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
33781d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertNotWriterHeld(const Thread* self) { AssertNotExclusiveHeld(self); }
33800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
33900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Is the current thread a shared holder of the ReaderWriterMutex.
34081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  bool IsSharedHeld(const Thread* self) const;
34100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
34200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Assert the current thread has shared access to the ReaderWriterMutex.
34381d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertSharedHeld(const Thread* self) {
344db978719dbcb73fc6acfd193561445c4462786b8Nicolas Geoffray    if (kDebugLocking && (gAborting == 0)) {
34523055dc5d7a90c4a12e259fd0ed7cd4d04d89182Ian Rogers      // TODO: we can only assert this well when self != NULL.
34623055dc5d7a90c4a12e259fd0ed7cd4d04d89182Ian Rogers      CHECK(IsSharedHeld(self) || self == NULL) << *this;
34700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    }
3488daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes  }
34981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertReaderHeld(const Thread* self) { AssertSharedHeld(self); }
3508daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
35100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // Assert the current thread doesn't hold this ReaderWriterMutex either in shared or exclusive
35200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  // mode.
35381d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  void AssertNotHeld(const Thread* self) {
354db978719dbcb73fc6acfd193561445c4462786b8Nicolas Geoffray    if (kDebugLocking && (gAborting == 0)) {
35501ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogers      CHECK(!IsSharedHeld(self)) << *this;
35600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers    }
35700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
35800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
359c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // Id associated with exclusive owner. No memory ordering semantics if called from a thread other
360c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // than the owner.
36100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  uint64_t GetExclusiveOwnerTid() const;
36281d425b0b232962441616f8b14f73620bffef5e5Ian Rogers
36356edc432fa914f7ccfa87ce443e64f5ef475666dIan Rogers  virtual void Dump(std::ostream& os) const;
36401ae5808367e641a983e3f8bb82b3e0d364cd03eIan Rogers
3658daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes private:
36651d212ef31945743abe8a469707aaa25bab95357Ian Rogers#if ART_USE_FUTEXES
367cf7f19135f0e273f7b0136315633c2abfc715343Ian Rogers  // Out-of-inline path for handling contention for a SharedLock.
368cf7f19135f0e273f7b0136315633c2abfc715343Ian Rogers  void HandleSharedLockContention(Thread* self, int32_t cur_state);
369cf7f19135f0e273f7b0136315633c2abfc715343Ian Rogers
37081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  // -1 implies held exclusive, +ve shared held by state_ many owners.
371c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  AtomicInteger state_;
372c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // Exclusive owner. Modification guarded by this mutex.
37381d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  volatile uint64_t exclusive_owner_;
374c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // Number of contenders waiting for a reader share.
375c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  AtomicInteger num_pending_readers_;
376c7190697f8665e706f6ebb4ae36fa63c46a32cd5Ian Rogers  // Number of contenders waiting to be the writer.
377b122a4bbed34ab22b4c1541ee25e5cf22f12a926Ian Rogers  AtomicInteger num_pending_writers_;
37881d425b0b232962441616f8b14f73620bffef5e5Ian Rogers#else
37900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  pthread_rwlock_t rwlock_;
380c5f17732d8144491c642776b6b48c85dfadf4b52Ian Rogers  volatile uint64_t exclusive_owner_;  // Guarded by rwlock_.
38181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers#endif
38200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  DISALLOW_COPY_AND_ASSIGN(ReaderWriterMutex);
3838daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes};
3848daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
38500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// ConditionVariables allow threads to queue and sleep. Threads may then be resumed individually
38600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// (Signal) or all at once (Broadcast).
3875f79133a435ebcb20000370d56046fe01201dd80Elliott Hughesclass ConditionVariable {
3885f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes public:
38923055dc5d7a90c4a12e259fd0ed7cd4d04d89182Ian Rogers  explicit ConditionVariable(const char* name, Mutex& mutex);
3905f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes  ~ConditionVariable();
3915f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes
392c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  void Broadcast(Thread* self);
393c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  void Signal(Thread* self);
394c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // TODO: No thread safety analysis on Wait and TimedWait as they call mutex operations via their
395c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  //       pointer copy, thereby defeating annotalysis.
396c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  void Wait(Thread* self) NO_THREAD_SAFETY_ANALYSIS;
3977b078e8c04f3e1451dbdd18543c8b9692b5b067eIan Rogers  bool TimedWait(Thread* self, int64_t ms, int32_t ns) NO_THREAD_SAFETY_ANALYSIS;
3981d54e73444e017d3a65234e0f193846f3e27472bIan Rogers  // Variant of Wait that should be used with caution. Doesn't validate that no mutexes are held
3991d54e73444e017d3a65234e0f193846f3e27472bIan Rogers  // when waiting.
4001d54e73444e017d3a65234e0f193846f3e27472bIan Rogers  // TODO: remove this.
4011d54e73444e017d3a65234e0f193846f3e27472bIan Rogers  void WaitHoldingLocks(Thread* self) NO_THREAD_SAFETY_ANALYSIS;
4025f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes
4035f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes private:
40423055dc5d7a90c4a12e259fd0ed7cd4d04d89182Ian Rogers  const char* const name_;
405c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // The Mutex being used by waiters. It is an error to mix condition variables between different
406c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // Mutexes.
407c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  Mutex& guard_;
408c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers#if ART_USE_FUTEXES
409c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // A counter that is modified by signals and broadcasts. This ensures that when a waiter gives up
410d45f201e9bd43490e30a35710865789b8d70e249Ian Rogers  // their Mutex and another thread takes it and signals, the waiting thread observes that sequence_
411d45f201e9bd43490e30a35710865789b8d70e249Ian Rogers  // changed and doesn't enter the wait. Modified while holding guard_, but is read by futex wait
412d45f201e9bd43490e30a35710865789b8d70e249Ian Rogers  // without guard_ held.
413b122a4bbed34ab22b4c1541ee25e5cf22f12a926Ian Rogers  AtomicInteger sequence_;
414c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  // Number of threads that have come into to wait, not the length of the waiters on the futex as
4155bd97c483c1de1eb97afe76123b1b9ab53095edfIan Rogers  // waiters may have been requeued onto guard_. Guarded by guard_.
416c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  volatile int32_t num_waiters_;
417c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers#else
418c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers  pthread_cond_t cond_;
419c604d731730b43231f63040c8db1d58304da0cf3Ian Rogers#endif
4205f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes  DISALLOW_COPY_AND_ASSIGN(ConditionVariable);
4215f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes};
4225f79133a435ebcb20000370d56046fe01201dd80Elliott Hughes
42300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Scoped locker/unlocker for a regular Mutex that acquires mu upon construction and releases it
42400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// upon destruction.
42500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersclass SCOPED_LOCKABLE MutexLock {
42600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers public:
42781d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  explicit MutexLock(Thread* self, Mutex& mu) EXCLUSIVE_LOCK_FUNCTION(mu) : self_(self), mu_(mu) {
42881d425b0b232962441616f8b14f73620bffef5e5Ian Rogers    mu_.ExclusiveLock(self_);
42981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  }
43081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers
43100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ~MutexLock() UNLOCK_FUNCTION() {
43281d425b0b232962441616f8b14f73620bffef5e5Ian Rogers    mu_.ExclusiveUnlock(self_);
43300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
43400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
43500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers private:
43681d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  Thread* const self_;
43700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  Mutex& mu_;
43800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  DISALLOW_COPY_AND_ASSIGN(MutexLock);
43900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers};
44000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Catch bug where variable name is omitted. "MutexLock (lock);" instead of "MutexLock mu(lock)".
441575e78c41ece0dec969d31f46be563d4eb7ae43bAndreas Gampe#define MutexLock(x) static_assert(0, "MutexLock declaration missing variable name")
44200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
44300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Scoped locker/unlocker for a ReaderWriterMutex that acquires read access to mu upon
44400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// construction and releases it upon destruction.
44500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersclass SCOPED_LOCKABLE ReaderMutexLock {
44600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers public:
44781d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  explicit ReaderMutexLock(Thread* self, ReaderWriterMutex& mu) EXCLUSIVE_LOCK_FUNCTION(mu) :
44881d425b0b232962441616f8b14f73620bffef5e5Ian Rogers      self_(self), mu_(mu) {
44981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers    mu_.SharedLock(self_);
45081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  }
45181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers
45200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ~ReaderMutexLock() UNLOCK_FUNCTION() {
45381d425b0b232962441616f8b14f73620bffef5e5Ian Rogers    mu_.SharedUnlock(self_);
45400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
45500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
45600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers private:
45781d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  Thread* const self_;
45800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ReaderWriterMutex& mu_;
45900f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  DISALLOW_COPY_AND_ASSIGN(ReaderMutexLock);
46000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers};
46100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Catch bug where variable name is omitted. "ReaderMutexLock (lock);" instead of
46200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// "ReaderMutexLock mu(lock)".
463575e78c41ece0dec969d31f46be563d4eb7ae43bAndreas Gampe#define ReaderMutexLock(x) static_assert(0, "ReaderMutexLock declaration missing variable name")
46400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
46500f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Scoped locker/unlocker for a ReaderWriterMutex that acquires write access to mu upon
46600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// construction and releases it upon destruction.
46700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogersclass SCOPED_LOCKABLE WriterMutexLock {
46800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers public:
46981d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  explicit WriterMutexLock(Thread* self, ReaderWriterMutex& mu) EXCLUSIVE_LOCK_FUNCTION(mu) :
47081d425b0b232962441616f8b14f73620bffef5e5Ian Rogers      self_(self), mu_(mu) {
47181d425b0b232962441616f8b14f73620bffef5e5Ian Rogers    mu_.ExclusiveLock(self_);
47281d425b0b232962441616f8b14f73620bffef5e5Ian Rogers  }
47381d425b0b232962441616f8b14f73620bffef5e5Ian Rogers
47400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ~WriterMutexLock() UNLOCK_FUNCTION() {
47581d425b0b232962441616f8b14f73620bffef5e5Ian Rogers    mu_.ExclusiveUnlock(self_);
47600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  }
47700f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
47800f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers private:
47950b35e2fd1a68cd1240e4a9d9f363e11764957d1Ian Rogers  Thread* const self_;
48000f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  ReaderWriterMutex& mu_;
48100f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers  DISALLOW_COPY_AND_ASSIGN(WriterMutexLock);
48200f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers};
48300f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// Catch bug where variable name is omitted. "WriterMutexLock (lock);" instead of
48400f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers// "WriterMutexLock mu(lock)".
485575e78c41ece0dec969d31f46be563d4eb7ae43bAndreas Gampe#define WriterMutexLock(x) static_assert(0, "WriterMutexLock declaration missing variable name")
48600f7d0eaa6bd93d33bf0c1429bf4ba0b3f28abacIan Rogers
487719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers// Global mutexes corresponding to the levels above.
488719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogersclass Locks {
489719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers public:
490719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  static void Init();
49191e56692c6bd9fa1d41951ee7dc311f19461f4beMathieu Chartier  static void InitConditions() NO_THREAD_SAFETY_ANALYSIS;  // Condition variables.
4929ef78b59da51080882e47505896b420977fd79aeMathieu Chartier  // Guards allocation entrypoint instrumenting.
4934ad5cd3e7d519484559ef778d96fb3f0be8919faIan Rogers  static Mutex* instrument_entrypoints_lock_;
4949ef78b59da51080882e47505896b420977fd79aeMathieu Chartier
495719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // The mutator_lock_ is used to allow mutators to execute in a shared (reader) mode or to block
496719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // mutators by having an exclusive (writer) owner. In normal execution each mutator thread holds
497719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // a share on the mutator_lock_. The garbage collector may also execute with shared access but
498719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // at times requires exclusive access to the heap (not to be confused with the heap meta-data
499719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // guarded by the heap_lock_ below). When the garbage collector requires exclusive access it asks
500719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // the mutators to suspend themselves which also involves usage of the thread_suspend_count_lock_
501719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // to cover weaknesses in using ReaderWriterMutexes with ConditionVariables. We use a condition
502719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // variable to wait upon in the suspension logic as releasing and then re-acquiring a share on
503719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // the mutator lock doesn't necessarily allow the exclusive user (e.g the garbage collector)
504719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // chance to acquire the lock.
505719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //
506719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Thread suspension:
507719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Shared users                                  | Exclusive user
508719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // (holding mutator lock and in kRunnable state) |   .. running ..
509719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. running ..                               | Request thread suspension by:
510719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. running ..                               |   - acquiring thread_suspend_count_lock_
511719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. running ..                               |   - incrementing Thread::suspend_count_ on
512719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. running ..                               |     all mutator threads
513719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. running ..                               |   - releasing thread_suspend_count_lock_
514719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. running ..                               | Block trying to acquire exclusive mutator lock
515719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Poll Thread::suspend_count_ and enter full    |   .. blocked ..
516719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // suspend code.                                 |   .. blocked ..
517719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Change state to kSuspended                    |   .. blocked ..
518719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // x: Release share on mutator_lock_             | Carry out exclusive access
519719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Acquire thread_suspend_count_lock_            |   .. exclusive ..
520719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // while Thread::suspend_count_ > 0              |   .. exclusive ..
521719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   - wait on Thread::resume_cond_              |   .. exclusive ..
522719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //     (releases thread_suspend_count_lock_)     |   .. exclusive ..
523719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. waiting ..                               | Release mutator_lock_
524719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. waiting ..                               | Request thread resumption by:
525719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. waiting ..                               |   - acquiring thread_suspend_count_lock_
526719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. waiting ..                               |   - decrementing Thread::suspend_count_ on
527719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. waiting ..                               |     all mutator threads
528719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   .. waiting ..                               |   - notifying on Thread::resume_cond_
529719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    - re-acquire thread_suspend_count_lock_    |   - releasing thread_suspend_count_lock_
530719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Release thread_suspend_count_lock_            |  .. running ..
531719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Acquire share on mutator_lock_                |  .. running ..
532719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //  - This could block but the thread still      |  .. running ..
533719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    has a state of kSuspended and so this      |  .. running ..
534719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    isn't an issue.                            |  .. running ..
535719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Acquire thread_suspend_count_lock_            |  .. running ..
536719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //  - we poll here as we're transitioning into   |  .. running ..
537719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    kRunnable and an individual thread suspend |  .. running ..
538719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    request (e.g for debugging) won't try      |  .. running ..
539719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    to acquire the mutator lock (which would   |  .. running ..
540719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    block as we hold the mutator lock). This   |  .. running ..
541719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    poll ensures that if the suspender thought |  .. running ..
542719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    we were suspended by incrementing our      |  .. running ..
543719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    Thread::suspend_count_ and then reading    |  .. running ..
544719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    our state we go back to waiting on         |  .. running ..
545719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //    Thread::resume_cond_.                      |  .. running ..
546719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // can_go_runnable = Thread::suspend_count_ == 0 |  .. running ..
547719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Release thread_suspend_count_lock_            |  .. running ..
548719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // if can_go_runnable                            |  .. running ..
549719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   Change state to kRunnable                   |  .. running ..
550719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // else                                          |  .. running ..
551719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //   Goto x                                      |  .. running ..
552719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  //  .. running ..                                |  .. running ..
5539ef78b59da51080882e47505896b420977fd79aeMathieu Chartier  static ReaderWriterMutex* mutator_lock_ ACQUIRED_AFTER(instrument_entrypoints_lock_);
554719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
555719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Allow reader-writer mutual exclusion on the mark and live bitmaps of the heap.
556719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  static ReaderWriterMutex* heap_bitmap_lock_ ACQUIRED_AFTER(mutator_lock_);
557719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
558719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Guards shutdown of the runtime.
559719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  static Mutex* runtime_shutdown_lock_ ACQUIRED_AFTER(heap_bitmap_lock_);
560719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
5619e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  // Guards background profiler global state.
5629e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  static Mutex* profiler_lock_ ACQUIRED_AFTER(runtime_shutdown_lock_);
5639e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu
5649e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  // Guards trace (ie traceview) requests.
5659e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  static Mutex* trace_lock_ ACQUIRED_AFTER(profiler_lock_);
5669e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu
567306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  // Guards debugger recent allocation records.
568306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  static Mutex* alloc_tracker_lock_ ACQUIRED_AFTER(trace_lock_);
569306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom
570306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  // Guards updates to instrumentation to ensure mutual exclusion of
571306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  // events like deoptimization requests.
572306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  // TODO: improve name, perhaps instrumentation_update_lock_.
573306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  static Mutex* deoptimization_lock_ ACQUIRED_AFTER(alloc_tracker_lock_);
574306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom
575719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // The thread_list_lock_ guards ThreadList::list_. It is also commonly held to stop threads
576719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // attaching and detaching.
577306db81aba41eb244a4e8299cf58ac18ae9999c7Brian Carlstrom  static Mutex* thread_list_lock_ ACQUIRED_AFTER(deoptimization_lock_);
578719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
57991e56692c6bd9fa1d41951ee7dc311f19461f4beMathieu Chartier  // Signaled when threads terminate. Used to determine when all non-daemons have terminated.
58091e56692c6bd9fa1d41951ee7dc311f19461f4beMathieu Chartier  static ConditionVariable* thread_exit_cond_ GUARDED_BY(Locks::thread_list_lock_);
58191e56692c6bd9fa1d41951ee7dc311f19461f4beMathieu Chartier
58268d8b42ddec39ec0174162d90d4abaa004d1983eIan Rogers  // Guards maintaining loading library data structures.
58368d8b42ddec39ec0174162d90d4abaa004d1983eIan Rogers  static Mutex* jni_libraries_lock_ ACQUIRED_AFTER(thread_list_lock_);
58468d8b42ddec39ec0174162d90d4abaa004d1983eIan Rogers
585719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Guards breakpoints.
586ed2be1725fb79075892b1a9103487c9d9a95b350Sebastien Hertz  static ReaderWriterMutex* breakpoint_lock_ ACQUIRED_AFTER(jni_libraries_lock_);
587719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
588719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Guards lists of classes within the class linker.
5899e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  static ReaderWriterMutex* classlinker_classes_lock_ ACQUIRED_AFTER(breakpoint_lock_);
590719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
5912435a43f6c851c23922d8508fb17c6079248201cbowen_lai  static Mutex* method_verifiers_lock_ ACQUIRED_AFTER(classlinker_classes_lock_);
5922435a43f6c851c23922d8508fb17c6079248201cbowen_lai
593719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // When declaring any Mutex add DEFAULT_MUTEX_ACQUIRED_AFTER to use annotalysis to check the code
594719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // doesn't try to hold a higher level Mutex.
5952435a43f6c851c23922d8508fb17c6079248201cbowen_lai  #define DEFAULT_MUTEX_ACQUIRED_AFTER ACQUIRED_AFTER(Locks::method_verifiers_lock_)
596719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
59774240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe  static Mutex* allocated_monitor_ids_lock_ ACQUIRED_AFTER(classlinker_classes_lock_);
59874240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe
5999e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  // Guard the allocation/deallocation of thread ids.
60074240819ae09e29b2753ef38f4eb4be1c2762e2eAndreas Gampe  static Mutex* allocated_thread_ids_lock_ ACQUIRED_AFTER(allocated_monitor_ids_lock_);
6019e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu
6029e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  // Guards modification of the LDT on x86.
6039e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  static Mutex* modify_ldt_lock_ ACQUIRED_AFTER(allocated_thread_ids_lock_);
6049e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu
605719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Guards intern table.
6069e36931cc79ca665908db9575126881d1cfdea5aChao-ying Fu  static Mutex* intern_table_lock_ ACQUIRED_AFTER(modify_ldt_lock_);
607719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
608a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  // Guards reference processor.
609a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* reference_processor_lock_ ACQUIRED_AFTER(intern_table_lock_);
610a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier
611a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  // Guards cleared references queue.
612a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* reference_queue_cleared_references_lock_ ACQUIRED_AFTER(reference_processor_lock_);
613a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier
614a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  // Guards weak references queue.
615a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* reference_queue_weak_references_lock_ ACQUIRED_AFTER(reference_queue_cleared_references_lock_);
616a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier
617a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  // Guards finalizer references queue.
618a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* reference_queue_finalizer_references_lock_ ACQUIRED_AFTER(reference_queue_weak_references_lock_);
619a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier
620a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  // Guards phantom references queue.
621a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* reference_queue_phantom_references_lock_ ACQUIRED_AFTER(reference_queue_finalizer_references_lock_);
622a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier
623a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  // Guards soft references queue.
624a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* reference_queue_soft_references_lock_ ACQUIRED_AFTER(reference_queue_phantom_references_lock_);
625a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier
626719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Have an exclusive aborting thread.
627a5a53efea976af505f4f849b5925d5e14c4f8e5cMathieu Chartier  static Mutex* abort_lock_ ACQUIRED_AFTER(reference_queue_soft_references_lock_);
628719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
629719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Allow mutual exclusion when manipulating Thread::suspend_count_.
630719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // TODO: Does the trade-off of a per-thread lock make sense?
631719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  static Mutex* thread_suspend_count_lock_ ACQUIRED_AFTER(abort_lock_);
632719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
633719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // One unexpected signal at a time lock.
634719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  static Mutex* unexpected_signal_lock_ ACQUIRED_AFTER(thread_suspend_count_lock_);
635719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
6363eed93dd5be03e5539827bebf0f414251a12e15eHiroshi Yamauchi  // Guards the maps in mem_map.
6373eed93dd5be03e5539827bebf0f414251a12e15eHiroshi Yamauchi  static Mutex* mem_maps_lock_ ACQUIRED_AFTER(unexpected_signal_lock_);
6383eed93dd5be03e5539827bebf0f414251a12e15eHiroshi Yamauchi
639719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  // Have an exclusive logging thread.
640719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers  static Mutex* logging_lock_ ACQUIRED_AFTER(unexpected_signal_lock_);
641719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers};
642719d1a33f6569864f529e5a3fff59e7bca97aad0Ian Rogers
6438daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes}  // namespace art
6448daa0929f08a3080ea64dbd4e997e72f411e6fc9Elliott Hughes
645fc0e3219edc9a5bf81b166e82fd5db2796eb6a0dBrian Carlstrom#endif  // ART_RUNTIME_BASE_MUTEX_H_
646