latentprion/libspinscale
1
0
Fork 0
mirror of https://github.com/latentPrion/libspinscale.git synced 2026-04-17 22:44:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbg:Gridlock detection: exclude locks where hasBeenReleased=true

Browse Source
This commit is contained in:
Hayodea Hekol
2026-03-05 23:29:48 -04:00
parent e4332323f9
commit 596ad367e2
1 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
include/spinscale/serializedAsynchronousContinuation.h
View File

@@ -47,7 +47,8 @@ public:
// Return list of all qutexes in predecessors' LockSets; excludes self.
[[nodiscard]]
std::unique_ptr<std::forward_list<std::reference_wrapper<Qutex>>>
getAcquiredQutexHistory() const;
getAcquiredQutexHistory(
bool includeLocksWhichHaveBeenReleased = false) const;
/**
* @brief Release a specific qutex early
@@ -276,8 +277,8 @@ public:
template <class OriginalCbFnT>
std::unique_ptr<std::forward_list<std::reference_wrapper<Qutex>>>
SerializedAsynchronousContinuation<OriginalCbFnT>::getAcquiredQutexHistory()
const
SerializedAsynchronousContinuation<OriginalCbFnT>::getAcquiredQutexHistory(
bool includeLocksWhichHaveBeenReleased) const
{
auto heldLocks = std::make_unique<
std::forward_list<std::reference_wrapper<Qutex>>>();
@@ -297,12 +298,18 @@ const
auto heldLockSet = currContin->getLockSet();
if (!heldLockSet.has_value()) { continue; }
// Add this continuation's locks to the held locks list
for (size_t i = 0; i < heldLockSet->get().locks.size(); ++i)
{
heldLocks->push_front(heldLockSet->get().locks[i].qutex);
// Add this continuation's locks to the held locks list
for (size_t i = 0; i < heldLockSet->get().locks.size(); ++i)
{
if (!includeLocksWhichHaveBeenReleased
&& heldLockSet->get().locks[i].hasBeenReleased)
{
continue;
}
heldLocks->push_front(heldLockSet->get().locks[i].qutex);
}
}
}
return heldLocks;
}