Changeset 96c30c8 in mainline for kernel/generic/src/synch/waitq.c

Timestamp:

2018-06-28T15:45:37Z (7 years ago)

Author:

Jiří Zárevúcky <jiri.zarevucky@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

331d024

Parents:

82453b29

git-author:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-06-28 15:36:29)

git-committer:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-06-28 15:45:37)

Message:

Turn ipc_poke() into a regular wakeup on the waitq.

With prior behavior of ignoring the poke when no thread is blocking,
a thread could go to sleep just after a poke meant for it and sleep
indefinitely despite there being work to do.

After the change, worst case scenario, thread enters ipc wait, exits
immediately due to a previous poke, finds no work to do and enters ipc wait
again (possibly repeating the spurious wakeup a few times).

File:

• kernel/generic/src/synch/waitq.c (modified) (1 diff)

kernel/generic/src/synch/waitq.c

@@ -190 +190 @@
         if (do_wakeup)
                 thread_ready(thread);
-}
-
-/** Interrupt the first thread sleeping in the wait queue.
- *
- * Note that the caller somehow needs to know that the thread to be interrupted
- * is sleeping interruptibly.
- *
- * @param wq Pointer to wait queue.
- *
- */
-void waitq_unsleep(waitq_t *wq)
-{
-        irq_spinlock_lock(&wq->lock, true);
-
-        if (!list_empty(&wq->sleepers)) {
-                thread_t *thread = list_get_instance(list_first(&wq->sleepers),
-                    thread_t, wq_link);
-
-                irq_spinlock_lock(&thread->lock, false);
-
-                assert(thread->sleep_interruptible);
-
-                if ((thread->timeout_pending) &&
-                    (timeout_unregister(&thread->sleep_timeout)))
-                        thread->timeout_pending = false;
-
-                list_remove(&thread->wq_link);
-                thread->saved_context = thread->sleep_interruption_context;
-                thread->sleep_queue = NULL;
-
-                irq_spinlock_unlock(&thread->lock, false);
-                thread_ready(thread);
-        }
-
-        irq_spinlock_unlock(&wq->lock, true);
 }