Lines Matching refs:msk
45 if (subflow_req->msk) in subflow_req_destructor()
46 sock_put((struct sock *)subflow_req->msk); in subflow_req_destructor()
62 static bool mptcp_can_accept_new_subflow(const struct mptcp_sock *msk) in mptcp_can_accept_new_subflow() argument
64 return mptcp_is_fully_established((void *)msk) && in mptcp_can_accept_new_subflow()
65 ((mptcp_pm_is_userspace(msk) && in mptcp_can_accept_new_subflow()
66 mptcp_userspace_pm_active(msk)) || in mptcp_can_accept_new_subflow()
67 READ_ONCE(msk->pm.accept_subflow)); in mptcp_can_accept_new_subflow()
73 struct mptcp_sock *msk = subflow_req->msk; in subflow_req_create_thmac() local
78 subflow_generate_hmac(msk->local_key, msk->remote_key, in subflow_req_create_thmac()
88 struct mptcp_sock *msk; in subflow_token_join_request() local
91 msk = mptcp_token_get_sock(sock_net(req_to_sk(req)), subflow_req->token); in subflow_token_join_request()
92 if (!msk) { in subflow_token_join_request()
97 local_id = mptcp_pm_get_local_id(msk, (struct sock_common *)req); in subflow_token_join_request()
99 sock_put((struct sock *)msk); in subflow_token_join_request()
103 subflow_req->request_bkup = mptcp_pm_is_backup(msk, (struct sock_common *)req); in subflow_token_join_request()
105 return msk; in subflow_token_join_request()
116 subflow_req->msk = NULL; in subflow_init_req()
120 static bool subflow_use_different_sport(struct mptcp_sock *msk, const struct sock *sk) in subflow_use_different_sport() argument
122 return inet_sk(sk)->inet_sport != inet_sk((struct sock *)msk)->inet_sport; in subflow_use_different_sport()
224 subflow_req->msk = subflow_token_join_request(req); in subflow_check_req()
227 if (!subflow_req->msk) { in subflow_check_req()
232 if (subflow_use_different_sport(subflow_req->msk, sk_listener)) { in subflow_check_req()
235 ntohs(inet_sk((struct sock *)subflow_req->msk)->inet_sport)); in subflow_check_req()
236 if (!mptcp_pm_sport_in_anno_list(subflow_req->msk, sk_listener)) { in subflow_check_req()
246 if (mptcp_can_accept_new_subflow(subflow_req->msk)) in subflow_check_req()
253 subflow_req->remote_nonce, subflow_req->msk); in subflow_check_req()
432 static bool subflow_use_different_dport(struct mptcp_sock *msk, const struct sock *sk) in subflow_use_different_dport() argument
434 return inet_sk(sk)->inet_dport != inet_sk((struct sock *)msk)->inet_dport; in subflow_use_different_dport()
440 struct mptcp_sock *msk = mptcp_sk(sk); in __mptcp_sync_state() local
441 struct sock *ssk = msk->first; in __mptcp_sync_state()
445 if (!msk->rcvspace_init) in __mptcp_sync_state()
446 mptcp_rcv_space_init(msk, ssk); in __mptcp_sync_state()
452 WRITE_ONCE(msk->write_seq, subflow->idsn + 1); in __mptcp_sync_state()
453 WRITE_ONCE(msk->snd_nxt, msk->write_seq); in __mptcp_sync_state()
459 static void subflow_set_remote_key(struct mptcp_sock *msk, in subflow_set_remote_key() argument
474 WRITE_ONCE(msk->remote_key, subflow->remote_key); in subflow_set_remote_key()
475 WRITE_ONCE(msk->ack_seq, subflow->iasn); in subflow_set_remote_key()
476 WRITE_ONCE(msk->can_ack, true); in subflow_set_remote_key()
477 atomic64_set(&msk->rcv_wnd_sent, subflow->iasn); in subflow_set_remote_key()
484 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_propagate_state() local
491 WRITE_ONCE(msk->snd_una, subflow->idsn + 1); in mptcp_propagate_state()
492 WRITE_ONCE(msk->wnd_end, subflow->idsn + 1 + tcp_sk(ssk)->snd_wnd); in mptcp_propagate_state()
493 subflow_set_remote_key(msk, subflow, mp_opt); in mptcp_propagate_state()
499 msk->pending_state = ssk->sk_state; in mptcp_propagate_state()
500 __set_bit(MPTCP_SYNC_STATE, &msk->cb_flags); in mptcp_propagate_state()
510 struct mptcp_sock *msk; in subflow_finish_connect() local
518 msk = mptcp_sk(parent); in subflow_finish_connect()
530 pr_fallback(msk); in subflow_finish_connect()
535 WRITE_ONCE(msk->csum_enabled, true); in subflow_finish_connect()
537 WRITE_ONCE(msk->pm.remote_deny_join_id0, true); in subflow_finish_connect()
579 if (subflow_use_different_dport(msk, sk)) { in subflow_finish_connect()
605 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in subflow_chk_local_id() local
611 err = mptcp_pm_get_local_id(msk, (struct sock_common *)sk); in subflow_chk_local_id()
616 subflow->request_bkup = mptcp_pm_is_backup(msk, (struct sock_common *)sk); in subflow_chk_local_id()
730 struct mptcp_sock *msk; in subflow_hmac_valid() local
733 msk = subflow_req->msk; in subflow_hmac_valid()
734 if (!msk) in subflow_hmac_valid()
737 subflow_generate_hmac(msk->remote_key, msk->local_key, in subflow_hmac_valid()
774 void __mptcp_subflow_fully_established(struct mptcp_sock *msk, in __mptcp_subflow_fully_established() argument
778 subflow_set_remote_key(msk, subflow, mp_opt); in __mptcp_subflow_fully_established()
780 WRITE_ONCE(msk->fully_established, true); in __mptcp_subflow_fully_established()
783 __mptcp_fastopen_gen_msk_ackseq(msk, subflow, mp_opt); in __mptcp_subflow_fully_established()
833 !mptcp_can_accept_new_subflow(subflow_req->msk)) { in subflow_syn_recv_sock()
880 owner = subflow_req->msk; in subflow_syn_recv_sock()
887 subflow_req->msk = NULL; in subflow_syn_recv_sock()
1068 struct mptcp_sock *msk) in get_mapping_status() argument
1071 bool csum_reqd = READ_ONCE(msk->csum_enabled); in get_mapping_status()
1117 bool updated = mptcp_update_rcv_data_fin(msk, mpext->data_seq, in get_mapping_status()
1130 mptcp_schedule_work((struct sock *)msk); in get_mapping_status()
1143 mptcp_update_rcv_data_fin(msk, data_fin_seq, mpext->dsn64); in get_mapping_status()
1152 map_seq = mptcp_expand_seq(READ_ONCE(msk->ack_seq), mpext->data_seq, mpext->dsn64); in get_mapping_status()
1239 static void subflow_sched_work_if_closed(struct mptcp_sock *msk, struct sock *ssk) in subflow_sched_work_if_closed() argument
1241 struct sock *sk = (struct sock *)msk; in subflow_sched_work_if_closed()
1249 !test_and_set_bit(MPTCP_WORK_CLOSE_SUBFLOW, &msk->flags)) in subflow_sched_work_if_closed()
1253 static void mptcp_subflow_fail(struct mptcp_sock *msk, struct sock *ssk) in mptcp_subflow_fail() argument
1259 if (WARN_ON_ONCE(ssk != READ_ONCE(msk->first))) in mptcp_subflow_fail()
1265 if (sock_flag((struct sock *)msk, SOCK_DEAD)) in mptcp_subflow_fail()
1277 mptcp_reset_tout_timer(msk, subflow->fail_tout); in mptcp_subflow_fail()
1284 struct mptcp_sock *msk; in subflow_check_data_avail() local
1292 msk = mptcp_sk(subflow->conn); in subflow_check_data_avail()
1297 status = get_mapping_status(ssk, msk); in subflow_check_data_avail()
1310 if (unlikely(!READ_ONCE(msk->can_ack))) in subflow_check_data_avail()
1313 old_ack = READ_ONCE(msk->ack_seq); in subflow_check_data_avail()
1328 subflow_sched_work_if_closed(msk, ssk); in subflow_check_data_avail()
1332 if (!__mptcp_check_fallback(msk)) { in subflow_check_data_avail()
1338 if (!READ_ONCE(msk->allow_infinite_fallback)) { in subflow_check_data_avail()
1343 mptcp_subflow_fail(msk, ssk); in subflow_check_data_avail()
1348 if (!READ_ONCE(msk->allow_infinite_fallback)) { in subflow_check_data_avail()
1370 subflow->map_seq = READ_ONCE(msk->ack_seq); in subflow_check_data_avail()
1437 struct mptcp_sock *msk; in subflow_data_ready() local
1441 msk = mptcp_sk(parent); in subflow_data_ready()
1453 WARN_ON_ONCE(!__mptcp_check_fallback(msk) && !subflow->mp_capable && in subflow_data_ready()
1462 if (mptcp_data_avail(msk) < parent->sk_rcvlowat && in subflow_data_ready()
1542 struct mptcp_sock *msk = mptcp_sk(sk); in __mptcp_subflow_connect() local
1571 mptcp_pm_get_flags_and_ifindex_by_id(msk, local_id, in __mptcp_subflow_connect()
1574 subflow->remote_key = msk->remote_key; in __mptcp_subflow_connect()
1575 subflow->local_key = msk->local_key; in __mptcp_subflow_connect()
1576 subflow->token = msk->token; in __mptcp_subflow_connect()
1584 mptcp_sockopt_sync(msk, ssk); in __mptcp_subflow_connect()
1592 pr_debug("msk=%p remote_token=%u local_id=%d remote_id=%d\n", msk, in __mptcp_subflow_connect()
1598 subflow->subflow_id = msk->subflow_id++; in __mptcp_subflow_connect()
1602 list_add_tail(&subflow->node, &msk->conn_list); in __mptcp_subflow_connect()
1610 WRITE_ONCE(msk->allow_infinite_fallback, false); in __mptcp_subflow_connect()
1626 mptcp_pm_close_subflow(msk); in __mptcp_subflow_connect()
1782 struct mptcp_sock *msk; in subflow_state_change() local
1786 msk = mptcp_sk(parent); in subflow_state_change()
1789 pr_fallback(msk); in subflow_state_change()
1808 if (__mptcp_check_fallback(msk) && subflow_is_done(sk) && msk->first == sk && in subflow_state_change()
1809 mptcp_update_rcv_data_fin(msk, READ_ONCE(msk->ack_seq), true)) in subflow_state_change()