Author: hselasky
Date: Tue Mar 14 16:01:36 2017
New Revision: 315269
URL: https://svnweb.freebsd.org/changeset/base/315269

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/9/sys/kern/subr_taskqueue.c
  stable/9/sys/sys/taskqueue.h
Directory Properties:
  stable/9/sys/   (props changed)
  stable/9/sys/sys/   (props changed)

Modified: stable/9/sys/kern/subr_taskqueue.c
==============================================================================
--- stable/9/sys/kern/subr_taskqueue.c  Tue Mar 14 16:00:33 2017        
(r315268)
+++ stable/9/sys/kern/subr_taskqueue.c  Tue Mar 14 16:01:36 2017        
(r315269)
@@ -356,6 +356,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/9/sys/sys/taskqueue.h
==============================================================================
--- stable/9/sys/sys/taskqueue.h        Tue Mar 14 16:00:33 2017        
(r315268)
+++ stable/9/sys/sys/taskqueue.h        Tue Mar 14 16:01:36 2017        
(r315269)
@@ -64,6 +64,7 @@ int   taskqueue_start_threads(struct taskq
 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,
_______________________________________________
svn-src-stable-9@freebsd.org mailing list
https://lists.freebsd.org/mailman/listinfo/svn-src-stable-9
To unsubscribe, send any mail to "svn-src-stable-9-unsubscr...@freebsd.org"

Reply via email to