417 rcu_torture_pipe_update_one(struct rcu_torture *rp)  in rcu_torture_pipe_update_one()  argument
420 	struct rcu_torture_reader_check *rtrcp = READ_ONCE(rp->rtort_chkp);  in rcu_torture_pipe_update_one()
423 		WRITE_ONCE(rp->rtort_chkp, NULL);  in rcu_torture_pipe_update_one()
426 	i = READ_ONCE(rp->rtort_pipe_count);  in rcu_torture_pipe_update_one()
430 	WRITE_ONCE(rp->rtort_pipe_count, i + 1);  in rcu_torture_pipe_update_one()
431 	if (rp->rtort_pipe_count >= RCU_TORTURE_PIPE_LEN) {  in rcu_torture_pipe_update_one()
432 		rp->rtort_mbtest = 0;  in rcu_torture_pipe_update_one()
445 	struct rcu_torture *rp;  in rcu_torture_pipe_update()  local
450 	list_for_each_entry_safe(rp, rp1, &rcu_torture_removed, rtort_free) {  in rcu_torture_pipe_update()
451 		if (rcu_torture_pipe_update_one(rp)) {  in rcu_torture_pipe_update()
452 			list_del(&rp->rtort_free);  in rcu_torture_pipe_update()
453 			rcu_torture_free(rp);  in rcu_torture_pipe_update()
461 	struct rcu_torture *rp = container_of(p, struct rcu_torture, rtort_rcu);  in rcu_torture_cb()  local
468 	if (rcu_torture_pipe_update_one(rp))  in rcu_torture_cb()
469 		rcu_torture_free(rp);  in rcu_torture_cb()
471 		cur_ops->deferred_free(rp);  in rcu_torture_cb()
609 static void srcu_torture_deferred_free(struct rcu_torture *rp)  in srcu_torture_deferred_free()  argument
611 	call_srcu(srcu_ctlp, &rp->rtort_rcu, rcu_torture_cb);  in srcu_torture_deferred_free()
1157 	struct rcu_torture *rp;  in rcu_torture_writer()  local
1181 		rp = rcu_torture_alloc();  in rcu_torture_writer()
1182 		if (rp == NULL)  in rcu_torture_writer()
1184 		rp->rtort_pipe_count = 0;  in rcu_torture_writer()
1190 		rp->rtort_mbtest = 1;  in rcu_torture_writer()
1191 		rcu_assign_pointer(rcu_torture_current, rp);  in rcu_torture_writer()