Lines Matching defs:subflow_req
40 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req);
42 pr_debug("subflow_req=%p\n", subflow_req);
44 if (subflow_req->msk)
45 sock_put((struct sock *)subflow_req->msk);
70 static void subflow_req_create_thmac(struct mptcp_subflow_request_sock *subflow_req)
72 struct mptcp_sock *msk = subflow_req->msk;
75 subflow_req->local_nonce = get_random_u32();
79 subflow_req->local_nonce,
80 subflow_req->remote_nonce, hmac);
82 subflow_req->thmac = get_unaligned_be64(hmac);
87 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req);
91 msk = mptcp_token_get_sock(sock_net(req_to_sk(req)), subflow_req->token);
102 subflow_req->local_id = local_id;
103 subflow_req->request_bkup = mptcp_pm_is_backup(msk, (struct sock_common *)req);
110 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req);
112 subflow_req->mp_capable = 0;
113 subflow_req->mp_join = 0;
114 subflow_req->csum_reqd = mptcp_is_checksum_enabled(sock_net(sk_listener));
115 subflow_req->allow_join_id0 = mptcp_allow_join_id0(sock_net(sk_listener));
116 subflow_req->msk = NULL;
152 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req);
156 pr_debug("subflow_req=%p, listener=%p\n", subflow_req, listener);
191 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq;
194 get_random_bytes(&subflow_req->local_key, sizeof(subflow_req->local_key));
195 } while (subflow_req->local_key == 0);
198 mptcp_crypto_key_sha(subflow_req->local_key,
199 &subflow_req->token,
200 &subflow_req->idsn);
201 if (mptcp_token_exists(subflow_req->token)) {
206 subflow_req->mp_capable = 1;
213 subflow_req->mp_capable = 1;
220 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq;
221 subflow_req->mp_join = 1;
222 subflow_req->backup = mp_opt.backup;
223 subflow_req->remote_id = mp_opt.join_id;
224 subflow_req->token = mp_opt.token;
225 subflow_req->remote_nonce = mp_opt.nonce;
226 subflow_req->msk = subflow_token_join_request(req);
229 if (!subflow_req->msk) {
234 if (subflow_use_different_sport(subflow_req->msk, sk_listener)) {
237 ntohs(inet_sk((struct sock *)subflow_req->msk)->inet_sport));
238 if (!mptcp_pm_sport_in_anno_list(subflow_req->msk, sk_listener)) {
246 subflow_req_create_thmac(subflow_req);
249 if (!mptcp_can_accept_new_subflow(subflow_req->msk)) {
255 subflow_init_req_cookie_join_save(subflow_req, skb);
258 pr_debug("token=%u, remote_nonce=%u msk=%p\n", subflow_req->token,
259 subflow_req->remote_nonce, subflow_req->msk);
270 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req);
287 subflow_req->local_key = mp_opt.rcvr_key;
292 subflow_req->mp_capable = 1;
293 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq - 1;
295 if (!mptcp_token_join_cookie_init_state(subflow_req, skb))
298 subflow_req->mp_join = 1;
299 subflow_req->ssn_offset = TCP_SKB_CB(skb)->seq - 1;
753 static bool subflow_hmac_valid(const struct mptcp_subflow_request_sock *subflow_req,
756 struct mptcp_sock *msk = subflow_req->msk;
761 subflow_req->remote_nonce,
762 subflow_req->local_nonce, hmac);
816 struct mptcp_subflow_request_sock *subflow_req;
831 subflow_req = mptcp_subflow_rsk(req);
832 fallback_is_fatal = tcp_rsk(req)->is_mptcp && subflow_req->mp_join;
838 if (subflow_req->mp_capable) {
852 } else if (subflow_req->mp_join) {
903 owner = subflow_req->msk;
909 if (!subflow_hmac_valid(subflow_req, &mp_opt)) {
922 subflow_req->msk = NULL;
2039 struct mptcp_subflow_request_sock *subflow_req = mptcp_subflow_rsk(req);
2044 (!subflow_req->mp_capable && !subflow_req->mp_join)) {
2061 if (subflow_req->mp_capable) {
2066 new_ctx->local_key = subflow_req->local_key;
2067 new_ctx->token = subflow_req->token;
2068 new_ctx->ssn_offset = subflow_req->ssn_offset;
2069 new_ctx->idsn = subflow_req->idsn;
2073 } else if (subflow_req->mp_join) {
2074 new_ctx->ssn_offset = subflow_req->ssn_offset;
2078 new_ctx->backup = subflow_req->backup;
2079 new_ctx->request_bkup = subflow_req->request_bkup;
2080 WRITE_ONCE(new_ctx->remote_id, subflow_req->remote_id);
2081 new_ctx->token = subflow_req->token;
2082 new_ctx->thmac = subflow_req->thmac;
2087 subflow_set_local_id(new_ctx, subflow_req->local_id);