OrgApache/incubator-nuttx
OrgApache
/
incubator-nuttx
mirror of https://github.com/apache/incubator-nuttx.git
1
0
Fork 0
Code Issues Releases Wiki Activity

sched/misc: optimize collect_deadlock implementation 

Signed-off-by: Petro Karashchenko <petro.karashchenko@gmail.com>
This commit is contained in:
Petro Karashchenko 2023-09-06 17:41:33 +03:00 committed by Xiang Xiao
parent a2df576ecf
commit 47627c5fbd
1 changed files with 29 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
sched/misc/deadlock.c
View File

@ -41,46 +41,47 @@ struct deadlock_info_s
****************************************************************************/
/****************************************************************************
* Name:find_circular_lock
* Name: collect_deadlock
****************************************************************************/
static void collect_deadlock(FAR struct tcb_s *tcb, FAR void *arg)
{
FAR struct deadlock_info_s *info = arg;
size_t index;
for (index = 0; index < info->found; index++)
{
if (info->pid[index] == tcb->pid)
{
return;
}
}
for (index = info->found; index < info->count; index++)
if (tcb->task_state == TSTATE_WAIT_SEM)
{
FAR sem_t *sem = tcb->waitobj;
pid_t next;
size_t i;
if (tcb->task_state != TSTATE_WAIT_SEM || sem == NULL ||
!(sem->flags & SEM_TYPE_MUTEX))
if (sem != NULL && (sem->flags & SEM_TYPE_MUTEX) != 0)
{
return;
}
FAR struct deadlock_info_s *info = arg;
size_t index;
next = ((FAR mutex_t *)sem)->holder;
for (i = info->found; i < index; i++)
{
if (info->pid[i] == next)
for (index = 0; index < info->found; index++)
{
info->found = index;
return;
if (info->pid[index] == tcb->pid)
{
return;
}
}
for (index = info->found; index < info->count; index++)
{
pid_t next;
size_t i;
next = ((FAR mutex_t *)sem)->holder;
for (i = info->found; i < index; i++)
{
if (info->pid[i] == next)
{
info->found = index;
return;
}
}
info->pid[index] = tcb->pid;
tcb = nxsched_get_tcb(next);
}
}
info->pid[index] = tcb->pid;
tcb = nxsched_get_tcb(next);
}
}