Changeset 73f7c4e in mainline for uspace/srv/sysman/sysman.c

Timestamp:

2019-08-06T18:29:02Z (6 years ago)

Author:

Matthieu Riolo <matthieu.riolo@…>

Children:

c2d50c8

Parents:

c1b2084

git-author:

Michal Koutný <xm.koutny+hos@…> (2015-05-24 09:32:10)

git-committer:

Matthieu Riolo <matthieu.riolo@…> (2019-08-06 18:29:02)

Message:

sysman: Create tests for job control

• units are mocked by patching virtual methods table
• sysman_process_queue to enforce emptying event queue

Conflicts:

.bzrignore
boot/Makefile.common

File:

• uspace/srv/sysman/sysman.c (modified) (6 diffs)

uspace/srv/sysman/sysman.c

@@ -62 +62 @@
 static LIST_INITIALIZE(event_queue);
 static fibril_mutex_t event_queue_mtx;
-static fibril_condvar_t event_queue_cv;
+static fibril_condvar_t event_queue_nonempty_cv;
+static fibril_condvar_t event_queue_empty_cv;
 
 static hash_table_t observed_objects;
@@ -123 +124 @@
 {
         fibril_mutex_initialize(&event_queue_mtx);
-        fibril_condvar_initialize(&event_queue_cv);
+        fibril_condvar_initialize(&event_queue_nonempty_cv);
+        fibril_condvar_initialize(&event_queue_empty_cv);
 
         bool table =
@@ -141 +143 @@
                 fibril_mutex_lock(&event_queue_mtx);
                 while (list_empty(&event_queue)) {
-                        fibril_condvar_wait(&event_queue_cv, &event_queue_mtx);
+                        fibril_condvar_signal(&event_queue_empty_cv);
+                        fibril_condvar_wait(&event_queue_nonempty_cv,
+                            &event_queue_mtx);
                 }
 
@@ -160 +164 @@
 /** Create and queue job for unit
  *
+ * If unit already has the same job assigned callback is set to it.
+ *
  * @param[in]  callback  (optional) callback must explicitly delete reference
- *                       to job
- */
-int sysman_queue_job(unit_t *unit, unit_state_t target_state,
+ *                       to job, void callback(void *job, void *callback_arg)
+ *
+ * return EBUSY  unit already has a job assigned of different type
+ */
+int sysman_run_job(unit_t *unit, unit_state_t target_state,
     callback_handler_t callback, void *callback_arg)
 {
-        job_t *job = job_create(unit, target_state);
-        if (job == NULL) {
-                return ENOMEM;
+        job_t *job;
+
+        if (unit->job != NULL) {
+                assert(unit->job->state != JOB_UNQUEUED);
+
+                if (unit->job->target_state != target_state) {
+                        return EBUSY;
+                }
+                job = unit->job;
+        } else {
+                job = job_create(unit, target_state);
+                if (job == NULL) {
+                        return ENOMEM;
+                }
+                /* Reference in unit is enough */
+                job_del_ref(&job);
         }
 
@@ -176 +197 @@
         }
 
-        job_add_ref(job);
-        sysman_raise_event(&sysman_event_job_process, job);
-
-        job_del_ref(&job);
+        if (job->state == JOB_UNQUEUED) {
+                job_add_ref(job);
+                sysman_raise_event(&sysman_event_job_process, job);
+        }
+
         return EOK;
 }
@@ -199 +221 @@
         list_append(&event->event_queue, &event_queue);
         /* There's only single event loop, broadcast is unnecessary */
-        fibril_condvar_signal(&event_queue_cv);
+        fibril_condvar_signal(&event_queue_nonempty_cv);
+        fibril_mutex_unlock(&event_queue_mtx);
+}
+
+/** Empty current content of event queue
+ *
+ * This is potentially blocking call and as long as fibrils are cooperatively
+ * scheduled, queue will be empty upon return from this function.
+ */
+void sysman_process_queue(void)
+{
+        fibril_mutex_lock(&event_queue_mtx);
+        while (!list_empty(&event_queue)) {
+                fibril_condvar_wait(&event_queue_empty_cv, &event_queue_mtx);
+        }
         fibril_mutex_unlock(&event_queue_mtx);
 }