69 static int mptcp_cancel_urgency_timer(struct mptses *mpte);
72 mptcp_timer_demux(struct mptses *mpte, uint64_t now_msecs)  in mptcp_timer_demux()  argument
75 	mp_tp = mpte->mpte_mptcb;  in mptcp_timer_demux()
78 	DTRACE_MPTCP2(timer, struct mptses *, mpte, struct mptcb *, mp_tp);  in mptcp_timer_demux()
101 				mptcp_output(mpte);  in mptcp_timer_demux()
144 		struct mptses *mpte;  in mptcp_timer()  local
147 		mpte = mptompte(mpp);  in mptcp_timer()
152 		if (mptcp_timer_demux(mpte, now_msecs)) {  in mptcp_timer()
162 mptcp_start_timer(struct mptses *mpte, int timer_type)  in mptcp_start_timer()  argument
165 	struct mptcb *mp_tp = mpte->mpte_mptcb;  in mptcp_start_timer()
171 	socket_lock_assert_owned(mptetoso(mpte));  in mptcp_start_timer()
220 	struct mptses *mpte = mp_tp->mpt_mpte;  in mptcp_cancel_all_timers()  local
222 	mptcp_cancel_urgency_timer(mpte);  in mptcp_cancel_all_timers()
232 	struct mptses *mpte = (struct mptses *)param0;  in mptcp_urgency_timer()  local
233 	struct socket *mp_so = mptetoso(mpte);  in mptcp_urgency_timer()
242 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), mpte->mpte_time_target, time_now, mp_so->so_use…  in mptcp_urgency_timer()
244 	mptcp_check_subflows_and_add(mpte);  in mptcp_urgency_timer()
254 	struct mptses *mpte = (struct mptses *)param0;  in mptcp_urgency_stop()  local
255 	struct socket *mp_so = mptetoso(mpte);  in mptcp_urgency_stop()
262 	    __func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), mp_so->so_usecount);  in mptcp_urgency_stop()
264 	mptcp_check_subflows_and_remove(mpte);  in mptcp_urgency_stop()
272 mptcp_init_urgency_timer(struct mptses *mpte)  in mptcp_init_urgency_timer()  argument
275 	mpte->mpte_time_thread = thread_call_allocate(mptcp_urgency_timer, mpte);  in mptcp_init_urgency_timer()
276 	mpte->mpte_stop_urgency = thread_call_allocate(mptcp_urgency_stop, mpte);  in mptcp_init_urgency_timer()
280 mptcp_set_urgency_timer(struct mptses *mpte)  in mptcp_set_urgency_timer()  argument
282 	struct socket *mp_so = mptetoso(mpte);  in mptcp_set_urgency_timer()
290 	if (mpte->mpte_time_target == 0) {  in mptcp_set_urgency_timer()
293 		ret = thread_call_enter(mpte->mpte_stop_urgency);  in mptcp_set_urgency_timer()
304 	if ((int64_t)(mpte->mpte_time_target - time_now) > 0) {  in mptcp_set_urgency_timer()
305 		ret = thread_call_enter(mpte->mpte_stop_urgency);  in mptcp_set_urgency_timer()
311 		ret = thread_call_enter_delayed_with_leeway(mpte->mpte_time_thread, NULL,  in mptcp_set_urgency_timer()
312 		    mpte->mpte_time_target, 0, THREAD_CALL_CONTINUOUS);  in mptcp_set_urgency_timer()
317 	} else if ((int64_t)(mpte->mpte_time_target - time_now) <= 0) {  in mptcp_set_urgency_timer()
319 		ret = thread_call_enter(mpte->mpte_time_thread);  in mptcp_set_urgency_timer()
328 	    __func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), mpte->mpte_time_target, time_now,  in mptcp_set_urgency_timer()
333 mptcp_cancel_urgency_timer(struct mptses *mpte)  in mptcp_cancel_urgency_timer()  argument
335 	struct socket *mp_so = mptetoso(mpte);  in mptcp_cancel_urgency_timer()
338 	ret = thread_call_cancel(mpte->mpte_time_thread);  in mptcp_cancel_urgency_timer()
341 	    __func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), mp_so->so_usecount, ret);  in mptcp_cancel_urgency_timer()
343 	mptcp_check_subflows_and_remove(mpte);  in mptcp_cancel_urgency_timer()
350 	ret = thread_call_cancel(mpte->mpte_stop_urgency);  in mptcp_cancel_urgency_timer()