/kernel/linux/linux-5.10/net/sctp/ |
H A D | tsnmap.c | 10 * These functions manipulate sctp tsn mapping array. 69 int sctp_tsnmap_check(const struct sctp_tsnmap *map, __u32 tsn) in sctp_tsnmap_check() argument 74 if (TSN_lte(tsn, map->cumulative_tsn_ack_point)) in sctp_tsnmap_check() 80 if (!TSN_lt(tsn, map->base_tsn + SCTP_TSN_MAP_SIZE)) in sctp_tsnmap_check() 84 gap = tsn - map->base_tsn; in sctp_tsnmap_check() 95 int sctp_tsnmap_mark(struct sctp_tsnmap *map, __u32 tsn, in sctp_tsnmap_mark() argument 100 if (TSN_lt(tsn, map->base_tsn)) in sctp_tsnmap_mark() 103 gap = tsn - map->base_tsn; in sctp_tsnmap_mark() 109 /* In this case the map has no gaps and the tsn we are in sctp_tsnmap_mark() 110 * recording is the next expected tsn in sctp_tsnmap_mark() 190 sctp_tsnmap_skip(struct sctp_tsnmap *map, __u32 tsn) sctp_tsnmap_skip() argument 300 sctp_tsnmap_renege(struct sctp_tsnmap *map, __u32 tsn) sctp_tsnmap_renege() argument [all...] |
H A D | outqueue.c | 42 static int sctp_acked(struct sctp_sackhdr *sack, __u32 tsn); 153 static inline int sctp_cacc_skip_3_2(struct sctp_transport *primary, __u32 tsn) in sctp_cacc_skip_3_2() argument 156 TSN_lt(tsn, primary->cacc.next_tsn_at_change)) in sctp_cacc_skip_3_2() 178 __u32 tsn) in sctp_cacc_skip() 182 sctp_cacc_skip_3_2(primary, tsn))) in sctp_cacc_skip() 327 ntsn = ntohl(nchunk->subh.data_hdr->tsn); in sctp_insert_list() 331 ltsn = ntohl(lchunk->subh.data_hdr->tsn); in sctp_insert_list() 1087 pr_debug("%s: outq:%p, chunk:%p[%s], tx-tsn:0x%x skb->head:%p skb->users:%d\n", in sctp_outq_flush_data() 1090 "illegal chunk", ntohl(chunk->subh.data_hdr->tsn), in sctp_outq_flush_data() 1101 pr_debug("%s: could not transmit tsn in sctp_outq_flush_data() 175 sctp_cacc_skip(struct sctp_transport *primary, struct sctp_transport *transport, int count_of_newacks, __u32 tsn) sctp_cacc_skip() argument 1233 __u32 sack_ctsn, ctsn, tsn; sctp_outq_sack() local 1419 __u32 tsn; sctp_check_transmitted() local 1690 __u32 tsn; sctp_mark_missing() local 1747 sctp_acked(struct sctp_sackhdr *sack, __u32 tsn) sctp_acked() argument 1803 __u32 tsn; sctp_generate_fwdtsn() local [all...] |
H A D | ulpqueue.c | 278 __u32 tsn, ctsn; in sctp_ulpq_store_reasm() local 280 tsn = event->tsn; in sctp_ulpq_store_reasm() 291 ctsn = cevent->tsn; in sctp_ulpq_store_reasm() 292 if (TSN_lt(ctsn, tsn)) { in sctp_ulpq_store_reasm() 300 ctsn = cevent->tsn; in sctp_ulpq_store_reasm() 302 if (TSN_lt(tsn, ctsn)) in sctp_ulpq_store_reasm() 433 ctsn = cevent->tsn; in sctp_ulpq_retrieve_reassembled() 530 ctsn = cevent->tsn; in sctp_ulpq_retrieve_partial() 594 /* Do not even bother unless this is the next tsn t in sctp_ulpq_reasm() 689 __u32 tsn; sctp_ulpq_reasm_flushtsn() local 968 __u32 tsn, last_tsn; sctp_ulpq_renege_list() local [all...] |
H A D | stream_interleave.c | 1114 __u32 tsn; in sctp_generate_iftsn() local 1124 tsn = ntohl(chunk->subh.data_hdr->tsn); in sctp_generate_iftsn() 1126 if (TSN_lte(tsn, ctsn)) { in sctp_generate_iftsn() 1129 } else if (TSN_lte(tsn, asoc->adv_peer_ack_point + 1)) { in sctp_generate_iftsn() 1137 asoc->adv_peer_ack_point = tsn; in sctp_generate_iftsn() 1220 __u32 tsn = event->tsn; in sctp_intl_reasm_flushtsn() local 1222 if (TSN_lte(tsn, ftsn)) { in sctp_intl_reasm_flushtsn() 1230 __u32 tsn in sctp_intl_reasm_flushtsn() local [all...] |
H A D | ulpevent.c | 709 ntohl(chunk->subh.data_hdr->tsn), in sctp_ulpevent_make_rcvmsg() 752 event->tsn = ntohl(chunk->subh.data_hdr->tsn); in sctp_ulpevent_make_rcvmsg() 1000 sinfo.sinfo_tsn = event->tsn; in sctp_ulpevent_read_sndrcvinfo() 1028 rinfo.rcv_tsn = event->tsn; in sctp_ulpevent_read_rcvinfo()
|
H A D | sm_statefuns.c | 2812 /* If Cumulative TSN Ack beyond the max tsn currently in sctp_sf_do_9_2_shutdown() 2897 /* If Cumulative TSN Ack beyond the max tsn currently in sctp_sf_do_9_2_shut_ctsn() 3355 /* If Cumulative TSN Ack beyond the max tsn currently in sctp_sf_eat_sack_6_2() 4099 __u32 tsn; in sctp_sf_eat_fwd_tsn() local 4121 tsn = ntohl(fwdtsn_hdr->new_cum_tsn); in sctp_sf_eat_fwd_tsn() 4122 pr_debug("%s: TSN 0x%x\n", __func__, tsn); in sctp_sf_eat_fwd_tsn() 4127 if (sctp_tsnmap_check(&asoc->peer.tsn_map, tsn) < 0) in sctp_sf_eat_fwd_tsn() 4133 sctp_add_cmd_sf(commands, SCTP_CMD_REPORT_FWDTSN, SCTP_U32(tsn)); in sctp_sf_eat_fwd_tsn() 4166 __u32 tsn; in sctp_sf_eat_fwd_tsn_fast() local 4188 tsn in sctp_sf_eat_fwd_tsn_fast() 6384 __u32 tsn; sctp_eat_data() local [all...] |
H A D | associola.c | 915 __u32 tsn) in sctp_assoc_lookup_tsn() 921 __be32 key = htonl(tsn); in sctp_assoc_lookup_tsn() 945 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn() 959 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn() 914 sctp_assoc_lookup_tsn(struct sctp_association *asoc, __u32 tsn) sctp_assoc_lookup_tsn() argument
|
/kernel/linux/linux-6.6/net/sctp/ |
H A D | tsnmap.c | 10 * These functions manipulate sctp tsn mapping array. 69 int sctp_tsnmap_check(const struct sctp_tsnmap *map, __u32 tsn) in sctp_tsnmap_check() argument 74 if (TSN_lte(tsn, map->cumulative_tsn_ack_point)) in sctp_tsnmap_check() 80 if (!TSN_lt(tsn, map->base_tsn + SCTP_TSN_MAP_SIZE)) in sctp_tsnmap_check() 84 gap = tsn - map->base_tsn; in sctp_tsnmap_check() 95 int sctp_tsnmap_mark(struct sctp_tsnmap *map, __u32 tsn, in sctp_tsnmap_mark() argument 100 if (TSN_lt(tsn, map->base_tsn)) in sctp_tsnmap_mark() 103 gap = tsn - map->base_tsn; in sctp_tsnmap_mark() 109 /* In this case the map has no gaps and the tsn we are in sctp_tsnmap_mark() 110 * recording is the next expected tsn in sctp_tsnmap_mark() 190 sctp_tsnmap_skip(struct sctp_tsnmap *map, __u32 tsn) sctp_tsnmap_skip() argument 300 sctp_tsnmap_renege(struct sctp_tsnmap *map, __u32 tsn) sctp_tsnmap_renege() argument [all...] |
H A D | outqueue.c | 42 static int sctp_acked(struct sctp_sackhdr *sack, __u32 tsn); 153 static inline int sctp_cacc_skip_3_2(struct sctp_transport *primary, __u32 tsn) in sctp_cacc_skip_3_2() argument 156 TSN_lt(tsn, primary->cacc.next_tsn_at_change)) in sctp_cacc_skip_3_2() 178 __u32 tsn) in sctp_cacc_skip() 182 sctp_cacc_skip_3_2(primary, tsn))) in sctp_cacc_skip() 327 ntsn = ntohl(nchunk->subh.data_hdr->tsn); in sctp_insert_list() 331 ltsn = ntohl(lchunk->subh.data_hdr->tsn); in sctp_insert_list() 1103 pr_debug("%s: outq:%p, chunk:%p[%s], tx-tsn:0x%x skb->head:%p skb->users:%d\n", in sctp_outq_flush_data() 1106 "illegal chunk", ntohl(chunk->subh.data_hdr->tsn), in sctp_outq_flush_data() 1117 pr_debug("%s: could not transmit tsn in sctp_outq_flush_data() 175 sctp_cacc_skip(struct sctp_transport *primary, struct sctp_transport *transport, int count_of_newacks, __u32 tsn) sctp_cacc_skip() argument 1255 __u32 sack_ctsn, ctsn, tsn; sctp_outq_sack() local 1445 __u32 tsn; sctp_check_transmitted() local 1716 __u32 tsn; sctp_mark_missing() local 1773 sctp_acked(struct sctp_sackhdr *sack, __u32 tsn) sctp_acked() argument 1829 __u32 tsn; sctp_generate_fwdtsn() local [all...] |
H A D | ulpqueue.c | 272 __u32 tsn, ctsn; in sctp_ulpq_store_reasm() local 274 tsn = event->tsn; in sctp_ulpq_store_reasm() 285 ctsn = cevent->tsn; in sctp_ulpq_store_reasm() 286 if (TSN_lt(ctsn, tsn)) { in sctp_ulpq_store_reasm() 294 ctsn = cevent->tsn; in sctp_ulpq_store_reasm() 296 if (TSN_lt(tsn, ctsn)) in sctp_ulpq_store_reasm() 427 ctsn = cevent->tsn; in sctp_ulpq_retrieve_reassembled() 524 ctsn = cevent->tsn; in sctp_ulpq_retrieve_partial() 588 /* Do not even bother unless this is the next tsn t in sctp_ulpq_reasm() 683 __u32 tsn; sctp_ulpq_reasm_flushtsn() local 962 __u32 tsn, last_tsn; sctp_ulpq_renege_list() local [all...] |
H A D | stream_interleave.c | 1106 __u32 tsn; in sctp_generate_iftsn() local 1116 tsn = ntohl(chunk->subh.data_hdr->tsn); in sctp_generate_iftsn() 1118 if (TSN_lte(tsn, ctsn)) { in sctp_generate_iftsn() 1121 } else if (TSN_lte(tsn, asoc->adv_peer_ack_point + 1)) { in sctp_generate_iftsn() 1129 asoc->adv_peer_ack_point = tsn; in sctp_generate_iftsn() 1212 __u32 tsn = event->tsn; in sctp_intl_reasm_flushtsn() local 1214 if (TSN_lte(tsn, ftsn)) { in sctp_intl_reasm_flushtsn() 1222 __u32 tsn in sctp_intl_reasm_flushtsn() local [all...] |
H A D | ulpevent.c | 709 ntohl(chunk->subh.data_hdr->tsn), in sctp_ulpevent_make_rcvmsg() 752 event->tsn = ntohl(chunk->subh.data_hdr->tsn); in sctp_ulpevent_make_rcvmsg() 1000 sinfo.sinfo_tsn = event->tsn; in sctp_ulpevent_read_sndrcvinfo() 1028 rinfo.rcv_tsn = event->tsn; in sctp_ulpevent_read_rcvinfo()
|
H A D | sm_statefuns.c | 2876 /* If Cumulative TSN Ack beyond the max tsn currently in sctp_sf_do_9_2_shutdown() 2961 /* If Cumulative TSN Ack beyond the max tsn currently in sctp_sf_do_9_2_shut_ctsn() 3419 /* If Cumulative TSN Ack beyond the max tsn currently in sctp_sf_eat_sack_6_2() 4202 __u32 tsn; in sctp_sf_eat_fwd_tsn() local 4224 tsn = ntohl(fwdtsn_hdr->new_cum_tsn); in sctp_sf_eat_fwd_tsn() 4225 pr_debug("%s: TSN 0x%x\n", __func__, tsn); in sctp_sf_eat_fwd_tsn() 4230 if (sctp_tsnmap_check(&asoc->peer.tsn_map, tsn) < 0) in sctp_sf_eat_fwd_tsn() 4236 sctp_add_cmd_sf(commands, SCTP_CMD_REPORT_FWDTSN, SCTP_U32(tsn)); in sctp_sf_eat_fwd_tsn() 4269 __u32 tsn; in sctp_sf_eat_fwd_tsn_fast() local 4291 tsn in sctp_sf_eat_fwd_tsn_fast() 6486 __u32 tsn; sctp_eat_data() local [all...] |
H A D | associola.c | 923 __u32 tsn) in sctp_assoc_lookup_tsn() 929 __be32 key = htonl(tsn); in sctp_assoc_lookup_tsn() 953 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn() 967 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn() 922 sctp_assoc_lookup_tsn(struct sctp_association *asoc, __u32 tsn) sctp_assoc_lookup_tsn() argument
|
/kernel/linux/linux-5.10/include/net/sctp/ |
H A D | tsnmap.h | 95 int sctp_tsnmap_check(const struct sctp_tsnmap *, __u32 tsn); 98 int sctp_tsnmap_mark(struct sctp_tsnmap *, __u32 tsn, 102 void sctp_tsnmap_skip(struct sctp_tsnmap *map, __u32 tsn); 122 /* Return pointer to duplicate tsn array as needed by SACK. */ 145 static inline void sctp_tsnmap_mark_dup(struct sctp_tsnmap *map, __u32 tsn) in sctp_tsnmap_mark_dup() argument 148 map->dup_tsns[map->num_dup_tsns++] = htonl(tsn); in sctp_tsnmap_mark_dup() 152 void sctp_tsnmap_renege(struct sctp_tsnmap *, __u32 tsn);
|
H A D | ulpevent.h | 50 __u32 tsn; member
|
H A D | sm.h | 209 __u32 tsn);
|
/kernel/linux/linux-6.6/include/net/sctp/ |
H A D | tsnmap.h | 95 int sctp_tsnmap_check(const struct sctp_tsnmap *, __u32 tsn); 98 int sctp_tsnmap_mark(struct sctp_tsnmap *, __u32 tsn, 102 void sctp_tsnmap_skip(struct sctp_tsnmap *map, __u32 tsn); 122 /* Return pointer to duplicate tsn array as needed by SACK. */ 145 static inline void sctp_tsnmap_mark_dup(struct sctp_tsnmap *map, __u32 tsn) in sctp_tsnmap_mark_dup() argument 148 map->dup_tsns[map->num_dup_tsns++] = htonl(tsn); in sctp_tsnmap_mark_dup() 152 void sctp_tsnmap_renege(struct sctp_tsnmap *, __u32 tsn);
|
H A D | ulpevent.h | 50 __u32 tsn; member
|
/kernel/linux/linux-5.10/block/ |
H A D | sed-opal.c | 86 u32 tsn; member 686 static int cmd_finalize(struct opal_dev *cmd, u32 hsn, u32 tsn) in cmd_finalize() argument 712 hdr->pkt.tsn = cpu_to_be32(tsn); in cmd_finalize() 1049 u32 hsn, tsn; in start_opal_session_cont() local 1057 tsn = response_get_u64(&dev->parsed, 5); in start_opal_session_cont() 1059 if (hsn != GENERIC_HOST_SESSION_NUM || tsn < FIRST_TPER_SESSION_NUM) { in start_opal_session_cont() 1065 dev->tsn = tsn; in start_opal_session_cont() 1088 dev->tsn in end_session_cont() [all...] |
H A D | opal_proto.h | 229 __be32 tsn; member
|
/kernel/linux/linux-5.10/include/linux/ |
H A D | sctp.h | 220 __be32 tsn; member 233 __be32 tsn; member
|
/kernel/linux/linux-6.6/include/linux/ |
H A D | sctp.h | 221 __be32 tsn; member 234 __be32 tsn; member
|
/kernel/linux/linux-6.6/block/ |
H A D | sed-opal.c | 90 u32 tsn; member 846 static int cmd_finalize(struct opal_dev *cmd, u32 hsn, u32 tsn) in cmd_finalize() argument 872 hdr->pkt.tsn = cpu_to_be32(tsn); in cmd_finalize() 1213 u32 hsn, tsn; in start_opal_session_cont() local 1221 tsn = response_get_u64(&dev->parsed, 5); in start_opal_session_cont() 1223 if (hsn != GENERIC_HOST_SESSION_NUM || tsn < FIRST_TPER_SESSION_NUM) { in start_opal_session_cont() 1229 dev->tsn = tsn; in start_opal_session_cont() 1252 dev->tsn in end_session_cont() [all...] |
H A D | opal_proto.h | 249 __be32 tsn; member
|