Lines Matching refs:msk
15 int mptcp_pm_announce_addr(struct mptcp_sock *msk, in mptcp_pm_announce_addr() argument
19 pr_debug("msk=%p, local_id=%d", msk, addr->id); in mptcp_pm_announce_addr()
21 msk->pm.local = *addr; in mptcp_pm_announce_addr()
22 WRITE_ONCE(msk->pm.add_addr_echo, echo); in mptcp_pm_announce_addr()
23 WRITE_ONCE(msk->pm.add_addr_signal, true); in mptcp_pm_announce_addr()
27 int mptcp_pm_remove_addr(struct mptcp_sock *msk, u8 local_id) in mptcp_pm_remove_addr() argument
29 pr_debug("msk=%p, local_id=%d", msk, local_id); in mptcp_pm_remove_addr()
31 msk->pm.rm_id = local_id; in mptcp_pm_remove_addr()
32 WRITE_ONCE(msk->pm.rm_addr_signal, true); in mptcp_pm_remove_addr()
36 int mptcp_pm_remove_subflow(struct mptcp_sock *msk, u8 local_id) in mptcp_pm_remove_subflow() argument
38 pr_debug("msk=%p, local_id=%d", msk, local_id); in mptcp_pm_remove_subflow()
40 spin_lock_bh(&msk->pm.lock); in mptcp_pm_remove_subflow()
41 mptcp_pm_nl_rm_subflow_received(msk, local_id); in mptcp_pm_remove_subflow()
42 spin_unlock_bh(&msk->pm.lock); in mptcp_pm_remove_subflow()
48 void mptcp_pm_new_connection(struct mptcp_sock *msk, int server_side) in mptcp_pm_new_connection() argument
50 struct mptcp_pm_data *pm = &msk->pm; in mptcp_pm_new_connection()
52 pr_debug("msk=%p, token=%u side=%d", msk, msk->token, server_side); in mptcp_pm_new_connection()
57 bool mptcp_pm_allow_new_subflow(struct mptcp_sock *msk) in mptcp_pm_allow_new_subflow() argument
59 struct mptcp_pm_data *pm = &msk->pm; in mptcp_pm_allow_new_subflow()
62 pr_debug("msk=%p subflows=%d max=%d allow=%d", msk, pm->subflows, in mptcp_pm_allow_new_subflow()
83 static bool mptcp_pm_schedule_work(struct mptcp_sock *msk, in mptcp_pm_schedule_work() argument
86 pr_debug("msk=%p status=%x new=%lx", msk, msk->pm.status, in mptcp_pm_schedule_work()
88 if (msk->pm.status & BIT(new_status)) in mptcp_pm_schedule_work()
91 msk->pm.status |= BIT(new_status); in mptcp_pm_schedule_work()
92 if (schedule_work(&msk->work)) in mptcp_pm_schedule_work()
93 sock_hold((struct sock *)msk); in mptcp_pm_schedule_work()
97 void mptcp_pm_fully_established(struct mptcp_sock *msk) in mptcp_pm_fully_established() argument
99 struct mptcp_pm_data *pm = &msk->pm; in mptcp_pm_fully_established()
101 pr_debug("msk=%p", msk); in mptcp_pm_fully_established()
110 mptcp_pm_schedule_work(msk, MPTCP_PM_ESTABLISHED); in mptcp_pm_fully_established()
115 void mptcp_pm_connection_closed(struct mptcp_sock *msk) in mptcp_pm_connection_closed() argument
117 pr_debug("msk=%p", msk); in mptcp_pm_connection_closed()
120 void mptcp_pm_subflow_established(struct mptcp_sock *msk, in mptcp_pm_subflow_established() argument
123 struct mptcp_pm_data *pm = &msk->pm; in mptcp_pm_subflow_established()
125 pr_debug("msk=%p", msk); in mptcp_pm_subflow_established()
133 mptcp_pm_schedule_work(msk, MPTCP_PM_SUBFLOW_ESTABLISHED); in mptcp_pm_subflow_established()
138 void mptcp_pm_subflow_closed(struct mptcp_sock *msk, u8 id) in mptcp_pm_subflow_closed() argument
140 pr_debug("msk=%p", msk); in mptcp_pm_subflow_closed()
143 void mptcp_pm_add_addr_received(struct mptcp_sock *msk, in mptcp_pm_add_addr_received() argument
146 struct mptcp_pm_data *pm = &msk->pm; in mptcp_pm_add_addr_received()
148 pr_debug("msk=%p remote_id=%d accept=%d", msk, addr->id, in mptcp_pm_add_addr_received()
154 mptcp_pm_announce_addr(msk, addr, true); in mptcp_pm_add_addr_received()
155 else if (mptcp_pm_schedule_work(msk, MPTCP_PM_ADD_ADDR_RECEIVED)) in mptcp_pm_add_addr_received()
161 void mptcp_pm_rm_addr_received(struct mptcp_sock *msk, u8 rm_id) in mptcp_pm_rm_addr_received() argument
163 struct mptcp_pm_data *pm = &msk->pm; in mptcp_pm_rm_addr_received()
165 pr_debug("msk=%p remote_id=%d", msk, rm_id); in mptcp_pm_rm_addr_received()
168 mptcp_pm_schedule_work(msk, MPTCP_PM_RM_ADDR_RECEIVED); in mptcp_pm_rm_addr_received()
175 bool mptcp_pm_add_addr_signal(struct mptcp_sock *msk, unsigned int remaining, in mptcp_pm_add_addr_signal() argument
180 spin_lock_bh(&msk->pm.lock); in mptcp_pm_add_addr_signal()
183 if (!mptcp_pm_should_add_signal(msk)) in mptcp_pm_add_addr_signal()
186 *echo = READ_ONCE(msk->pm.add_addr_echo); in mptcp_pm_add_addr_signal()
188 if (remaining < mptcp_add_addr_len(msk->pm.local.family, *echo)) in mptcp_pm_add_addr_signal()
191 *saddr = msk->pm.local; in mptcp_pm_add_addr_signal()
192 WRITE_ONCE(msk->pm.add_addr_signal, false); in mptcp_pm_add_addr_signal()
196 spin_unlock_bh(&msk->pm.lock); in mptcp_pm_add_addr_signal()
200 bool mptcp_pm_rm_addr_signal(struct mptcp_sock *msk, unsigned int remaining, in mptcp_pm_rm_addr_signal() argument
205 spin_lock_bh(&msk->pm.lock); in mptcp_pm_rm_addr_signal()
208 if (!mptcp_pm_should_rm_signal(msk)) in mptcp_pm_rm_addr_signal()
214 *rm_id = msk->pm.rm_id; in mptcp_pm_rm_addr_signal()
215 WRITE_ONCE(msk->pm.rm_addr_signal, false); in mptcp_pm_rm_addr_signal()
219 spin_unlock_bh(&msk->pm.lock); in mptcp_pm_rm_addr_signal()
223 int mptcp_pm_get_local_id(struct mptcp_sock *msk, struct sock_common *skc) in mptcp_pm_get_local_id() argument
225 return mptcp_pm_nl_get_local_id(msk, skc); in mptcp_pm_get_local_id()
228 void mptcp_pm_data_init(struct mptcp_sock *msk) in mptcp_pm_data_init() argument
230 msk->pm.add_addr_signaled = 0; in mptcp_pm_data_init()
231 msk->pm.add_addr_accepted = 0; in mptcp_pm_data_init()
232 msk->pm.local_addr_used = 0; in mptcp_pm_data_init()
233 msk->pm.subflows = 0; in mptcp_pm_data_init()
234 msk->pm.rm_id = 0; in mptcp_pm_data_init()
235 WRITE_ONCE(msk->pm.work_pending, false); in mptcp_pm_data_init()
236 WRITE_ONCE(msk->pm.add_addr_signal, false); in mptcp_pm_data_init()
237 WRITE_ONCE(msk->pm.rm_addr_signal, false); in mptcp_pm_data_init()
238 WRITE_ONCE(msk->pm.accept_addr, false); in mptcp_pm_data_init()
239 WRITE_ONCE(msk->pm.accept_subflow, false); in mptcp_pm_data_init()
240 WRITE_ONCE(msk->pm.add_addr_echo, false); in mptcp_pm_data_init()
241 msk->pm.status = 0; in mptcp_pm_data_init()
243 spin_lock_init(&msk->pm.lock); in mptcp_pm_data_init()
244 INIT_LIST_HEAD(&msk->pm.anno_list); in mptcp_pm_data_init()
246 mptcp_pm_nl_data_init(msk); in mptcp_pm_data_init()