X-Git-Url: https://git.camperquake.de/gitweb.cgi?a=blobdiff_plain;f=module%2Fzfs%2Fzfs_rlock.c;h=4f34b3758fa01737c0d3c713aaac5be275730af6;hb=04f9432d3bcb15ff8ed6ddc2dc377a4c0264340d;hp=26ad58de8b83a1d6176bf2af07aec002ec0f9bca;hpb=8926ab7a50d60d855e4d49d2ed7bdef49dd56149;p=zfs.git

diff --git a/module/zfs/zfs_rlock.c b/module/zfs/zfs_rlock.c
index 26ad58d..4f34b37 100644
--- a/module/zfs/zfs_rlock.c
+++ b/module/zfs/zfs_rlock.c
@@ -426,7 +426,7 @@ zfs_range_lock(znode_t *zp, uint64_t off, uint64_t len, rl_type_t type)
 
 	ASSERT(type == RL_READER || type == RL_WRITER || type == RL_APPEND);
 
-	new = kmem_alloc(sizeof (rl_t), KM_SLEEP);
+	new = kmem_alloc(sizeof (rl_t), KM_PUSHPAGE);
 	new->r_zp = zp;
 	new->r_off = off;
 	if (len + off < off)	/* overflow */
@@ -471,7 +471,7 @@ zfs_range_free(void *arg)
  * Unlock a reader lock
  */
 static void
-zfs_range_unlock_reader(znode_t *zp, rl_t *remove)
+zfs_range_unlock_reader(znode_t *zp, rl_t *remove, list_t *free_list)
 {
 	avl_tree_t *tree = &zp->z_range_avl;
 	rl_t *rl, *next = NULL;
@@ -493,7 +493,7 @@ zfs_range_unlock_reader(znode_t *zp, rl_t *remove)
 		if (remove->r_read_wanted)
 			cv_broadcast(&remove->r_rd_cv);
 
-		taskq_dispatch(system_taskq, zfs_range_free, remove, 0);
+		list_insert_tail(free_list, remove);
 	} else {
 		ASSERT3U(remove->r_cnt, ==, 0);
 		ASSERT3U(remove->r_write_wanted, ==, 0);
@@ -526,8 +526,7 @@ zfs_range_unlock_reader(znode_t *zp, rl_t *remove)
 				if (rl->r_read_wanted)
 					cv_broadcast(&rl->r_rd_cv);
 
-				taskq_dispatch(system_taskq,
-				    zfs_range_free, rl, 0);
+				list_insert_tail(free_list, rl);
 			}
 		}
 
@@ -543,10 +542,13 @@ void
 zfs_range_unlock(rl_t *rl)
 {
 	znode_t *zp = rl->r_zp;
+	list_t free_list;
+	rl_t *free_rl;
 
 	ASSERT(rl->r_type == RL_WRITER || rl->r_type == RL_READER);
 	ASSERT(rl->r_cnt == 1 || rl->r_cnt == 0);
 	ASSERT(!rl->r_proxy);
+	list_create(&free_list, sizeof(rl_t), offsetof(rl_t, rl_node));
 
 	mutex_enter(&zp->z_range_lock);
 	if (rl->r_type == RL_WRITER) {
@@ -559,14 +561,21 @@ zfs_range_unlock(rl_t *rl)
 		if (rl->r_read_wanted)
 			cv_broadcast(&rl->r_rd_cv);
 
-		taskq_dispatch(system_taskq, zfs_range_free, rl, 0);
+		list_insert_tail(&free_list, rl);
 	} else {
 		/*
 		 * lock may be shared, let zfs_range_unlock_reader()
 		 * release the zp->z_range_lock lock and free the rl_t
 		 */
-		zfs_range_unlock_reader(zp, rl);
+		zfs_range_unlock_reader(zp, rl, &free_list);
 	}
+
+	while ((free_rl = list_head(&free_list)) != NULL) {
+		list_remove(&free_list, free_rl);
+		zfs_range_free(free_rl);
+	}
+
+	list_destroy(&free_list);
 }
 
 /*