sched: remove unnecessary type cast
fix code style issues Signed-off-by: Petro Karashchenko <petro.karashchenko@gmail.com>
This commit is contained in:
parent
b6d9d4e92f
commit
5b4e12774c
@ -86,12 +86,12 @@ bool nxsched_add_prioritized(FAR struct tcb_s *tcb, DSEG dq_queue_t *list)
|
|||||||
* is the g_pendingtasks list!
|
* is the g_pendingtasks list!
|
||||||
*/
|
*/
|
||||||
|
|
||||||
if (!next)
|
if (next == NULL)
|
||||||
{
|
{
|
||||||
/* The tcb goes at the end of the list. */
|
/* The tcb goes at the end of the list. */
|
||||||
|
|
||||||
prev = (FAR struct tcb_s *)list->tail;
|
prev = (FAR struct tcb_s *)list->tail;
|
||||||
if (!prev)
|
if (prev == NULL)
|
||||||
{
|
{
|
||||||
/* Special case: The list is empty */
|
/* Special case: The list is empty */
|
||||||
|
|
||||||
@ -115,8 +115,8 @@ bool nxsched_add_prioritized(FAR struct tcb_s *tcb, DSEG dq_queue_t *list)
|
|||||||
{
|
{
|
||||||
/* The tcb goes just before next */
|
/* The tcb goes just before next */
|
||||||
|
|
||||||
prev = (FAR struct tcb_s *)next->blink;
|
prev = next->blink;
|
||||||
if (!prev)
|
if (prev == NULL)
|
||||||
{
|
{
|
||||||
/* Special case: Insert at the head of the list */
|
/* Special case: Insert at the head of the list */
|
||||||
|
|
||||||
|
@ -165,7 +165,7 @@ bool nxsched_add_readytorun(FAR struct tcb_s *btcb)
|
|||||||
{
|
{
|
||||||
/* Yes.. that is the CPU we must use */
|
/* Yes.. that is the CPU we must use */
|
||||||
|
|
||||||
cpu = btcb->cpu;
|
cpu = btcb->cpu;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@ -178,7 +178,7 @@ bool nxsched_add_readytorun(FAR struct tcb_s *btcb)
|
|||||||
|
|
||||||
/* Get the task currently running on the CPU (may be the IDLE task) */
|
/* Get the task currently running on the CPU (may be the IDLE task) */
|
||||||
|
|
||||||
rtcb = (FAR struct tcb_s *)g_assignedtasks[cpu].head;
|
rtcb = current_task(cpu);
|
||||||
|
|
||||||
/* Determine the desired new task state. First, if the new task priority
|
/* Determine the desired new task state. First, if the new task priority
|
||||||
* is higher then the priority of the lowest priority, running task, then
|
* is higher then the priority of the lowest priority, running task, then
|
||||||
@ -198,7 +198,7 @@ bool nxsched_add_readytorun(FAR struct tcb_s *btcb)
|
|||||||
else if ((btcb->flags & TCB_FLAG_CPU_LOCKED) != 0)
|
else if ((btcb->flags & TCB_FLAG_CPU_LOCKED) != 0)
|
||||||
{
|
{
|
||||||
task_state = TSTATE_TASK_ASSIGNED;
|
task_state = TSTATE_TASK_ASSIGNED;
|
||||||
cpu = btcb->cpu;
|
cpu = btcb->cpu;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Otherwise, it will be ready-to-run, but not not yet running */
|
/* Otherwise, it will be ready-to-run, but not not yet running */
|
||||||
@ -206,7 +206,7 @@ bool nxsched_add_readytorun(FAR struct tcb_s *btcb)
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
task_state = TSTATE_TASK_READYTORUN;
|
task_state = TSTATE_TASK_READYTORUN;
|
||||||
cpu = 0; /* CPU does not matter */
|
cpu = 0; /* CPU does not matter */
|
||||||
}
|
}
|
||||||
|
|
||||||
/* If the selected state is TSTATE_TASK_RUNNING, then we would like to
|
/* If the selected state is TSTATE_TASK_RUNNING, then we would like to
|
||||||
@ -232,7 +232,7 @@ bool nxsched_add_readytorun(FAR struct tcb_s *btcb)
|
|||||||
|
|
||||||
nxsched_add_prioritized(btcb, &g_pendingtasks);
|
nxsched_add_prioritized(btcb, &g_pendingtasks);
|
||||||
btcb->task_state = TSTATE_TASK_PENDING;
|
btcb->task_state = TSTATE_TASK_PENDING;
|
||||||
doswitch = false;
|
doswitch = false;
|
||||||
}
|
}
|
||||||
else if (task_state == TSTATE_TASK_READYTORUN)
|
else if (task_state == TSTATE_TASK_READYTORUN)
|
||||||
{
|
{
|
||||||
@ -316,7 +316,7 @@ bool nxsched_add_readytorun(FAR struct tcb_s *btcb)
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
DEBUGASSERT(btcb->flink != NULL);
|
DEBUGASSERT(btcb->flink != NULL);
|
||||||
next = (FAR struct tcb_s *)btcb->flink;
|
next = btcb->flink;
|
||||||
|
|
||||||
if ((next->flags & TCB_FLAG_CPU_LOCKED) != 0)
|
if ((next->flags & TCB_FLAG_CPU_LOCKED) != 0)
|
||||||
{
|
{
|
||||||
|
@ -116,7 +116,7 @@ bool nxsched_merge_pending(void)
|
|||||||
/* The ptcb goes just before rtcb */
|
/* The ptcb goes just before rtcb */
|
||||||
|
|
||||||
rprev = rtcb->blink;
|
rprev = rtcb->blink;
|
||||||
if (!rprev)
|
if (rprev == NULL)
|
||||||
{
|
{
|
||||||
/* Special case: Inserting ptcb at the head of the list */
|
/* Special case: Inserting ptcb at the head of the list */
|
||||||
|
|
||||||
|
@ -146,8 +146,7 @@ bool nxsched_remove_readytorun(FAR struct tcb_s *rtcb, bool merge)
|
|||||||
* assigned to a CPU, and (2) and the g_assignedtasks[] lists which hold
|
* assigned to a CPU, and (2) and the g_assignedtasks[] lists which hold
|
||||||
* tasks assigned a CPU, including the task that is currently running on
|
* tasks assigned a CPU, including the task that is currently running on
|
||||||
* that CPU. Only this latter list contains the currently active task
|
* that CPU. Only this latter list contains the currently active task
|
||||||
* only only removing the head of that list can result in a context
|
* only removing the head of that list can result in a context switch.
|
||||||
* switch.
|
|
||||||
*
|
*
|
||||||
* rtcb->blink == NULL will tell us if the TCB is at the head of the
|
* rtcb->blink == NULL will tell us if the TCB is at the head of the
|
||||||
* ready-to-run list and, hence, a candidate for the new running task.
|
* ready-to-run list and, hence, a candidate for the new running task.
|
||||||
@ -167,7 +166,7 @@ bool nxsched_remove_readytorun(FAR struct tcb_s *rtcb, bool merge)
|
|||||||
* after the TCB being removed.
|
* after the TCB being removed.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
nxttcb = (FAR struct tcb_s *)rtcb->flink;
|
nxttcb = rtcb->flink;
|
||||||
DEBUGASSERT(nxttcb != NULL);
|
DEBUGASSERT(nxttcb != NULL);
|
||||||
|
|
||||||
/* If we are modifying the head of some assigned task list other than
|
/* If we are modifying the head of some assigned task list other than
|
||||||
@ -206,7 +205,7 @@ bool nxsched_remove_readytorun(FAR struct tcb_s *rtcb, bool merge)
|
|||||||
|
|
||||||
for (rtrtcb = (FAR struct tcb_s *)g_readytorun.head;
|
for (rtrtcb = (FAR struct tcb_s *)g_readytorun.head;
|
||||||
rtrtcb != NULL && !CPU_ISSET(cpu, &rtrtcb->affinity);
|
rtrtcb != NULL && !CPU_ISSET(cpu, &rtrtcb->affinity);
|
||||||
rtrtcb = (FAR struct tcb_s *)rtrtcb->flink);
|
rtrtcb = rtrtcb->flink);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Did we find a task in the g_readytorun list? Which task should
|
/* Did we find a task in the g_readytorun list? Which task should
|
||||||
|
@ -56,7 +56,7 @@
|
|||||||
#ifdef CONFIG_SMP
|
#ifdef CONFIG_SMP
|
||||||
static FAR struct tcb_s *nxsched_nexttcb(FAR struct tcb_s *tcb)
|
static FAR struct tcb_s *nxsched_nexttcb(FAR struct tcb_s *tcb)
|
||||||
{
|
{
|
||||||
FAR struct tcb_s *nxttcb = (FAR struct tcb_s *)tcb->flink;
|
FAR struct tcb_s *nxttcb = tcb->flink;
|
||||||
FAR struct tcb_s *rtrtcb;
|
FAR struct tcb_s *rtrtcb;
|
||||||
|
|
||||||
/* Which task should run next? It will be either the next tcb in the
|
/* Which task should run next? It will be either the next tcb in the
|
||||||
@ -74,7 +74,7 @@ static FAR struct tcb_s *nxsched_nexttcb(FAR struct tcb_s *tcb)
|
|||||||
|
|
||||||
for (rtrtcb = (FAR struct tcb_s *)g_readytorun.head;
|
for (rtrtcb = (FAR struct tcb_s *)g_readytorun.head;
|
||||||
rtrtcb != NULL && !CPU_ISSET(tcb->cpu, &rtrtcb->affinity);
|
rtrtcb != NULL && !CPU_ISSET(tcb->cpu, &rtrtcb->affinity);
|
||||||
rtrtcb = (FAR struct tcb_s *)rtrtcb->flink);
|
rtrtcb = rtrtcb->flink);
|
||||||
|
|
||||||
/* Return the TCB from the readyt-to-run list if it is the next
|
/* Return the TCB from the readyt-to-run list if it is the next
|
||||||
* highest priority task.
|
* highest priority task.
|
||||||
@ -128,7 +128,7 @@ static inline void nxsched_running_setpriority(FAR struct tcb_s *tcb,
|
|||||||
#ifdef CONFIG_SMP
|
#ifdef CONFIG_SMP
|
||||||
nxttcb = nxsched_nexttcb(tcb);
|
nxttcb = nxsched_nexttcb(tcb);
|
||||||
#else
|
#else
|
||||||
nxttcb = (FAR struct tcb_s *)tcb->flink;
|
nxttcb = tcb->flink;
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
DEBUGASSERT(nxttcb != NULL);
|
DEBUGASSERT(nxttcb != NULL);
|
||||||
|
@ -322,7 +322,7 @@ static int nxsem_recoverholders(FAR struct semholder_s *pholder,
|
|||||||
static int nxsem_boostholderprio(FAR struct semholder_s *pholder,
|
static int nxsem_boostholderprio(FAR struct semholder_s *pholder,
|
||||||
FAR sem_t *sem, FAR void *arg)
|
FAR sem_t *sem, FAR void *arg)
|
||||||
{
|
{
|
||||||
FAR struct tcb_s *htcb = (FAR struct tcb_s *)pholder->htcb;
|
FAR struct tcb_s *htcb = pholder->htcb;
|
||||||
FAR struct tcb_s *rtcb = (FAR struct tcb_s *)arg;
|
FAR struct tcb_s *rtcb = (FAR struct tcb_s *)arg;
|
||||||
|
|
||||||
/* If the priority of the thread that is waiting for a count is less than
|
/* If the priority of the thread that is waiting for a count is less than
|
||||||
@ -357,7 +357,7 @@ static int nxsem_verifyholder(FAR struct semholder_s *pholder,
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
#if 0
|
#if 0
|
||||||
FAR struct tcb_s *htcb = (FAR struct tcb_s *)pholder->htcb;
|
FAR struct tcb_s *htcb = pholder->htcb;
|
||||||
|
|
||||||
/* Called after a semaphore has been released (incremented), the semaphore
|
/* Called after a semaphore has been released (incremented), the semaphore
|
||||||
* could be non-negative, and there is no thread waiting for the count.
|
* could be non-negative, and there is no thread waiting for the count.
|
||||||
|
@ -192,7 +192,7 @@ static void nxsig_null_action(int signo)
|
|||||||
#ifdef HAVE_NXSIG_ABNORMAL_TERMINANTION
|
#ifdef HAVE_NXSIG_ABNORMAL_TERMINANTION
|
||||||
static void nxsig_abnormal_termination(int signo)
|
static void nxsig_abnormal_termination(int signo)
|
||||||
{
|
{
|
||||||
FAR struct tcb_s *rtcb = (FAR struct tcb_s *)this_task();
|
FAR struct tcb_s *rtcb = this_task();
|
||||||
|
|
||||||
/* Careful: In the multi-threaded task, the signal may be handled on a
|
/* Careful: In the multi-threaded task, the signal may be handled on a
|
||||||
* child pthread.
|
* child pthread.
|
||||||
@ -248,7 +248,7 @@ static void nxsig_abnormal_termination(int signo)
|
|||||||
#ifdef CONFIG_SIG_SIGSTOP_ACTION
|
#ifdef CONFIG_SIG_SIGSTOP_ACTION
|
||||||
static void nxsig_stop_task(int signo)
|
static void nxsig_stop_task(int signo)
|
||||||
{
|
{
|
||||||
FAR struct tcb_s *rtcb = (FAR struct tcb_s *)this_task();
|
FAR struct tcb_s *rtcb = this_task();
|
||||||
#if defined(CONFIG_SCHED_WAITPID) && !defined(CONFIG_SCHED_HAVE_PARENT)
|
#if defined(CONFIG_SCHED_WAITPID) && !defined(CONFIG_SCHED_HAVE_PARENT)
|
||||||
FAR struct task_group_s *group;
|
FAR struct task_group_s *group;
|
||||||
|
|
||||||
|
@ -81,7 +81,7 @@ int nxtask_delete(pid_t pid)
|
|||||||
|
|
||||||
/* Get the TCB of the task to be deleted */
|
/* Get the TCB of the task to be deleted */
|
||||||
|
|
||||||
dtcb = (FAR struct tcb_s *)nxsched_get_tcb(pid);
|
dtcb = nxsched_get_tcb(pid);
|
||||||
if (dtcb == NULL)
|
if (dtcb == NULL)
|
||||||
{
|
{
|
||||||
/* The pid does not correspond to any known thread. The task
|
/* The pid does not correspond to any known thread. The task
|
||||||
|
@ -126,7 +126,7 @@ static int work_thread(int argc, FAR char *argv[])
|
|||||||
{
|
{
|
||||||
FAR struct kwork_wqueue_s *wqueue;
|
FAR struct kwork_wqueue_s *wqueue;
|
||||||
FAR struct work_s *work;
|
FAR struct work_s *work;
|
||||||
worker_t worker;
|
worker_t worker;
|
||||||
irqstate_t flags;
|
irqstate_t flags;
|
||||||
FAR void *arg;
|
FAR void *arg;
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user