Changeset 015b147 in mainline for uspace/srv/sysman/repo.c

Timestamp:

2019-08-17T13:52:32Z (5 years ago)

Author:

Matthieu Riolo <matthieu.riolo@…>

Children:

be07995

Parents:

31ef7c1

git-author:

Michal Koutný <xm.koutny+hos@…> (2016-01-10 17:17:19)

git-committer:

Matthieu Riolo <matthieu.riolo@…> (2019-08-17 13:52:32)

Message:

sysman: Refactored unit repo iteration and locking

File:

• uspace/srv/sysman/repo.c (modified) (12 diffs)

uspace/srv/sysman/repo.c

@@ -38 +38 @@
 #include "log.h"
 
-LIST_INITIALIZE(units);
+LIST_INITIALIZE(units_);
 
 static hash_table_t units_by_name;
@@ -119 +119 @@
 static void repo_remove_unit_internal(unit_t *u)
 {
+        assert(fibril_rwlock_is_write_locked(&repo_lock));
+
         hash_table_remove_item(&units_by_name, &u->units_by_name);
         hash_table_remove_item(&units_by_handle, &u->units_by_handle);
@@ -125 +127 @@
         // TODO decrease refcount of unit
         // unit may be referenced e.g. from running job, thus we cannot simply destroy it
+}
+
+static unit_t *repo_find_unit_by_name_internal(const char *name, bool lock)
+{
+        sysman_log(LVL_DEBUG2, "%s(%s, %i)", __func__, name, lock);
+        if (lock) fibril_rwlock_read_lock(&repo_lock);
+        ht_link_t *ht_link = hash_table_find(&units_by_name, (void *)name);
+        if (lock) fibril_rwlock_read_unlock(&repo_lock);
+
+        if (ht_link != NULL) {
+                return hash_table_get_inst(ht_link, unit_t, units_by_name);
+        } else {
+                return NULL;
+        }
 }
 
@@ -139 +155 @@
         assert(unit->handle == 0);
         assert(unit->name != NULL);
+        assert(fibril_rwlock_is_write_locked(&repo_lock));
         sysman_log(LVL_DEBUG2, "%s('%s')", __func__, unit_name(unit));
 
-        fibril_rwlock_write_lock(&repo_lock);
         if (hash_table_insert_unique(&units_by_name, &unit->units_by_name)) {
                 /* Pointers are same size as unit_handle_t both on 32b and 64b */
@@ -147 +163 @@
 
                 hash_table_insert(&units_by_handle, &unit->units_by_handle);
-                list_append(&unit->units, &units);
-                fibril_rwlock_write_unlock(&repo_lock);
+                list_append(&unit->units, &units_);
                 return EOK;
         } else {
-                fibril_rwlock_write_unlock(&repo_lock);
                 return EEXISTS;
         }
@@ -162 +176 @@
 }
 
-void repo_begin_update(void) {
-        sysman_log(LVL_DEBUG2, "%s", __func__);
+void repo_begin_update_(void) {
+        sysman_log(LVL_DEBUG2, "%s", __func__);
+        fibril_rwlock_write_lock(&repo_lock);
 }
 
@@ -196 +211 @@
          */
         hash_table_apply(&units_by_name, &repo_commit_unit, NULL);
+        fibril_rwlock_write_unlock(&repo_lock);
 }
 
@@ -228 +244 @@
 
         hash_table_apply(&units_by_name, &repo_rollback_unit, NULL);
+        fibril_rwlock_write_unlock(&repo_lock);
 }
 
@@ -243 +260 @@
 
                 unit_t *output =
-                    repo_find_unit_by_name(e->output_name);
+                    repo_find_unit_by_name_unsafe(e->output_name);
                 if (output == NULL) {
                         sysman_log(LVL_ERROR,
@@ -273 +290 @@
 }
 
-unit_t *repo_find_unit_by_name(const char *name)
-{
-        fibril_rwlock_read_lock(&repo_lock);
-        ht_link_t *ht_link = hash_table_find(&units_by_name, (void *)name);
-        fibril_rwlock_read_unlock(&repo_lock);
-
-        if (ht_link != NULL) {
-                return hash_table_get_inst(ht_link, unit_t, units_by_name);
-        } else {
-                return NULL;
-        }
-}
-
+/**
+ * The function can be safely called from non-event loop fibrils
+ */
+unit_t *repo_find_unit_by_name_(const char *name)
+{
+        return repo_find_unit_by_name_internal(name, true);
+}
+
+/**
+ * @note Caller must hold repo_lock (at least reader)
+ */
+unit_t *repo_find_unit_by_name_unsafe(const char *name)
+{
+        return repo_find_unit_by_name_internal(name, false);
+}
+
+/**
+ * The function can be safely called from non-event loop fibrils
+ */
 unit_t *repo_find_unit_by_handle(unit_handle_t handle)
 {
+        sysman_log(LVL_DEBUG2, "%s", __func__);
         fibril_rwlock_read_lock(&repo_lock);
         ht_link_t *ht_link = hash_table_find(&units_by_handle, &handle);
@@ -301 +325 @@
 void repo_rlock(void)
 {
+        sysman_log(LVL_DEBUG2, "%s", __func__);
         fibril_rwlock_read_lock(&repo_lock);
 }
@@ -306 +331 @@
 void repo_runlock(void)
 {
+        sysman_log(LVL_DEBUG2, "%s", __func__);
         fibril_rwlock_read_unlock(&repo_lock);
 }