d/freebsd-dev
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Create separate taskqueue to call zfs_unlinked_drain().

Browse Source 
r334810 introduced zfs_unlinked_drain() dispatch to taskqueue on every
deletion of a file with extended attributes.  Using system_taskq for that
with its multiple threads in case of multiple files deletion caused all
available CPU threads to uselessly spin on busy locks, completely blocking
the system.

Use of single dedicated taskqueue is the only easy solution I've found,
while in would be great if we could specify that some task should be
executed only once at a time, but never in parallel, while many tasks
could use different threads same time.

Sponsored by:	iXsystems, Inc.
This commit is contained in:
Alexander Motin 2018-08-22 16:27:24 +00:00
parent 39cec25ba7
commit 6128ca8683
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=338205
2 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sys/cddl/contrib/opensolaris/uts/common/fs/zfs/zfs_dir.c
View File

@ -402,6 +402,10 @@ zfs_purgedir(znode_t *dzp)
return (skipped);
}
#if defined(__FreeBSD__)
extern taskq_t *zfsvfs_taskq;
#endif
void
zfs_rmnode(znode_t *zp)
{
@ -520,15 +524,17 @@ zfs_rmnode(znode_t *zp)
dmu_tx_commit(tx);
#if defined(__FreeBSD__)
if (xattr_obj) {
/*
* We're using the FreeBSD taskqueue API here instead of
* the Solaris taskq API since the FreeBSD API allows for a
* task to be enqueued multiple times but executed once.
*/
taskqueue_enqueue(system_taskq->tq_queue,
taskqueue_enqueue(zfsvfs_taskq->tq_queue,
&zfsvfs->z_unlinked_drain_task);
}
#endif
}
static uint64_t

12
sys/cddl/contrib/opensolaris/uts/common/fs/zfs/zfs_vfsops.c
View File

@ -1130,6 +1130,8 @@ zfsvfs_init(zfsvfs_t *zfsvfs, objset_t *os)
}
#if defined(__FreeBSD__)
taskq_t *zfsvfs_taskq;
static void
zfsvfs_task_unlinked_drain(void *context, int pending __unused)
{
@ -2185,9 +2187,9 @@ zfs_umount(vfs_t *vfsp, int fflag)
}
#endif
while (taskqueue_cancel(system_taskq->tq_queue,
while (taskqueue_cancel(zfsvfs_taskq->tq_queue,
&zfsvfs->z_unlinked_drain_task, NULL) != 0)
taskqueue_drain(system_taskq->tq_queue,
taskqueue_drain(zfsvfs_taskq->tq_queue,
&zfsvfs->z_unlinked_drain_task);
VERIFY(zfsvfs_teardown(zfsvfs, B_TRUE) == 0);
@ -2554,11 +2556,17 @@ zfs_init(void)
zfs_vnodes_adjust();
dmu_objset_register_type(DMU_OST_ZFS, zfs_space_delta_cb);
#if defined(__FreeBSD__)
zfsvfs_taskq = taskq_create("zfsvfs", 1, minclsyspri, 0, 0, 0);
#endif
}
void
zfs_fini(void)
{
#if defined(__FreeBSD__)
taskq_destroy(zfsvfs_taskq);
#endif
zfsctl_fini();
zfs_znode_fini();
zfs_vnodes_adjust_back();