Changes in kernel/generic/src/synch/workqueue.c [63e27ef:b7fd2a0] in mainline

File:

• kernel/generic/src/synch/workqueue.c (modified) (7 diffs)

kernel/generic/src/synch/workqueue.c

@@ -38 +38 @@
 
 #include <assert.h>
+#include <errno.h>
 #include <synch/workqueue.h>
 #include <synch/spinlock.h>
@@ -256 +257 @@
  * workq_stop().
  */
-int workq_init(struct work_queue *workq, const char *name)
+bool workq_init(struct work_queue *workq, const char *name)
 {
         workq_preinit(workq, name);
@@ -394 +395 @@
  * See workq_enqueue_noblock() for more details.
  */
-int workq_global_enqueue_noblock(work_t *work_item, work_func_t func)
+bool workq_global_enqueue_noblock(work_t *work_item, work_func_t func)
 {
         return workq_enqueue_noblock(&g_work_queue, work_item, func);
@@ -403 +404 @@
  * See workq_enqueue() for more details.
  */
-int workq_global_enqueue(work_t *work_item, work_func_t func)
+bool workq_global_enqueue(work_t *work_item, work_func_t func)
 {
         return workq_enqueue(&g_work_queue, work_item, func);
@@ -426 +427 @@
  * @return true  Otherwise. func() will be invoked in a separate thread.
  */
-int workq_enqueue_noblock(struct work_queue *workq, work_t *work_item, 
+bool workq_enqueue_noblock(struct work_queue *workq, work_t *work_item, 
         work_func_t func)
 {
@@ -446 +447 @@
  * @return true  Otherwise. func() will be invoked in a separate thread.
  */
-int workq_enqueue(struct work_queue *workq, work_t *work_item, work_func_t func)
+bool workq_enqueue(struct work_queue *workq, work_t *work_item, work_func_t func)
 {
         return _workq_enqueue(workq, work_item, func, true);
@@ -894 +895 @@
         
         while (list_empty(&info->work_queues) && !stop) {
-                int ret = _condvar_wait_timeout_irq_spinlock(&info->req_cv, 
+                errno_t ret = _condvar_wait_timeout_irq_spinlock(&info->req_cv, 
                         &info->lock, SYNCH_NO_TIMEOUT, SYNCH_FLAGS_INTERRUPTIBLE);
                 
-                stop = (ret == ESYNCH_INTERRUPTED);
+                stop = (ret == EINTR);
         }