bsd/netinet/mptcp.c

465 mptcp_data_ack_rcvd(struct mptcb *mp_tp, struct tcpcb *tp, u_int64_t full_dack)
477 		tp->t_mpflags &= ~TMPF_SEND_DFIN;
483 mptcp_update_dss_rcv_state(struct mptcp_dsn_opt *dss_info, struct tcpcb *tp,
486 	struct mptcb *mp_tp = tptomptp(tp);
497 	mptcp_update_rcv_state_meat(mp_tp, tp,
504 mptcp_update_rcv_state_meat(struct mptcb *mp_tp, struct tcpcb *tp,
515 		mptcp_notify_mpfail(tp->t_inpcb->inp_socket);
532 	mptcp_notify_mpready(tp->t_inpcb->inp_socket);
533 	tp->t_rcv_map.mpt_dsn = full_dsn;
534 	tp->t_rcv_map.mpt_sseq = seqn;
535 	tp->t_rcv_map.mpt_len = mdss_data_len;
536 	tp->t_rcv_map.mpt_csum = csum;
537 	tp->t_mpflags |= TMPF_EMBED_DSN;
542 mptcp_update_rcv_state_f(struct mptcp_dss_ack_opt *dss_info, struct tcpcb *tp,
546 	struct mptcb *mp_tp = tptomptp(tp);
554 	mptcp_update_rcv_state_meat(mp_tp, tp,
563     struct tcpcb *tp, uint16_t csum)
566 	struct mptcb *mp_tp = tptomptp(tp);
570 	mptcp_update_rcv_state_meat(mp_tp, tp,
586 mptcp_input_csum(struct tcpcb *tp, struct mbuf *m, int off)
588 	struct mptcb *mp_tp = tptomptp(tp);
601 	if (!(tp->t_mpflags & TMPF_EMBED_DSN))
604 	if (tp->t_mpflags & TMPF_TCP_FALLBACK)
611 	if ((int)m_length2(m, NULL) < (off + tp->t_rcv_map.mpt_len))
614 	if (tp->t_rcv_map.mpt_len != 0)
615 		sum = m_sum16(m, off, tp->t_rcv_map.mpt_len);
617 	dsn = mptcp_hton64(tp->t_rcv_map.mpt_dsn);
618 	sseq = htonl(tp->t_rcv_map.mpt_sseq);
619 	len = htons(tp->t_rcv_map.mpt_len);
620 	csum = tp->t_rcv_map.mpt_csum;
623 	DTRACE_MPTCP3(checksum__result, struct tcpcb *, tp, struct mbuf *, m,
630 mptcp_output_csum(struct tcpcb *tp, struct mbuf *m, int32_t len,
633 	struct mptcb *mp_tp = tptomptp(tp);
661 	DTRACE_MPTCP3(checksum__result, struct tcpcb *, tp, struct mbuf *, m,