Lines Matching refs:msk
245 struct mptcp_sock *msk = mptcp_sk(sk);
247 if (list_empty(&msk->rtx_queue))
250 return list_last_entry(&msk->rtx_queue, struct mptcp_data_frag, list);
255 struct mptcp_sock *msk = mptcp_sk(sk);
257 return list_first_entry_or_null(&msk->rtx_queue, struct mptcp_data_frag, list);
274 struct mptcp_sock *msk;
407 void mptcp_rcv_space_init(struct mptcp_sock *msk, const struct sock *ssk);
412 bool mptcp_update_rcv_data_fin(struct mptcp_sock *msk, u64 data_fin_seq, bool use_64bit);
413 void mptcp_destroy_common(struct mptcp_sock *msk);
425 struct mptcp_sock *msk);
430 void mptcp_token_destroy(struct mptcp_sock *msk);
437 void mptcp_pm_data_init(struct mptcp_sock *msk);
438 void mptcp_pm_new_connection(struct mptcp_sock *msk, int server_side);
439 void mptcp_pm_fully_established(struct mptcp_sock *msk);
440 bool mptcp_pm_allow_new_subflow(struct mptcp_sock *msk);
441 void mptcp_pm_connection_closed(struct mptcp_sock *msk);
442 void mptcp_pm_subflow_established(struct mptcp_sock *msk,
444 void mptcp_pm_subflow_closed(struct mptcp_sock *msk, u8 id);
445 void mptcp_pm_add_addr_received(struct mptcp_sock *msk,
447 void mptcp_pm_rm_addr_received(struct mptcp_sock *msk, u8 rm_id);
448 void mptcp_pm_free_anno_list(struct mptcp_sock *msk);
450 mptcp_pm_del_add_timer(struct mptcp_sock *msk,
453 int mptcp_pm_announce_addr(struct mptcp_sock *msk,
456 int mptcp_pm_remove_addr(struct mptcp_sock *msk, u8 local_id);
457 int mptcp_pm_remove_subflow(struct mptcp_sock *msk, u8 local_id);
459 static inline bool mptcp_pm_should_add_signal(struct mptcp_sock *msk)
461 return READ_ONCE(msk->pm.add_addr_signal);
464 static inline bool mptcp_pm_should_rm_signal(struct mptcp_sock *msk)
466 return READ_ONCE(msk->pm.rm_addr_signal);
477 bool mptcp_pm_add_addr_signal(struct mptcp_sock *msk, unsigned int remaining,
479 bool mptcp_pm_rm_addr_signal(struct mptcp_sock *msk, unsigned int remaining,
481 int mptcp_pm_get_local_id(struct mptcp_sock *msk, struct sock_common *skc);
484 void mptcp_pm_nl_data_init(struct mptcp_sock *msk);
485 void mptcp_pm_nl_fully_established(struct mptcp_sock *msk);
486 void mptcp_pm_nl_subflow_established(struct mptcp_sock *msk);
487 void mptcp_pm_nl_add_addr_received(struct mptcp_sock *msk);
488 void mptcp_pm_nl_rm_addr_received(struct mptcp_sock *msk);
489 void mptcp_pm_nl_rm_subflow_received(struct mptcp_sock *msk, u8 rm_id);
490 int mptcp_pm_nl_get_local_id(struct mptcp_sock *msk, struct sock_common *skc);
506 static inline bool __mptcp_check_fallback(const struct mptcp_sock *msk)
508 return test_bit(MPTCP_FALLBACK_DONE, &msk->flags);
514 struct mptcp_sock *msk = mptcp_sk(subflow->conn);
516 return __mptcp_check_fallback(msk);
519 static inline void __mptcp_do_fallback(struct mptcp_sock *msk)
521 if (test_bit(MPTCP_FALLBACK_DONE, &msk->flags)) {
522 pr_debug("TCP fallback already done (msk=%p)", msk);
525 set_bit(MPTCP_FALLBACK_DONE, &msk->flags);
531 struct mptcp_sock *msk = mptcp_sk(subflow->conn);
533 __mptcp_do_fallback(msk);
536 #define pr_fallback(a) pr_debug("%s:fallback to TCP (msk=%p)", __func__, a)