lib/sanitizer_common/sanitizer_deadlock_detector1.cpp

46   void DestroyLogicalThread(DDLogicalThread *lt) override;
57   void MutexEnsureID(DDLogicalThread *lt, DDMutex *m);
80   DDLogicalThread *lt = (DDLogicalThread*)InternalAlloc(sizeof(*lt));
81   lt->ctx = ctx;
82   lt->dd.clear();
83   lt->report_pending = false;
84   return lt;
87 void DD::DestroyLogicalThread(DDLogicalThread *lt) {
88   lt->~DDLogicalThread();
89   InternalFree(lt);
97 void DD::MutexEnsureID(DDLogicalThread *lt, DDMutex *m) {
100   dd.ensureCurrentEpoch(&lt->dd);
105   DDLogicalThread *lt = cb->lt;
106   if (lt->dd.empty()) return;  // This will be the first lock held by lt.
107   if (dd.hasAllEdges(&lt->dd, m->id)) return;  // We already have all edges.
109   MutexEnsureID(lt, m);
110   if (dd.isHeld(&lt->dd, m->id))
112   if (dd.onLockBefore(&lt->dd, m->id)) {
114     dd.addEdges(&lt->dd, m->id, cb->Unwind(), cb->UniqueTid());
120   DDLogicalThread *lt = cb->lt;
122   uptr len = dd.findPathToLock(&lt->dd, m->id, path, ARRAY_SIZE(path));
129   lt->report_pending = true;
131   DDReport *rep = &lt->rep;
153   DDLogicalThread *lt = cb->lt;
157   // Printf("T%p MutexLock:   %zx stk %u\n", lt, m->id, stk);
158   if (dd.onFirstLock(&lt->dd, m->id, stk))
160   if (dd.onLockFast(&lt->dd, m->id, stk))
164   MutexEnsureID(lt, m);
166     CHECK(!dd.isHeld(&lt->dd, m->id));
168     dd.addEdges(&lt->dd, m->id, stk ? stk : cb->Unwind(), cb->UniqueTid());
169   dd.onLockAfter(&lt->dd, m->id, stk);
173   // Printf("T%p MutexUnLock: %zx\n", cb->lt, m->id);
174   dd.onUnlock(&cb->lt->dd, m->id);
187   if (!cb->lt->report_pending)
189   cb->lt->report_pending = false;
190   return &cb->lt->rep;