Code

utils/channel: Added an asynchronous I/O multiplexer.
[sysdb.git] / src / utils / llist.c
index 3f54786074941d368bc88da4ca475b8cd2559e7c..0af9c8cb11bec4346b96c557275b4a813ccfd618 100644 (file)
@@ -117,12 +117,11 @@ sdb_llist_insert_after(sdb_llist_t *list, sdb_llist_elem_t *elem,
 
 static sdb_llist_elem_t *
 llist_search(sdb_llist_t *list,
-               sdb_llist_lookup_cb lookup, void *user_data)
+               sdb_llist_lookup_cb lookup, const void *user_data)
 {
        sdb_llist_elem_t *elem;
 
-       if ((! list) || (! lookup))
-               return NULL;
+       assert(list && lookup);
 
        for (elem = list->head; elem; elem = elem->next)
                if (! lookup(elem->obj, user_data))
@@ -307,10 +306,13 @@ sdb_llist_insert_sorted(sdb_llist_t *list,
 
 sdb_object_t *
 sdb_llist_search(sdb_llist_t *list,
-               sdb_llist_lookup_cb lookup, void *user_data)
+               sdb_llist_lookup_cb lookup, const void *user_data)
 {
        sdb_llist_elem_t *elem;
 
+       if ((! list) || (! lookup))
+               return NULL;
+
        pthread_rwlock_rdlock(&list->lock);
        elem = llist_search(list, lookup, user_data);
        pthread_rwlock_unlock(&list->lock);
@@ -343,11 +345,14 @@ sdb_llist_search_by_name(sdb_llist_t *list, const char *key)
 
 sdb_object_t *
 sdb_llist_remove(sdb_llist_t *list,
-               sdb_llist_lookup_cb lookup, void *user_data)
+               sdb_llist_lookup_cb lookup, const void *user_data)
 {
        sdb_llist_elem_t *elem;
        sdb_object_t *obj = NULL;
 
+       if ((! list) || (! lookup))
+               return NULL;
+
        pthread_rwlock_wrlock(&list->lock);
        elem = llist_search(list, lookup, user_data);
        if (elem)