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