Lines Matching refs:subflow_req
40 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req); in subflow_req_destructor() local
42 pr_debug("subflow_req=%p", subflow_req); in subflow_req_destructor()
44 if (subflow_req->msk) in subflow_req_destructor()
45 sock_put((struct sock *)subflow_req->msk); in subflow_req_destructor()
69 static void subflow_req_create_thmac(struct mptcp_subflow_request_sock *subflow_req) in subflow_req_create_thmac() argument
71 struct mptcp_sock *msk = subflow_req->msk; in subflow_req_create_thmac()
74 get_random_bytes(&subflow_req->local_nonce, sizeof(u32)); in subflow_req_create_thmac()
77 subflow_req->local_nonce, in subflow_req_create_thmac()
78 subflow_req->remote_nonce, hmac); in subflow_req_create_thmac()
80 subflow_req->thmac = get_unaligned_be64(hmac); in subflow_req_create_thmac()
85 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req); in subflow_token_join_request() local
89 msk = mptcp_token_get_sock(sock_net(req_to_sk(req)), subflow_req->token); in subflow_token_join_request()
100 subflow_req->local_id = local_id; in subflow_token_join_request()
107 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req); in subflow_init_req() local
109 subflow_req->mp_capable = 0; in subflow_init_req()
110 subflow_req->mp_join = 0; in subflow_init_req()
111 subflow_req->csum_reqd = mptcp_is_checksum_enabled(sock_net(sk_listener)); in subflow_init_req()
112 subflow_req->allow_join_id0 = mptcp_allow_join_id0(sock_net(sk_listener)); in subflow_init_req()
113 subflow_req->msk = NULL; in subflow_init_req()
142 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req); in subflow_check_req() local
146 pr_debug("subflow_req=%p, listener=%p", subflow_req, listener); in subflow_check_req()
172 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq; in subflow_check_req()
175 get_random_bytes(&subflow_req->local_key, sizeof(subflow_req->local_key)); in subflow_check_req()
176 } while (subflow_req->local_key == 0); in subflow_check_req()
179 mptcp_crypto_key_sha(subflow_req->local_key, in subflow_check_req()
180 &subflow_req->token, in subflow_check_req()
181 &subflow_req->idsn); in subflow_check_req()
182 if (mptcp_token_exists(subflow_req->token)) { in subflow_check_req()
187 subflow_req->mp_capable = 1; in subflow_check_req()
194 subflow_req->mp_capable = 1; in subflow_check_req()
201 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq; in subflow_check_req()
202 subflow_req->mp_join = 1; in subflow_check_req()
203 subflow_req->backup = mp_opt.backup; in subflow_check_req()
204 subflow_req->remote_id = mp_opt.join_id; in subflow_check_req()
205 subflow_req->token = mp_opt.token; in subflow_check_req()
206 subflow_req->remote_nonce = mp_opt.nonce; in subflow_check_req()
207 subflow_req->msk = subflow_token_join_request(req); in subflow_check_req()
210 if (!subflow_req->msk) { in subflow_check_req()
215 if (subflow_use_different_sport(subflow_req->msk, sk_listener)) { in subflow_check_req()
218 ntohs(inet_sk((struct sock *)subflow_req->msk)->inet_sport)); in subflow_check_req()
219 if (!mptcp_pm_sport_in_anno_list(subflow_req->msk, sk_listener)) { in subflow_check_req()
226 subflow_req_create_thmac(subflow_req); in subflow_check_req()
229 if (mptcp_can_accept_new_subflow(subflow_req->msk)) in subflow_check_req()
230 subflow_init_req_cookie_join_save(subflow_req, skb); in subflow_check_req()
235 pr_debug("token=%u, remote_nonce=%u msk=%p", subflow_req->token, in subflow_check_req()
236 subflow_req->remote_nonce, subflow_req->msk); in subflow_check_req()
247 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req); in mptcp_subflow_init_cookie_req() local
264 subflow_req->local_key = mp_opt.rcvr_key; in mptcp_subflow_init_cookie_req()
269 subflow_req->mp_capable = 1; in mptcp_subflow_init_cookie_req()
270 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq - 1; in mptcp_subflow_init_cookie_req()
272 if (!mptcp_token_join_cookie_init_state(subflow_req, skb)) in mptcp_subflow_init_cookie_req()
275 subflow_req->mp_join = 1; in mptcp_subflow_init_cookie_req()
276 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq - 1; in mptcp_subflow_init_cookie_req()
544 const struct mptcp_subflow_request_sock *subflow_req; in subflow_hmac_valid() local
548 subflow_req = mptcp_subflow_rsk(req); in subflow_hmac_valid()
549 msk = subflow_req->msk; in subflow_hmac_valid()
554 subflow_req->remote_nonce, in subflow_hmac_valid()
555 subflow_req->local_nonce, hmac); in subflow_hmac_valid()
636 struct mptcp_subflow_request_sock *subflow_req; in subflow_syn_recv_sock() local
650 subflow_req = mptcp_subflow_rsk(req); in subflow_syn_recv_sock()
651 fallback_is_fatal = tcp_rsk(req)->is_mptcp && subflow_req->mp_join; in subflow_syn_recv_sock()
657 if (subflow_req->mp_capable) { in subflow_syn_recv_sock()
675 } else if (subflow_req->mp_join) { in subflow_syn_recv_sock()
679 !mptcp_can_accept_new_subflow(subflow_req->msk)) { in subflow_syn_recv_sock()
728 mptcp_token_accept(subflow_req, mptcp_sk(new_msk)); in subflow_syn_recv_sock()
740 owner = subflow_req->msk; in subflow_syn_recv_sock()
747 subflow_req->msk = NULL; in subflow_syn_recv_sock()
1706 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req); in subflow_ulp_clone() local
1711 (!subflow_req->mp_capable && !subflow_req->mp_join)) { in subflow_ulp_clone()
1731 if (subflow_req->mp_capable) { in subflow_ulp_clone()
1736 new_ctx->local_key = subflow_req->local_key; in subflow_ulp_clone()
1737 new_ctx->token = subflow_req->token; in subflow_ulp_clone()
1738 new_ctx->ssn_offset = subflow_req->ssn_offset; in subflow_ulp_clone()
1739 new_ctx->idsn = subflow_req->idsn; in subflow_ulp_clone()
1740 } else if (subflow_req->mp_join) { in subflow_ulp_clone()
1741 new_ctx->ssn_offset = subflow_req->ssn_offset; in subflow_ulp_clone()
1744 new_ctx->backup = subflow_req->backup; in subflow_ulp_clone()
1745 new_ctx->local_id = subflow_req->local_id; in subflow_ulp_clone()
1746 new_ctx->remote_id = subflow_req->remote_id; in subflow_ulp_clone()
1747 new_ctx->token = subflow_req->token; in subflow_ulp_clone()
1748 new_ctx->thmac = subflow_req->thmac; in subflow_ulp_clone()