Work queues... correct cloning error in last commit
This commit is contained in:
parent
bbf4d5048a
commit
024113b90e
@ -91,10 +91,6 @@ static int work_qqueue(FAR struct usr_wqueue_s *wqueue,
|
|||||||
{
|
{
|
||||||
DEBUGASSERT(work != NULL);
|
DEBUGASSERT(work != NULL);
|
||||||
|
|
||||||
/* Cancel any pending work in the work stucture */
|
|
||||||
|
|
||||||
work_cancel(qid, work);
|
|
||||||
|
|
||||||
/* Get exclusive access to the work queue */
|
/* Get exclusive access to the work queue */
|
||||||
|
|
||||||
while (work_lock() < 0);
|
while (work_lock() < 0);
|
||||||
@ -154,6 +150,10 @@ int work_queue(int qid, FAR struct work_s *work, worker_t worker,
|
|||||||
{
|
{
|
||||||
if (qid == USRWORK)
|
if (qid == USRWORK)
|
||||||
{
|
{
|
||||||
|
/* Cancel any pending work in the work stucture */
|
||||||
|
|
||||||
|
work_cancel(qid, work);
|
||||||
|
|
||||||
return work_qqueue(&g_usrwork, work, worker, arg, delay);
|
return work_qqueue(&g_usrwork, work, worker, arg, delay);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
Loading…
Reference in New Issue
Block a user