X-Git-Url: https://git.saurik.com/apple/xnu.git/blobdiff_plain/a39ff7e25e19b3a8c3020042a3872ca9ec9659f1..bca245acd4c03fd752d1a45f011ad495e60fe53d:/bsd/netinet/mptcp_var.h diff --git a/bsd/netinet/mptcp_var.h b/bsd/netinet/mptcp_var.h index d09642033..c1063229d 100644 --- a/bsd/netinet/mptcp_var.h +++ b/bsd/netinet/mptcp_var.h @@ -27,7 +27,7 @@ */ #ifndef _NETINET_MPTCP_VAR_H_ -#define _NETINET_MPTCP_VAR_H_ +#define _NETINET_MPTCP_VAR_H_ #ifdef PRIVATE #include @@ -46,8 +46,9 @@ struct mpt_itf_info { uint32_t ifindex; uint32_t has_v4_conn:1, - has_v6_conn:1, - no_mptcp_support:1; + has_v6_conn:1, + has_nat64_conn:1, + no_mptcp_support:1; }; /* @@ -57,103 +58,110 @@ struct mpt_itf_info { * the per-PCB mpp_lock (also the socket's lock); */ struct mptses { - struct mppcb *mpte_mppcb; /* back ptr to multipath PCB */ - struct mptcb *mpte_mptcb; /* ptr to MPTCP PCB */ - TAILQ_HEAD(, mptopt) mpte_sopts; /* list of socket options */ - TAILQ_HEAD(, mptsub) mpte_subflows; /* list of subflows */ - uint16_t mpte_numflows; /* # of subflows in list */ - uint16_t mpte_nummpcapflows; /* # of MP_CAP subflows */ - sae_associd_t mpte_associd; /* MPTCP association ID */ - sae_connid_t mpte_connid_last; /* last used connection ID */ + struct mppcb *mpte_mppcb; /* back ptr to multipath PCB */ + struct mptcb *mpte_mptcb; /* ptr to MPTCP PCB */ + TAILQ_HEAD(, mptopt) mpte_sopts; /* list of socket options */ + TAILQ_HEAD(, mptsub) mpte_subflows; /* list of subflows */ +#define MPTCP_MAX_NUM_SUBFLOWS 256 + uint16_t mpte_numflows; /* # of subflows in list */ + uint16_t mpte_nummpcapflows; /* # of MP_CAP subflows */ + sae_associd_t mpte_associd; /* MPTCP association ID */ + sae_connid_t mpte_connid_last; /* last used connection ID */ + + uint64_t mpte_time_target; + thread_call_t mpte_time_thread; + + uint32_t mpte_last_cellicon_set; + uint32_t mpte_cellicon_increments; union { /* Source address of initial subflow */ - struct sockaddr mpte_src; - struct sockaddr_in __mpte_src_v4; - struct sockaddr_in6 __mpte_src_v6; - }; - + struct sockaddr _mpte_src; + struct sockaddr_in _mpte_src_v4; + struct sockaddr_in6 _mpte_src_v6; + } mpte_u_src; +#define mpte_src mpte_u_src._mpte_src +#define __mpte_src_v4 mpte_u_src._mpte_src_v4 +#define __mpte_src_v6 mpte_u_src._mpte_src_v6 union { /* Destination address of initial subflow */ - struct sockaddr mpte_dst; - struct sockaddr_in __mpte_dst_v4; - struct sockaddr_in6 __mpte_dst_v6; - }; + struct sockaddr _mpte_dst; + struct sockaddr_in _mpte_dst_v4; + struct sockaddr_in6 _mpte_dst_v6; + } mpte_u_dst; +#define mpte_dst mpte_u_dst._mpte_dst +#define __mpte_dst_v4 mpte_u_dst._mpte_dst_v4 +#define __mpte_dst_v6 mpte_u_dst._mpte_dst_v6 struct sockaddr_in mpte_dst_v4_nat64; - uint16_t mpte_alternate_port; /* Alternate port for subflow establishment (network-byte-order) */ + struct sockaddr_in mpte_dst_unicast_v4; + struct sockaddr_in6 mpte_dst_unicast_v6; - struct mptsub *mpte_active_sub; /* ptr to last active subf */ - uint8_t mpte_flags; /* per mptcp session flags */ -#define MPTE_SND_REM_ADDR 0x01 /* Send Remove_addr option */ -#define MPTE_SVCTYPE_CHECKED 0x02 /* Did entitlement-check for service-type */ -#define MPTE_FIRSTPARTY 0x04 /* First-party app used multipath_extended entitlement */ -#define MPTE_ACCESS_GRANTED 0x08 /* Access to cellular has been granted for this connection */ - uint8_t mpte_svctype; /* MPTCP Service type */ - uint8_t mpte_lost_aid; /* storing lost address id */ - uint8_t mpte_addrid_last; /* storing address id parm */ + uint16_t mpte_alternate_port; /* Alternate port for subflow establishment (network-byte-order) */ -#define MPTE_ITFINFO_SIZE 4 - uint32_t mpte_itfinfo_size; - struct mpt_itf_info _mpte_itfinfo[MPTE_ITFINFO_SIZE]; - struct mpt_itf_info *mpte_itfinfo; + int mpte_epid; + uuid_t mpte_euuid; - struct mbuf *mpte_reinjectq; + struct mptsub *mpte_active_sub; /* ptr to last active subf */ + uint16_t mpte_flags; /* per mptcp session flags */ +#define MPTE_SND_REM_ADDR 0x01 /* Send Remove_addr option */ +#define MPTE_SVCTYPE_CHECKED 0x02 /* Did entitlement-check for service-type */ +#define MPTE_FIRSTPARTY 0x04 /* First-party app used multipath_extended entitlement */ +#define MPTE_ACCESS_GRANTED 0x08 /* Access to cellular has been granted for this connection */ +#define MPTE_FORCE_ENABLE 0x10 /* For MPTCP regardless of heuristics to detect middleboxes */ +#define MPTE_IN_WORKLOOP 0x20 /* Are we currently inside the workloop ? */ +#define MPTE_WORKLOOP_RELAUNCH 0x40 /* Another event got queued, we should restart the workloop */ +#define MPTE_UNICAST_IP 0x80 /* New subflows are only being established towards the unicast IP in the ADD_ADDR */ +#define MPTE_CELL_PROHIBITED 0x100 /* Cell access has been prohibited based on signal quality */ + uint8_t mpte_svctype; /* MPTCP Service type */ + uint8_t mpte_lost_aid; /* storing lost address id */ + uint8_t mpte_addrid_last; /* storing address id parm */ + +#define MPTE_ITFINFO_SIZE 4 + uint32_t mpte_itfinfo_size; + struct mpt_itf_info _mpte_itfinfo[MPTE_ITFINFO_SIZE]; + struct mpt_itf_info *mpte_itfinfo; + + struct mbuf *mpte_reinjectq; /* The below is used for stats */ - uint32_t mpte_subflow_switches; /* Number of subflow-switches in sending */ - uint32_t mpte_used_cell:1, - mpte_used_wifi:1, - mpte_initial_cell:1, - mpte_handshake_success:1; - - struct mptcp_itf_stats mpte_itfstats[MPTCP_ITFSTATS_SIZE]; - uint64_t mpte_init_txbytes __attribute__((aligned(8))); - uint64_t mpte_init_rxbytes __attribute__((aligned(8))); + uint32_t mpte_subflow_switches; /* Number of subflow-switches in sending */ + uint32_t mpte_used_cell:1, + mpte_used_wifi:1, + mpte_initial_cell:1, + mpte_triggered_cell, + mpte_handshake_success:1; + + struct mptcp_itf_stats mpte_itfstats[MPTCP_ITFSTATS_SIZE]; + uint64_t mpte_init_txbytes __attribute__((aligned(8))); + uint64_t mpte_init_rxbytes __attribute__((aligned(8))); }; static inline struct socket * mptetoso(struct mptses *mpte) { - return (mpte->mpte_mppcb->mpp_socket); + return mpte->mpte_mppcb->mpp_socket; } static inline struct mptses * mptompte(struct mppcb *mp) { - return ((struct mptses *)mp->mpp_pcbe); + return (struct mptses *)mp->mpp_pcbe; } static inline struct mptses * mpsotompte(struct socket *so) { - return (mptompte(mpsotomppcb(so))); -} - -static inline void -mpp_lock_assert_held(struct mppcb *mp) -{ -#if !MACH_ASSERT -#pragma unused(mp) -#endif - LCK_MTX_ASSERT(&mp->mpp_lock, LCK_MTX_ASSERT_OWNED); -} - -static inline void -mpp_lock_assert_notheld(struct mppcb *mp) -{ -#if !MACH_ASSERT -#pragma unused(mp) -#endif - LCK_MTX_ASSERT(&mp->mpp_lock, LCK_MTX_ASSERT_NOTOWNED); + return mptompte(mpsotomppcb(so)); } static inline boolean_t mpp_try_lock(struct mppcb *mp) { - if (!lck_mtx_try_lock(&mp->mpp_lock)) + if (!lck_mtx_try_lock(&mp->mpp_lock)) { return false; + } VERIFY(!(mp->mpp_flags & MPP_INSIDE_OUTPUT)); VERIFY(!(mp->mpp_flags & MPP_INSIDE_INPUT)); @@ -185,43 +193,7 @@ mpp_getlock(struct mppcb *mp, int flags) VERIFY(!(mp->mpp_flags & MPP_INSIDE_INPUT)); } - return (&mp->mpp_lock); -} - -static inline void -mpte_lock_assert_held(struct mptses *mpte) -{ - mpp_lock_assert_held(mpte->mpte_mppcb); -} - -static inline void -mpte_lock_assert_notheld(struct mptses *mpte) -{ - mpp_lock_assert_notheld(mpte->mpte_mppcb); -} - -static inline boolean_t -mpte_try_lock(struct mptses *mpte) -{ - return (mpp_try_lock(mpte->mpte_mppcb)); -} - -static inline void -mpte_lock(struct mptses *mpte) -{ - mpp_lock(mpte->mpte_mppcb); -} - -static inline void -mpte_unlock(struct mptses *mpte) -{ - mpp_unlock(mpte->mpte_mppcb); -} - -static inline lck_mtx_t * -mpte_getlock(struct mptses *mpte, int flags) -{ - return mpp_getlock(mpte->mpte_mppcb, flags); + return &mp->mpp_lock; } static inline int @@ -230,7 +202,7 @@ mptcp_subflow_cwnd_space(struct socket *so) struct tcpcb *tp = sototcpcb(so); int cwnd = min(tp->snd_wnd, tp->snd_cwnd) - (so->so_snd.sb_cc); - return (min(cwnd, sbspace(&so->so_snd))); + return min(cwnd, sbspace(&so->so_snd)); } @@ -238,16 +210,16 @@ mptcp_subflow_cwnd_space(struct socket *so) * MPTCP socket options */ struct mptopt { - TAILQ_ENTRY(mptopt) mpo_entry; /* glue to other options */ - uint32_t mpo_flags; /* see flags below */ - int mpo_level; /* sopt_level */ - int mpo_name; /* sopt_name */ - int mpo_intval; /* sopt_val */ + TAILQ_ENTRY(mptopt) mpo_entry; /* glue to other options */ + uint32_t mpo_flags; /* see flags below */ + int mpo_level; /* sopt_level */ + int mpo_name; /* sopt_name */ + int mpo_intval; /* sopt_val */ }; -#define MPOF_ATTACHED 0x1 /* attached to MP socket */ -#define MPOF_SUBFLOW_OK 0x2 /* can be issued on subflow socket */ -#define MPOF_INTERIM 0x4 /* has not been issued on any subflow */ +#define MPOF_ATTACHED 0x1 /* attached to MP socket */ +#define MPOF_SUBFLOW_OK 0x2 /* can be issued on subflow socket */ +#define MPOF_INTERIM 0x4 /* has not been issued on any subflow */ /* * MPTCP subflow @@ -255,29 +227,31 @@ struct mptopt { * Note that mpts_flags and mpts_evctl are modified via atomic operations. */ struct mptsub { - TAILQ_ENTRY(mptsub) mpts_entry; /* glue to peer subflows */ - uint32_t mpts_refcnt; /* reference count */ - uint32_t mpts_flags; /* see flags below */ - uint32_t mpts_evctl; /* subflow control events */ - sae_connid_t mpts_connid; /* subflow connection ID */ - int mpts_oldintval; /* sopt_val before sosetopt */ - struct mptses *mpts_mpte; /* back ptr to MPTCP session */ - struct socket *mpts_socket; /* subflow socket */ - struct sockaddr *mpts_src; /* source address */ + TAILQ_ENTRY(mptsub) mpts_entry; /* glue to peer subflows */ + uint32_t mpts_refcnt; /* reference count */ + uint32_t mpts_flags; /* see flags below */ + uint32_t mpts_evctl; /* subflow control events */ + sae_connid_t mpts_connid; /* subflow connection ID */ + int mpts_oldintval; /* sopt_val before sosetopt */ + struct mptses *mpts_mpte; /* back ptr to MPTCP session */ + struct socket *mpts_socket; /* subflow socket */ + struct sockaddr *mpts_src; /* source address */ union { /* destination address */ - struct sockaddr mpts_dst; - struct sockaddr_in __mpts_dst_v4; - struct sockaddr_in6 __mpts_dst_v6; - }; - - u_int32_t mpts_rel_seq; /* running count of subflow # */ - u_int32_t mpts_iss; /* Initial sequence number, taking TFO into account */ - u_int32_t mpts_ifscope; /* scoped to the interface */ - uint32_t mpts_probesoon; /* send probe after probeto */ - uint32_t mpts_probecnt; /* number of probes sent */ - uint32_t mpts_maxseg; /* cached value of t_maxseg */ + struct sockaddr _mpts_dst; + struct sockaddr_in _mpts_dst_v4; + struct sockaddr_in6 _mpts_dst_v6; + } mpts_u_dst; +#define mpts_dst mpts_u_dst._mpts_dst +#define __mpts_dst_v4 mpts_u_dst._mpts_dst_v4 +#define __mpts_dst_v6 mpts_u_dst._mpts_dst_v6 + u_int32_t mpts_rel_seq; /* running count of subflow # */ + u_int32_t mpts_iss; /* Initial sequence number, taking TFO into account */ + u_int32_t mpts_ifscope; /* scoped to the interface */ + uint32_t mpts_probesoon; /* send probe after probeto */ + uint32_t mpts_probecnt; /* number of probes sent */ + uint32_t mpts_maxseg; /* cached value of t_maxseg */ }; /* @@ -309,30 +283,34 @@ struct mptsub { * * Keep in sync with bsd/dev/dtrace/scripts/mptcp.d. */ -#define MPTSF_ATTACHED 0x00000001 /* attached to MPTCP PCB */ -#define MPTSF_CONNECTING 0x00000002 /* connection was attempted */ -#define MPTSF_CONNECT_PENDING 0x00000004 /* will connect when MPTCP is ready */ -#define MPTSF_CONNECTED 0x00000008 /* connection is established */ -#define MPTSF_DISCONNECTING 0x00000010 /* disconnection was attempted */ -#define MPTSF_DISCONNECTED 0x00000020 /* has been disconnected */ -#define MPTSF_MP_CAPABLE 0x00000040 /* connected as a MPTCP subflow */ -#define MPTSF_MP_READY 0x00000080 /* MPTCP has been confirmed */ -#define MPTSF_MP_DEGRADED 0x00000100 /* has lost its MPTCP capabilities */ -#define MPTSF_PREFERRED 0x00000200 /* primary/preferred subflow */ -#define MPTSF_SOPT_OLDVAL 0x00000400 /* old option value is valid */ -#define MPTSF_SOPT_INPROG 0x00000800 /* sosetopt in progress */ -#define MPTSF_FAILINGOVER 0x00001000 /* subflow not used for output */ -#define MPTSF_ACTIVE 0x00002000 /* subflow currently in use */ -#define MPTSF_MPCAP_CTRSET 0x00004000 /* mpcap counter */ -#define MPTSF_CLOSED 0x00008000 /* soclose_locked has been called on this subflow */ -#define MPTSF_TFO_REQD 0x00010000 /* TFO requested */ -#define MPTSF_CLOSE_REQD 0x00020000 /* A close has been requested from NECP */ -#define MPTSF_INITIAL_SUB 0x00040000 /* This is the initial subflow */ -#define MPTSF_READ_STALL 0x00080000 /* A read-stall has been detected */ -#define MPTSF_WRITE_STALL 0x00100000 /* A write-stall has been detected */ -#define MPTSF_CONFIRMED 0x00200000 /* Subflow confirmed to be MPTCP-capable */ - -#define MPTSF_BITS \ +#define MPTSF_ATTACHED 0x00000001 /* attached to MPTCP PCB */ +#define MPTSF_CONNECTING 0x00000002 /* connection was attempted */ +#define MPTSF_CONNECT_PENDING 0x00000004 /* will connect when MPTCP is ready */ +#define MPTSF_CONNECTED 0x00000008 /* connection is established */ +#define MPTSF_DISCONNECTING 0x00000010 /* disconnection was attempted */ +#define MPTSF_DISCONNECTED 0x00000020 /* has been disconnected */ +#define MPTSF_MP_CAPABLE 0x00000040 /* connected as a MPTCP subflow */ +#define MPTSF_MP_READY 0x00000080 /* MPTCP has been confirmed */ +#define MPTSF_MP_DEGRADED 0x00000100 /* has lost its MPTCP capabilities */ +#define MPTSF_PREFERRED 0x00000200 /* primary/preferred subflow */ +#define MPTSF_SOPT_OLDVAL 0x00000400 /* old option value is valid */ +#define MPTSF_SOPT_INPROG 0x00000800 /* sosetopt in progress */ +#define MPTSF_FAILINGOVER 0x00001000 /* subflow not used for output */ +#define MPTSF_ACTIVE 0x00002000 /* subflow currently in use */ +#define MPTSF_MPCAP_CTRSET 0x00004000 /* mpcap counter */ +#define MPTSF_CLOSED 0x00008000 /* soclose_locked has been called on this subflow */ +#define MPTSF_TFO_REQD 0x00010000 /* TFO requested */ +#define MPTSF_CLOSE_REQD 0x00020000 /* A close has been requested from NECP */ +#define MPTSF_INITIAL_SUB 0x00040000 /* This is the initial subflow */ +#define MPTSF_READ_STALL 0x00080000 /* A read-stall has been detected */ +#define MPTSF_WRITE_STALL 0x00100000 /* A write-stall has been detected */ +#define MPTSF_FULLY_ESTABLISHED 0x00200000 /* Subflow is fully established and it has been confirmed + * whether or not it supports MPTCP. + * No need for further middlebox-detection. + */ +#define MPTSF_CELLICON_SET 0x00400000 /* This subflow set the cellicon */ + +#define MPTSF_BITS \ "\020\1ATTACHED\2CONNECTING\3PENDING\4CONNECTED\5DISCONNECTING" \ "\6DISCONNECTED\7MP_CAPABLE\10MP_READY\11MP_DEGRADED" \ "\12PREFERRED\13SOPT_OLDVAL" \ @@ -345,30 +323,30 @@ struct mptsub { * Keep in sync with bsd/dev/dtrace/mptcp.d */ typedef enum mptcp_state { - MPTCPS_CLOSED = 0, /* closed */ - MPTCPS_LISTEN = 1, /* not yet implemented */ - MPTCPS_ESTABLISHED = 2, /* MPTCP connection established */ - MPTCPS_CLOSE_WAIT = 3, /* rcvd DFIN, waiting for close */ - MPTCPS_FIN_WAIT_1 = 4, /* have closed, sent DFIN */ - MPTCPS_CLOSING = 5, /* closed xchd DFIN, waiting DFIN ACK */ - MPTCPS_LAST_ACK = 6, /* had DFIN and close; await DFIN ACK */ - MPTCPS_FIN_WAIT_2 = 7, /* have closed, DFIN is acked */ - MPTCPS_TIME_WAIT = 8, /* in 2*MSL quiet wait after close */ - MPTCPS_TERMINATE = 9, /* terminal state */ + MPTCPS_CLOSED = 0, /* closed */ + MPTCPS_LISTEN = 1, /* not yet implemented */ + MPTCPS_ESTABLISHED = 2, /* MPTCP connection established */ + MPTCPS_CLOSE_WAIT = 3, /* rcvd DFIN, waiting for close */ + MPTCPS_FIN_WAIT_1 = 4, /* have closed, sent DFIN */ + MPTCPS_CLOSING = 5, /* closed xchd DFIN, waiting DFIN ACK */ + MPTCPS_LAST_ACK = 6, /* had DFIN and close; await DFIN ACK */ + MPTCPS_FIN_WAIT_2 = 7, /* have closed, DFIN is acked */ + MPTCPS_TIME_WAIT = 8, /* in 2*MSL quiet wait after close */ + MPTCPS_TERMINATE = 9, /* terminal state */ } mptcp_state_t; -typedef u_int64_t mptcp_key_t; -typedef u_int32_t mptcp_token_t; -typedef u_int8_t mptcp_addr_id; +typedef u_int64_t mptcp_key_t; +typedef u_int32_t mptcp_token_t; +typedef u_int8_t mptcp_addr_id; /* Address ID list */ struct mptcp_subf_auth_entry { LIST_ENTRY(mptcp_subf_auth_entry) msae_next; - u_int32_t msae_laddr_rand; /* Local nonce */ - u_int32_t msae_raddr_rand; /* Remote nonce */ - mptcp_addr_id msae_laddr_id; /* Local addr ID */ - mptcp_addr_id msae_raddr_id; /* Remote addr ID */ + u_int32_t msae_laddr_rand; /* Local nonce */ + u_int32_t msae_raddr_rand; /* Remote nonce */ + mptcp_addr_id msae_laddr_id; /* Local addr ID */ + mptcp_addr_id msae_raddr_id; /* Remote addr ID */ }; /* @@ -378,96 +356,99 @@ struct mptcp_subf_auth_entry { * Keep in sync with bsd/dev/dtrace/scripts/mptcp.d. */ struct mptcb { - struct mptses *mpt_mpte; /* back ptr to MPTCP session */ - mptcp_state_t mpt_state; /* MPTCP state */ - u_int32_t mpt_flags; /* see flags below */ - u_int32_t mpt_version; /* MPTCP proto version */ - int mpt_softerror; /* error not yet reported */ + struct mptses *mpt_mpte; /* back ptr to MPTCP session */ + mptcp_state_t mpt_state; /* MPTCP state */ + uint32_t mpt_flags; /* see flags below */ + uint32_t mpt_version; /* MPTCP proto version */ + int mpt_softerror; /* error not yet reported */ /* * Authentication and metadata invariants */ - mptcp_key_t mpt_localkey; /* in network byte order */ - mptcp_key_t mpt_remotekey; /* in network byte order */ - mptcp_token_t mpt_localtoken; /* HMAC SHA1 of local key */ - mptcp_token_t mpt_remotetoken; /* HMAC SHA1 of remote key */ + mptcp_key_t mpt_localkey; /* in network byte order */ + mptcp_key_t mpt_remotekey; /* in network byte order */ + mptcp_token_t mpt_localtoken; /* HMAC SHA1 of local key */ + mptcp_token_t mpt_remotetoken; /* HMAC SHA1 of remote key */ /* * Timer vars for scenarios where subflow level acks arrive, but * Data ACKs do not. */ - int mpt_rxtshift; /* num of consecutive retrans */ - u_int32_t mpt_rxtstart; /* time at which rxt started */ - u_int64_t mpt_rtseq; /* seq # being tracked */ - u_int32_t mpt_timer_vals; /* timer related values */ - u_int32_t mpt_timewait; /* timewait */ + int mpt_rxtshift; /* num of consecutive retrans */ + uint32_t mpt_rxtstart; /* time at which rxt started */ + uint64_t mpt_rtseq; /* seq # being tracked */ + uint32_t mpt_timer_vals; /* timer related values */ + uint32_t mpt_timewait; /* timewait */ /* * Sending side */ - u_int64_t mpt_snduna; /* DSN of last unacked byte */ - u_int64_t mpt_sndnxt; /* DSN of next byte to send */ - u_int64_t mpt_sndmax; /* DSN of max byte sent */ - u_int64_t mpt_local_idsn; /* First byte's DSN */ - u_int32_t mpt_sndwnd; - u_int64_t mpt_sndwl1; - u_int64_t mpt_sndwl2; + uint64_t mpt_snduna; /* DSN of last unacked byte */ + uint64_t mpt_sndnxt; /* DSN of next byte to send */ + uint64_t mpt_sndmax; /* DSN of max byte sent */ + uint64_t mpt_local_idsn; /* First byte's DSN */ + uint32_t mpt_sndwnd; + uint64_t mpt_sndwl1; + uint64_t mpt_sndwl2; /* * Receiving side */ - u_int64_t mpt_rcvnxt; /* Next expected DSN */ - u_int64_t mpt_remote_idsn; /* Peer's IDSN */ - u_int32_t mpt_rcvwnd; + uint64_t mpt_rcvnxt; /* Next expected DSN */ + uint64_t mpt_remote_idsn; /* Peer's IDSN */ + uint32_t mpt_rcvwnd; + uint32_t mpt_rcvadv; LIST_HEAD(, mptcp_subf_auth_entry) mpt_subauth_list; /* address IDs */ /* * Fastclose */ - u_int64_t mpt_dsn_at_csum_fail; /* MPFail Opt DSN */ - u_int32_t mpt_ssn_at_csum_fail; /* MPFail Subflow Seq */ + uint64_t mpt_dsn_at_csum_fail; /* MPFail Opt DSN */ + uint32_t mpt_ssn_at_csum_fail; /* MPFail Subflow Seq */ /* * Zombie handling */ -#define MPT_GC_TICKS (30) -#define MPT_GC_TICKS_FAST (10) - int32_t mpt_gc_ticks; /* Used for zombie deletion */ +#define MPT_GC_TICKS (30) +#define MPT_GC_TICKS_FAST (10) + int32_t mpt_gc_ticks; /* Used for zombie deletion */ - u_int32_t mpt_notsent_lowat; /* TCP_NOTSENT_LOWAT support */ - u_int32_t mpt_peer_version; /* Version from peer */ + uint32_t mpt_notsent_lowat; /* TCP_NOTSENT_LOWAT support */ + uint32_t mpt_peer_version; /* Version from peer */ - struct tsegqe_head mpt_segq; - u_int16_t mpt_reassqlen; /* length of reassembly queue */ + struct tsegqe_head mpt_segq; + uint16_t mpt_reassqlen; /* length of reassembly queue */ }; /* valid values for mpt_flags (see also notes on mpts_flags above) */ -#define MPTCPF_CHECKSUM 0x001 /* checksum DSS option */ -#define MPTCPF_FALLBACK_TO_TCP 0x002 /* Fallback to TCP */ -#define MPTCPF_JOIN_READY 0x004 /* Ready to start 2 or more subflows */ -#define MPTCPF_RECVD_MPFAIL 0x008 /* Received MP_FAIL option */ -#define MPTCPF_SND_64BITDSN 0x010 /* Send full 64-bit DSN */ -#define MPTCPF_SND_64BITACK 0x020 /* Send 64-bit ACK response */ -#define MPTCPF_RCVD_64BITACK 0x040 /* Received 64-bit Data ACK */ -#define MPTCPF_POST_FALLBACK_SYNC 0x080 /* Post fallback resend data */ -#define MPTCPF_FALLBACK_HEURISTIC 0x100 /* Send SYN without MP_CAPABLE due to heuristic */ -#define MPTCPF_HEURISTIC_TRAC 0x200 /* Tracked this connection in the heuristics as a failure */ -#define MPTCPF_REASS_INPROG 0x400 /* Reassembly is in progress */ - -#define MPTCPF_BITS \ +#define MPTCPF_CHECKSUM 0x001 /* checksum DSS option */ +#define MPTCPF_FALLBACK_TO_TCP 0x002 /* Fallback to TCP */ +#define MPTCPF_JOIN_READY 0x004 /* Ready to start 2 or more subflows */ +#define MPTCPF_RECVD_MPFAIL 0x008 /* Received MP_FAIL option */ +#define MPTCPF_SND_64BITDSN 0x010 /* Send full 64-bit DSN */ +#define MPTCPF_SND_64BITACK 0x020 /* Send 64-bit ACK response */ +#define MPTCPF_RCVD_64BITACK 0x040 /* Received 64-bit Data ACK */ +#define MPTCPF_POST_FALLBACK_SYNC 0x080 /* Post fallback resend data */ +#define MPTCPF_FALLBACK_HEURISTIC 0x100 /* Send SYN without MP_CAPABLE due to heuristic */ +#define MPTCPF_HEURISTIC_TRAC 0x200 /* Tracked this connection in the heuristics as a failure */ +#define MPTCPF_REASS_INPROG 0x400 /* Reassembly is in progress */ +#define MPTCPF_UNICAST_IP 0x800 + +#define MPTCPF_BITS \ "\020\1CHECKSUM\2FALLBACK_TO_TCP\3JOIN_READY\4RECVD_MPFAIL" \ "\5SND_64BITDSN\6SND_64BITACK\7RCVD_64BITACK\10POST_FALLBACK_SYNC" \ "\11FALLBACK_HEURISTIC\12HEURISTIC_TRAC\13REASS_INPROG" /* valid values for mpt_timer_vals */ -#define MPTT_REXMT 0x01 /* Starting Retransmit Timer */ -#define MPTT_TW 0x02 /* Starting Timewait Timer */ -#define MPTT_FASTCLOSE 0x04 /* Starting Fastclose wait timer */ +#define MPTT_REXMT 0x01 /* Starting Retransmit Timer */ +#define MPTT_TW 0x02 /* Starting Timewait Timer */ +#define MPTT_FASTCLOSE 0x04 /* Starting Fastclose wait timer */ /* events for close FSM */ -#define MPCE_CLOSE 0x1 -#define MPCE_RECV_DATA_ACK 0x2 -#define MPCE_RECV_DATA_FIN 0x4 +#define MPCE_CLOSE 0x1 +#define MPCE_RECV_DATA_ACK 0x2 +#define MPCE_RECV_DATA_FIN 0x4 /* mptcb manipulation */ -static inline struct mptcb *tptomptp(struct tcpcb *tp) +static inline struct mptcb * +tptomptp(struct tcpcb *tp) { - return (tp->t_mptcb); + return tp->t_mptcb; } /* @@ -475,9 +456,9 @@ static inline struct mptcb *tptomptp(struct tcpcb *tp) * the MP protocol control block; the folllowing represents the layout. */ struct mpp_mtp { - struct mppcb mpp; /* Multipath PCB */ - struct mptses mpp_ses; /* MPTCP session */ - struct mptcb mtcb; /* MPTCP PCB */ + struct mppcb mpp; /* Multipath PCB */ + struct mptses mpp_ses; /* MPTCP session */ + struct mptcb mtcb; /* MPTCP PCB */ }; #ifdef SYSCTL_DECL @@ -489,37 +470,37 @@ extern struct pr_usrreqs mptcp_usrreqs; extern os_log_t mptcp_log_handle; /* Encryption algorithm related definitions */ -#define SHA1_TRUNCATED 8 +#define SHA1_TRUNCATED 8 /* MPTCP Debugging Levels */ -#define MPTCP_LOGLVL_NONE 0x0 /* No debug logging */ -#define MPTCP_LOGLVL_ERR 0x1 /* Errors in execution are logged */ -#define MPTCP_LOGLVL_LOG 0x2 /* Important logs */ -#define MPTCP_LOGLVL_VERBOSE 0x4 /* Verbose logs */ +#define MPTCP_LOGLVL_NONE 0x0 /* No debug logging */ +#define MPTCP_LOGLVL_ERR 0x1 /* Errors in execution are logged */ +#define MPTCP_LOGLVL_LOG 0x2 /* Important logs */ +#define MPTCP_LOGLVL_VERBOSE 0x4 /* Verbose logs */ /* MPTCP sub-components for debug logging */ -#define MPTCP_NO_DBG 0x00 /* No areas are logged */ -#define MPTCP_STATE_DBG 0x01 /* State machine logging */ -#define MPTCP_SOCKET_DBG 0x02 /* Socket call logging */ -#define MPTCP_SENDER_DBG 0x04 /* Sender side logging */ -#define MPTCP_RECEIVER_DBG 0x08 /* Receiver logging */ -#define MPTCP_EVENTS_DBG 0x10 /* Subflow events logging */ +#define MPTCP_NO_DBG 0x00 /* No areas are logged */ +#define MPTCP_STATE_DBG 0x01 /* State machine logging */ +#define MPTCP_SOCKET_DBG 0x02 /* Socket call logging */ +#define MPTCP_SENDER_DBG 0x04 /* Sender side logging */ +#define MPTCP_RECEIVER_DBG 0x08 /* Receiver logging */ +#define MPTCP_EVENTS_DBG 0x10 /* Subflow events logging */ /* Mask to obtain 32-bit portion of data sequence number */ -#define MPTCP_DATASEQ_LOW32_MASK (0xffffffff) -#define MPTCP_DATASEQ_LOW32(seq) (seq & MPTCP_DATASEQ_LOW32_MASK) +#define MPTCP_DATASEQ_LOW32_MASK (0xffffffff) +#define MPTCP_DATASEQ_LOW32(seq) (seq & MPTCP_DATASEQ_LOW32_MASK) /* Mask to obtain upper 32-bit portion of data sequence number */ -#define MPTCP_DATASEQ_HIGH32_MASK (0xffffffff00000000) -#define MPTCP_DATASEQ_HIGH32(seq) (seq & MPTCP_DATASEQ_HIGH32_MASK) +#define MPTCP_DATASEQ_HIGH32_MASK (0xffffffff00000000) +#define MPTCP_DATASEQ_HIGH32(seq) (seq & MPTCP_DATASEQ_HIGH32_MASK) /* Mask to obtain 32-bit portion of data ack */ -#define MPTCP_DATAACK_LOW32_MASK (0xffffffff) -#define MPTCP_DATAACK_LOW32(ack) (ack & MPTCP_DATAACK_LOW32_MASK) +#define MPTCP_DATAACK_LOW32_MASK (0xffffffff) +#define MPTCP_DATAACK_LOW32(ack) (ack & MPTCP_DATAACK_LOW32_MASK) /* Mask to obtain upper 32-bit portion of data ack */ -#define MPTCP_DATAACK_HIGH32_MASK (0xffffffff00000000) -#define MPTCP_DATAACK_HIGH32(ack) (ack & MPTCP_DATAACK_HIGH32_MASK) +#define MPTCP_DATAACK_HIGH32_MASK (0xffffffff00000000) +#define MPTCP_DATAACK_HIGH32(ack) (ack & MPTCP_DATAACK_HIGH32_MASK) /* * x is the 64-bit data sequence number, y the 32-bit data seq number to be @@ -535,54 +516,59 @@ extern os_log_t mptcp_log_handle; * comparing against rwnd. Bogus DSNs within rwnd cannot be protected against * and are as weak as bogus TCP sequence numbers. */ -#define MPTCP_EXTEND_DSN(x, y, z) { \ - if ((MPTCP_DATASEQ_LOW32(x) > y) && \ - ((((u_int32_t)MPTCP_DATASEQ_LOW32(x)) - (u_int32_t)y) >= \ - (u_int32_t)(1 << 31))) { \ - /* \ - * y wrapped around and x and y are 2**31 bytes apart \ - */ \ - z = MPTCP_DATASEQ_HIGH32(x) + 0x100000000; \ - z |= y; \ - } else if ((MPTCP_DATASEQ_LOW32(x) < y) && \ - (((u_int32_t)y - \ - ((u_int32_t)MPTCP_DATASEQ_LOW32(x))) >= \ - (u_int32_t)(1 << 31))) { \ - /* \ - * x wrapped around and x and y are 2**31 apart \ - */ \ - z = MPTCP_DATASEQ_HIGH32(x) - 0x100000000; \ - z |= y; \ - } else { \ - z = MPTCP_DATASEQ_HIGH32(x) | y; \ - } \ +#define MPTCP_EXTEND_DSN(x, y, z) { \ + if ((MPTCP_DATASEQ_LOW32(x) > y) && \ + ((((u_int32_t)MPTCP_DATASEQ_LOW32(x)) - (u_int32_t)y) >= \ + (u_int32_t)(1U << 31))) { \ + /* \ + * y wrapped around and x and y are 2**31 bytes apart \ + */ \ + z = MPTCP_DATASEQ_HIGH32(x) + 0x100000000; \ + z |= y; \ + } else if ((MPTCP_DATASEQ_LOW32(x) < y) && \ + (((u_int32_t)y - \ + ((u_int32_t)MPTCP_DATASEQ_LOW32(x))) >= \ + (u_int32_t)(1U << 31))) { \ + /* \ + * x wrapped around and x and y are 2**31 apart \ + */ \ + z = MPTCP_DATASEQ_HIGH32(x) - 0x100000000; \ + z |= y; \ + } else { \ + z = MPTCP_DATASEQ_HIGH32(x) | y; \ + } \ } -#define mptcplog(x, y, z) do { \ - if ((mptcp_dbg_area & y) && (mptcp_dbg_level & z)) \ - log x; \ +#define mptcplog(x, y, z) do { \ + if ((mptcp_dbg_area & y) && (mptcp_dbg_level & z)) \ + log x; \ } while (0) -extern int mptcp_enable; /* Multipath TCP */ -extern int mptcp_mpcap_retries; /* Multipath TCP retries */ -extern int mptcp_join_retries; /* Multipath TCP Join retries */ -extern int mptcp_dss_csum; /* Multipath DSS Option checksum */ -extern int mptcp_fail_thresh; /* Multipath failover thresh of retransmits */ +extern int mptcp_enable; /* Multipath TCP */ +extern int mptcp_mpcap_retries; /* Multipath TCP retries */ +extern int mptcp_join_retries; /* Multipath TCP Join retries */ +extern int mptcp_dss_csum; /* Multipath DSS Option checksum */ +extern int mptcp_fail_thresh; /* Multipath failover thresh of retransmits */ extern int mptcp_subflow_keeptime; /* Multipath subflow TCP_KEEPALIVE opt */ -extern uint32_t mptcp_dbg_level; /* Multipath TCP debugging level */ -extern uint32_t mptcp_dbg_area; /* Multipath TCP debugging area */ -extern int mptcp_developer_mode; /* Allow aggregation mode */ +extern uint32_t mptcp_dbg_level; /* Multipath TCP debugging level */ +extern uint32_t mptcp_dbg_area; /* Multipath TCP debugging area */ +extern int mptcp_developer_mode; /* Allow aggregation mode */ +extern uint32_t mptcp_cellicon_refcount; + +#define MPTCP_CELLICON_TOGGLE_RATE (5 * TCP_RETRANSHZ) /* Only toggle every 5 seconds */ -extern int tcp_jack_rxmt; /* Join ACK retransmission value in msecs */ +extern int tcp_jack_rxmt; /* Join ACK retransmission value in msecs */ __BEGIN_DECLS extern void mptcp_init(struct protosw *, struct domain *); extern int mptcp_ctloutput(struct socket *, struct sockopt *); -extern int mptcp_sescreate(struct mppcb *); -extern void mptcp_check_subflows_and_add(struct mptses *); -extern int mptcp_get_statsindex(struct mptcp_itf_stats *stats, - const struct mptsub *mpts); -extern void mptcpstats_inc_switch(struct mptses *, const struct mptsub *); +extern int mptcp_session_create(struct mppcb *); +extern boolean_t mptcp_ok_to_create_subflows(struct mptcb *mp_tp); +extern void mptcp_check_subflows_and_add(struct mptses *mpte); +extern void mptcp_check_subflows_and_remove(struct mptses *mpte); +extern void mptcpstats_inc_switch(struct mptses *mpte, const struct mptsub *mpts); +extern void mptcpstats_update(struct mptcp_itf_stats *stats, const struct mptsub *mpts); +extern int mptcpstats_get_index_by_ifindex(struct mptcp_itf_stats *stats, int ifindex, boolean_t create); extern struct mptses *mptcp_drop(struct mptses *, struct mptcb *, int); extern struct mptses *mptcp_close(struct mptses *, struct mptcb *); extern int mptcp_lock(struct socket *, int, void *); @@ -602,10 +588,10 @@ extern struct mptopt *mptcp_sopt_find(struct mptses *, struct sockopt *); extern int mptcp_subflow_add(struct mptses *, struct sockaddr *, struct sockaddr *, uint32_t, sae_connid_t *); -extern void mptcpstats_update(struct mptcp_itf_stats *stats, struct mptsub *mpts); extern void mptcp_subflow_del(struct mptses *, struct mptsub *); -#define MPTCP_SUBOUT_PROBING 0x01 +extern void mptcp_handle_input(struct socket *so); +#define MPTCP_SUBOUT_PROBING 0x01 extern int mptcp_subflow_output(struct mptses *mpte, struct mptsub *mpts, int flags); extern void mptcp_clean_reinjectq(struct mptses *mpte); extern void mptcp_subflow_shutdown(struct mptses *, struct mptsub *); @@ -631,14 +617,13 @@ extern int mptcp_init_remote_parms(struct mptcb *); extern boolean_t mptcp_ok_to_keepalive(struct mptcb *); extern void mptcp_insert_dsn(struct mppcb *, struct mbuf *); extern void mptcp_output_getm_dsnmap32(struct socket *so, int off, - uint32_t *dsn, uint32_t *relseq, - uint16_t *data_len, uint16_t *dss_csum); + uint32_t *dsn, uint32_t *relseq, + uint16_t *data_len, uint16_t *dss_csum); extern void mptcp_output_getm_dsnmap64(struct socket *so, int off, - uint64_t *dsn, uint32_t *relseq, - uint16_t *data_len, uint16_t *dss_csum); + uint64_t *dsn, uint32_t *relseq, + uint16_t *data_len, uint16_t *dss_csum); extern void mptcp_act_on_txfail(struct socket *); -extern struct mptsub *mptcp_get_subflow(struct mptses *, struct mptsub *, - struct mptsub **); +extern struct mptsub *mptcp_get_subflow(struct mptses *mpte, struct mptsub **preferred); extern int mptcp_get_map_for_dsn(struct socket *, u_int64_t, u_int32_t *); extern int32_t mptcp_adj_sendlen(struct socket *so, int32_t off); extern void mptcp_sbrcv_grow(struct mptcb *mp_tp); @@ -652,97 +637,106 @@ extern u_int32_t mptcp_get_notsent_lowat(struct mptses *mpte); extern int mptcp_notsent_lowat_check(struct socket *so); extern void mptcp_ask_symptoms(struct mptses *mpte); extern void mptcp_control_register(void); -extern int mptcp_is_wifi_unusable(void); +extern int mptcp_is_wifi_unusable_for_session(struct mptses *mpte); +extern boolean_t symptoms_is_wifi_lossy(void); extern void mptcp_ask_for_nat64(struct ifnet *ifp); -extern void mptcp_session_necp_cb(void *, int, struct necp_client_flow *); +extern void mptcp_session_necp_cb(void *, int, uint32_t, uint32_t, bool *); +extern struct sockaddr *mptcp_get_session_dst(struct mptses *mpte, + boolean_t has_v6, boolean_t has_v4); extern void mptcp_set_restrictions(struct socket *mp_so); -extern int mptcp_freeq(struct mptcb *); -extern void mptcp_set_cellicon(struct mptses *mpte); -extern void mptcp_unset_cellicon(void); +extern void mptcp_clear_cellicon(void); +extern void mptcp_unset_cellicon(struct mptses *mpte, struct mptsub *mpts, uint32_t val); extern void mptcp_reset_rexmit_state(struct tcpcb *tp); extern void mptcp_reset_keepalive(struct tcpcb *tp); extern int mptcp_validate_csum(struct tcpcb *tp, struct mbuf *m, uint64_t dsn, - uint32_t sseq, uint16_t dlen, uint16_t csum, - uint16_t dfin); + uint32_t sseq, uint16_t dlen, uint16_t csum, + uint16_t dfin); __END_DECLS #endif /* BSD_KERNEL_PRIVATE */ #ifdef PRIVATE typedef struct mptcp_flow { - size_t flow_len; - size_t flow_tcpci_offset; - uint32_t flow_flags; - sae_connid_t flow_cid; + size_t flow_len; + size_t flow_tcpci_offset; + uint32_t flow_flags; + sae_connid_t flow_cid; struct sockaddr_storage flow_src; struct sockaddr_storage flow_dst; - uint32_t flow_relseq; /* last subflow rel seq# */ - int32_t flow_soerror; /* subflow level error */ - uint32_t flow_probecnt; /* number of probes sent */ - conninfo_tcp_t flow_ci; /* must be the last field */ + uint32_t flow_relseq; /* last subflow rel seq# */ + int32_t flow_soerror; /* subflow level error */ + uint32_t flow_probecnt; /* number of probes sent */ + conninfo_tcp_t flow_ci; /* must be the last field */ } mptcp_flow_t; typedef struct conninfo_mptcp { - size_t mptcpci_len; - size_t mptcpci_flow_offset; /* offsetof first flow */ - size_t mptcpci_nflows; /* number of subflows */ - uint32_t mptcpci_state; /* MPTCP level state */ - uint32_t mptcpci_mpte_flags; /* Session flags */ - uint32_t mptcpci_flags; /* MPTCB flags */ - uint32_t mptcpci_ltoken; /* local token */ - uint32_t mptcpci_rtoken; /* remote token */ - uint32_t mptcpci_notsent_lowat; /* NOTSENT_LOWAT */ + size_t mptcpci_len; + size_t mptcpci_flow_offset; /* offsetof first flow */ + size_t mptcpci_nflows; /* number of subflows */ + uint32_t mptcpci_state; /* MPTCP level state */ + uint32_t mptcpci_mpte_flags; /* Session flags */ + uint32_t mptcpci_flags; /* MPTCB flags */ + uint32_t mptcpci_ltoken; /* local token */ + uint32_t mptcpci_rtoken; /* remote token */ + uint32_t mptcpci_notsent_lowat; /* NOTSENT_LOWAT */ /* Send side */ - uint64_t mptcpci_snduna; /* DSN of last unacked byte */ - uint64_t mptcpci_sndnxt; /* DSN of next byte to send */ - uint64_t mptcpci_sndmax; /* DSN of max byte sent */ - uint64_t mptcpci_lidsn; /* Local IDSN */ - uint32_t mptcpci_sndwnd; /* Send window snapshot */ + uint64_t mptcpci_snduna; /* DSN of last unacked byte */ + uint64_t mptcpci_sndnxt; /* DSN of next byte to send */ + uint64_t mptcpci_sndmax; /* DSN of max byte sent */ + uint64_t mptcpci_lidsn; /* Local IDSN */ + uint32_t mptcpci_sndwnd; /* Send window snapshot */ /* Receive side */ - uint64_t mptcpci_rcvnxt; /* Next expected DSN */ - uint64_t mptcpci_rcvatmark; /* Session level rcvnxt */ - uint64_t mptcpci_ridsn; /* Peer's IDSN */ - uint32_t mptcpci_rcvwnd; /* Receive window */ + uint64_t mptcpci_rcvnxt; /* Next expected DSN */ + uint64_t mptcpci_rcvatmark; /* Session level rcvnxt */ + uint64_t mptcpci_ridsn; /* Peer's IDSN */ + uint32_t mptcpci_rcvwnd; /* Receive window */ - uint8_t mptcpci_mpte_addrid; /* last addr id */ + uint8_t mptcpci_mpte_addrid; /* last addr id */ - mptcp_flow_t mptcpci_flows[1]; + mptcp_flow_t mptcpci_flows[1]; } conninfo_mptcp_t; /* Use SymptomsD notifications of wifi and cell status in subflow selection */ #define MPTCP_KERN_CTL_NAME "com.apple.network.advisory" typedef struct symptoms_advisory { union { - uint32_t sa_nwk_status_int; + uint32_t sa_nwk_status_int; struct { union { -#define SYMPTOMS_ADVISORY_NOCOMMENT 0x0000 -#define SYMPTOMS_ADVISORY_USEAPP 0xFFFF /* Very ugly workaround to avoid breaking backwards compatibility - ToDo: Fix it in +1 */ - uint16_t sa_nwk_status; +#define SYMPTOMS_ADVISORY_NOCOMMENT 0x0000 +#define SYMPTOMS_ADVISORY_USEAPP 0xFFFF /* Very ugly workaround to avoid breaking backwards compatibility - ToDo: Fix it in +1 */ + uint16_t sa_nwk_status; struct { #define SYMPTOMS_ADVISORY_WIFI_BAD 0x01 #define SYMPTOMS_ADVISORY_WIFI_OK 0x02 - uint8_t sa_wifi_status; + uint8_t sa_wifi_status; #define SYMPTOMS_ADVISORY_CELL_BAD 0x01 #define SYMPTOMS_ADVISORY_CELL_OK 0x02 - uint8_t sa_cell_status; + uint8_t sa_cell_status; }; }; - uint16_t sa_unused; + uint16_t sa_unused; }; }; } symptoms_advisory_t; +#define MPTCP_TARGET_BASED_RSSI_THRESHOLD -75 +struct mptcp_symptoms_answer { + struct symptoms_advisory advisory; + uuid_t uuid; + int32_t rssi; +}; + struct mptcp_symptoms_ask_uuid { - uint32_t cmd; -#define MPTCP_SYMPTOMS_ASK_UUID 1 - uuid_t uuid; - uint32_t priority; -#define MPTCP_SYMPTOMS_UNKNOWN 0 -#define MPTCP_SYMPTOMS_BACKGROUND 1 -#define MPTCP_SYMPTOMS_FOREGROUND 2 + uint32_t cmd; +#define MPTCP_SYMPTOMS_ASK_UUID 1 + uuid_t uuid; + uint32_t priority; +#define MPTCP_SYMPTOMS_UNKNOWN 0 +#define MPTCP_SYMPTOMS_BACKGROUND 1 +#define MPTCP_SYMPTOMS_FOREGROUND 2 }; struct kev_mptcp_data {