----- On Dec 7, 2018, at 5:06 PM, Jeremie Galarneau
jeremie.galarn...@efficios.com wrote:
> The work queue implementation is derived from the call-rcu thread. A
> number of references seem to have been left in place when adapting the
> code for its new purpose.
All 4 patches merged into master, stable-0.10. It is not needed in
stable-0.9 because workqueue.c was only introduced in 0.10. One
thing to keep in mind: workqueue.{c,h} is an internal API for now,
so there is really only just a single user of this API (rculfhash)
at the moment.
I added two additional patches, for the following sequences of
commits:
5bbe95b Fix: only wait if work queue is empty in real-time mode
c6871b6 Fix: don't wait after completion of a work queue job batch
73d8b52 Fix: don't wait after completion of job batch if work queue is empty
d25f25d Fix: workqueue: struct urcu_work vs rcu_head mixup
1b6fc17 Cleanup: workqueue: update comments referring to call-rcu
9db9edc Fix: mixup between URCU_WORKQUEUE_RT and URCU_CALL_RCU_RT
Thanks!
Mathieu
>
> The URCU_CALL_RCU_RT flag is used by wake_worker_thread() while the
> rest of the workqueue.c code uses URCU_WORKQUEUE_RT to determine if
> the work queue was configured in real-time mode. Both flags are defined
> to the same value (0x1) and the current internal user of the
> work queue (lfht) never specifies any flags.
>
> In practice, this does not cause any problem so I doubt this patch
> needs to be backported. Feel free to rename "Fix" to "Clean-up".
>
> There are a number of comments referencing call-rcu which may need
> to be adapted. Changing them is left as an exercise to the maintainer
> as I don't know if they apply to the workqueue thread.
>
> Signed-off-by: Jérémie Galarneau <jeremie.galarn...@efficios.com>
> ---
> src/workqueue.c | 2 +-
> 1 file changed, 1 insertion(+), 1 deletion(-)
>
> diff --git a/src/workqueue.c b/src/workqueue.c
> index 17ea835..8561a7a 100644
> --- a/src/workqueue.c
> +++ b/src/workqueue.c
> @@ -309,7 +309,7 @@ struct urcu_workqueue *urcu_workqueue_create(unsigned long
> flags,
>
> static void wake_worker_thread(struct urcu_workqueue *workqueue)
> {
> - if (!(_CMM_LOAD_SHARED(workqueue->flags) & URCU_CALL_RCU_RT))
> + if (!(_CMM_LOAD_SHARED(workqueue->flags) & URCU_WORKQUEUE_RT))
> futex_wake_up(&workqueue->futex);
> }
>
> --
> 2.19.2
--
Mathieu Desnoyers
EfficiOS Inc.
http://www.efficios.com
_______________________________________________
lttng-dev mailing list
lttng-dev@lists.lttng.org
https://lists.lttng.org/cgi-bin/mailman/listinfo/lttng-dev
