svn commit: r315267 - in stable/11/sys: kern sys
Hans Petter Selasky
hselasky at FreeBSD.org
Tue Mar 14 15:59:53 UTC 2017
Author: hselasky
Date: Tue Mar 14 15:59:51 2017
New Revision: 315267
URL: https://svnweb.freebsd.org/changeset/base/315267
Log:
MFC r314553:
Implement taskqueue_poll_is_busy() for use by the LinuxKPI.
Refer to comment above function for a detailed description.
Discussed with: kib @
Sponsored by: Mellanox Technologies
Modified:
stable/11/sys/kern/subr_taskqueue.c
stable/11/sys/sys/taskqueue.h
Directory Properties:
stable/11/ (props changed)
Modified: stable/11/sys/kern/subr_taskqueue.c
==============================================================================
--- stable/11/sys/kern/subr_taskqueue.c Tue Mar 14 15:58:01 2017 (r315266)
+++ stable/11/sys/kern/subr_taskqueue.c Tue Mar 14 15:59:51 2017 (r315267)
@@ -487,6 +487,23 @@ task_is_running(struct taskqueue *queue,
return (0);
}
+/*
+ * Only use this function in single threaded contexts. It returns
+ * non-zero if the given task is either pending or running. Else the
+ * task is idle and can be queued again or freed.
+ */
+int
+taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task)
+{
+ int retval;
+
+ TQ_LOCK(queue);
+ retval = task->ta_pending > 0 || task_is_running(queue, task);
+ TQ_UNLOCK(queue);
+
+ return (retval);
+}
+
static int
taskqueue_cancel_locked(struct taskqueue *queue, struct task *task,
u_int *pendp)
Modified: stable/11/sys/sys/taskqueue.h
==============================================================================
--- stable/11/sys/sys/taskqueue.h Tue Mar 14 15:58:01 2017 (r315266)
+++ stable/11/sys/sys/taskqueue.h Tue Mar 14 15:59:51 2017 (r315267)
@@ -79,6 +79,7 @@ int taskqueue_start_threads_cpuset(struc
int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
int taskqueue_enqueue_timeout(struct taskqueue *queue,
struct timeout_task *timeout_task, int ticks);
+int taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task);
int taskqueue_cancel(struct taskqueue *queue, struct task *task,
u_int *pendp);
int taskqueue_cancel_timeout(struct taskqueue *queue,
More information about the svn-src-stable-11
mailing list