| /net/sctp/ |
| A D | stream_sched_rr.c | 32 if (pos == &stream->rr_list) in sctp_sched_rr_next_stream()
48 stream->rr_next = NULL; in sctp_sched_rr_unsched()
61 if (!stream->rr_next) in sctp_sched_rr_sched()
62 stream->rr_next = soute; in sctp_sched_rr_sched()
80 stream->rr_next = NULL; in sctp_sched_rr_init()
106 stream = &q->asoc->stream; in sctp_sched_rr_enqueue()
107 sctp_sched_rr_sched(stream, SCTP_SO(stream, sid)->ext); in sctp_sched_rr_enqueue()
112 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_rr_dequeue() local
121 if (stream->out_curr) in sctp_sched_rr_dequeue()
124 soute = stream->rr_next; in sctp_sched_rr_dequeue()
[all …]
|
| A D | stream.c | 31 asoc = container_of(stream, struct sctp_association, stream); in sctp_stream_shrink_out()
247 asoc = container_of(stream, struct sctp_association, stream); in sctp_stream_outq_is_empty()
268 struct sctp_stream *stream = &asoc->stream; in sctp_send_reset_streams() local
382 struct sctp_stream *stream = &asoc->stream; in sctp_send_reset_assoc() local
427 struct sctp_stream *stream = &asoc->stream; in sctp_send_add_streams() local
522 struct sctp_stream *stream = &asoc->stream; in sctp_process_strreset_outreq() local
611 struct sctp_stream *stream = &asoc->stream; in sctp_process_strreset_inreq() local
689 struct sctp_stream *stream = &asoc->stream; in sctp_process_strreset_tsnreq() local
785 struct sctp_stream *stream = &asoc->stream; in sctp_process_strreset_addstrm_out() local
855 struct sctp_stream *stream = &asoc->stream; in sctp_process_strreset_addstrm_in() local
[all …]
|
| A D | stream_sched_fc.c | 62 INIT_LIST_HEAD(&stream->fc_list); in sctp_sched_fc_init()
101 struct sctp_stream *stream; in sctp_sched_fc_enqueue() local
107 stream = &q->asoc->stream; in sctp_sched_fc_enqueue()
108 sctp_sched_fc_sched(stream, SCTP_SO(stream, sid)->ext); in sctp_sched_fc_enqueue()
113 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fc_dequeue() local
122 if (stream->out_curr) in sctp_sched_fc_dequeue()
123 soute = stream->out_curr->ext; in sctp_sched_fc_dequeue()
135 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fc_dequeue_done() local
174 asoc = container_of(stream, struct sctp_association, stream); in sctp_sched_fc_sched_all()
178 if (SCTP_SO(stream, sid)->ext) in sctp_sched_fc_sched_all()
[all …]
|
| A D | stream_sched.c | 60 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fcfs_dequeue() local
67 if (stream->out_curr) { in sctp_sched_fcfs_dequeue()
137 sched->unsched_all(stream); in sctp_sched_free_sched()
139 soute = SCTP_SO(stream, i)->ext; in sctp_sched_free_sched()
142 sched->free_sid(stream, i); in sctp_sched_free_sched()
168 n->init(&asoc->stream); in sctp_sched_set_sched()
209 if (sid >= asoc->stream.outcnt) in sctp_sched_set_value()
226 if (sid >= asoc->stream.outcnt) in sctp_sched_get_value()
248 q->asoc->stream.out_curr = sout; in sctp_sched_dequeue_done()
252 q->asoc->stream.out_curr = NULL; in sctp_sched_dequeue_done()
[all …]
|
| A D | stream_sched_prio.c | 75 for (i = 0; i < stream->outcnt; i++) { in sctp_sched_prio_get_head()
76 if (!SCTP_SO(stream, i)->ext) in sctp_sched_prio_get_head()
197 INIT_LIST_HEAD(&stream->prio_list); in sctp_sched_prio_init()
218 struct sctp_stream *stream; in sctp_sched_prio_enqueue() local
224 stream = &q->asoc->stream; in sctp_sched_prio_enqueue()
225 sctp_sched_prio_sched(stream, SCTP_SO(stream, sid)->ext); in sctp_sched_prio_enqueue()
230 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_prio_dequeue() local
242 if (stream->out_curr) { in sctp_sched_prio_dequeue()
243 soute = stream->out_curr->ext; in sctp_sched_prio_dequeue()
282 asoc = container_of(stream, struct sctp_association, stream); in sctp_sched_prio_sched_all()
[all …]
|
| A D | stream_interleave.c | 59 stream = &chunk->asoc->stream; in sctp_chunk_assign_mid()
98 stream = &chunk->asoc->stream; in sctp_validate_data()
117 stream = &chunk->asoc->stream; in sctp_validate_idata()
138 if (event->stream == cevent->stream && in sctp_intl_store_reasm()
149 event->stream > cevent->stream) { in sctp_intl_store_reasm()
158 if (event->stream < cevent->stream || in sctp_intl_store_reasm()
197 if (cevent->stream < event->stream) in sctp_intl_retrieve_partial()
277 if (cevent->stream < event->stream) in sctp_intl_retrieve_reassembled()
279 if (cevent->stream > event->stream) in sctp_intl_retrieve_reassembled()
425 stream = &ulpq->asoc->stream; in sctp_intl_retrieve_ordered()
[all …]
|
| A D | ulpqueue.c | 748 sid = event->stream; in sctp_ulpq_retrieve_ordered()
749 stream = &ulpq->asoc->stream; in sctp_ulpq_retrieve_ordered()
756 csid = cevent->stream; in sctp_ulpq_retrieve_ordered()
795 sid = event->stream; in sctp_ulpq_store_ordered()
799 csid = cevent->stream; in sctp_ulpq_store_ordered()
816 csid = cevent->stream; in sctp_ulpq_store_ordered()
841 sid = event->stream; in sctp_ulpq_order()
843 stream = &ulpq->asoc->stream; in sctp_ulpq_order()
878 stream = &ulpq->asoc->stream; in sctp_ulpq_reap_ordered()
885 csid = cevent->stream; in sctp_ulpq_reap_ordered()
[all …]
|
| A D | outqueue.c | 63 __u16 stream; in sctp_outq_head_data() local
68 stream = sctp_chunk_stream_no(ch); in sctp_outq_head_data()
69 oute = SCTP_SO(&q->asoc->stream, stream)->ext; in sctp_outq_head_data()
84 __u16 stream; in sctp_outq_tail_data() local
89 stream = sctp_chunk_stream_no(ch); in sctp_outq_tail_data()
90 oute = SCTP_SO(&q->asoc->stream, stream)->ext; in sctp_outq_tail_data()
409 asoc->stream.out_curr = NULL; in sctp_prsctp_prune_unsent()
417 q->sched->sched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
1809 int nskips, __be16 stream) in sctp_get_skip_pos() argument
1814 if (skiplist[i].stream == stream) in sctp_get_skip_pos()
[all …]
|
| A D | chunk.c | 99 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_datamsg_destroy()
108 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_datamsg_destroy()
177 sctp_datachk_len(&asoc->stream)); in sctp_datamsg_from_user()
262 chunk = asoc->stream.si->make_datafrag(asoc, sinfo, len, frag, in sctp_datamsg_from_user()
315 SCTP_SO(&chunk->asoc->stream, in sctp_chunk_abandoned()
330 SCTP_SO(&chunk->asoc->stream, in sctp_chunk_abandoned()
|
| A D | ulpevent.c | 355 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_ulpevent_notify_peer_addr_change()
450 skb_pull(skb, sctp_datachk_len(&asoc->stream)); in sctp_ulpevent_make_send_failed()
451 len -= sctp_datachk_len(&asoc->stream); in sctp_ulpevent_make_send_failed()
547 len -= sctp_datachk_len(&asoc->stream); in sctp_ulpevent_make_send_failed_event()
549 skb_pull(skb, sctp_datachk_len(&asoc->stream)); in sctp_ulpevent_make_send_failed_event()
747 event->stream = ntohs(chunk->subh.data_hdr->stream); in sctp_ulpevent_make_rcvmsg()
996 sinfo.sinfo_stream = event->stream; in sctp_ulpevent_read_sndrcvinfo()
1024 rinfo.rcv_sid = event->stream; in sctp_ulpevent_read_rcvinfo()
1047 nxtinfo.nxt_sid = event->stream; in __sctp_ulpevent_read_nxtinfo()
|
| A D | sm_sideeffect.c | 665 asoc->stream.si->abort_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_assoc_failed()
986 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_process_operr()
1059 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_assoc_change()
1069 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_peer_no_auth()
1081 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_adaptation_ind()
1352 asoc->stream.si->report_ftsn(&asoc->ulpq, cmd->obj.u32); in sctp_cmd_interpreter()
1356 asoc->stream.si->handle_ftsn(&asoc->ulpq, in sctp_cmd_interpreter()
1466 asoc->stream.si->ulpevent_data(&asoc->ulpq, in sctp_cmd_interpreter()
1476 asoc->stream.si->enqueue_event(&asoc->ulpq, in sctp_cmd_interpreter()
1727 asoc->stream.si->start_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_interpreter()
[all …]
|
| A D | associola.c | 232 if (sctp_stream_init(&asoc->stream, asoc->c.sinit_num_ostreams, 0, gfp)) in sctp_association_init()
279 sctp_stream_free(&asoc->stream); in sctp_association_init()
351 sctp_stream_free(&asoc->stream); in sctp_association_free()
1127 sctp_stream_clear(&asoc->stream); in sctp_assoc_update()
1153 sctp_stream_update(&asoc->stream, &new->stream); in sctp_assoc_update()
1383 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
1389 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
|
| A D | Makefile | 14 output.o input.o debug.o stream.o auth.o \
|
| A D | sm_statefuns.c | 3229 sctp_datahdr_len(&asoc->stream)); in sctp_sf_eat_data_6_2()
3345 sctp_datahdr_len(&asoc->stream)); in sctp_sf_eat_data_fast_4_4()
4244 if (!asoc->stream.si->validate_ftsn(chunk)) in sctp_sf_eat_fwd_tsn()
4248 if (len > sctp_ftsnhdr_len(&asoc->stream)) in sctp_sf_eat_fwd_tsn()
4311 if (!asoc->stream.si->validate_ftsn(chunk)) in sctp_sf_eat_fwd_tsn_fast()
4315 if (len > sctp_ftsnhdr_len(&asoc->stream)) in sctp_sf_eat_fwd_tsn_fast()
6550 datalen -= sctp_datachk_len(&asoc->stream); in sctp_eat_data()
6655 if (ntohs(data_hdr->stream) >= asoc->stream.incnt) { in sctp_eat_data()
6660 &data_hdr->stream, in sctp_eat_data()
6661 sizeof(data_hdr->stream), in sctp_eat_data()
[all …]
|
| A D | proc.c | 280 assoc->hbinterval, assoc->stream.incnt, in sctp_assocs_seq_show()
281 assoc->stream.outcnt, assoc->max_retrans, in sctp_assocs_seq_show()
|
| A D | sm_make_chunk.c | 91 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_control_release_owner()
726 dp.stream = htons(sinfo->sinfo_stream); in sctp_make_datafrag_empty()
1573 struct sctp_stream *stream; in sctp_chunk_assign_ssn() local
1582 sid = ntohs(chunk->subh.data_hdr->stream); in sctp_chunk_assign_ssn()
1583 stream = &chunk->asoc->stream; in sctp_chunk_assign_ssn()
1594 ssn = sctp_ssn_next(stream, out, sid); in sctp_chunk_assign_ssn()
1596 ssn = sctp_ssn_peek(stream, out, sid); in sctp_chunk_assign_ssn()
2485 if (sctp_stream_init(&asoc->stream, asoc->c.sinit_num_ostreams, in sctp_process_init()
3572 skip.stream = skiplist[i].stream; in sctp_make_fwdtsn()
|
| A D | output.c | 743 packet->overhead - sctp_datachk_len(&chunk->asoc->stream) - 4) in sctp_packet_can_append_data()
778 asoc->stream.si->assign_number(chunk); in sctp_packet_append_data()
|
| A D | socket.c | 1805 if (sinfo->sinfo_stream >= asoc->stream.outcnt) { in sctp_sendmsg_to_asoc()
1835 if (unlikely(sinfo->sinfo_stream >= asoc->stream.outcnt)) { in sctp_sendmsg_to_asoc()
2252 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_setsockopt_events()
3284 __u16 datasize = asoc ? sctp_datachk_len(&asoc->stream) : in sctp_setsockopt_maxseg()
4283 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_assoc_ulpevent_type_set()
5198 info->sctpi_instrms = asoc->stream.incnt; in sctp_get_sctp_info()
5199 info->sctpi_outstrms = asoc->stream.outcnt; in sctp_get_sctp_info()
5450 status.sstat_instrms = asoc->stream.incnt; in sctp_getsockopt_sctp_status()
5451 status.sstat_outstrms = asoc->stream.outcnt; in sctp_getsockopt_sctp_status()
7498 if (!asoc || params.sprstat_sid >= asoc->stream.outcnt) in sctp_getsockopt_pr_streamstatus()
[all …]
|
| A D | auth.c | 1014 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_auth_deact_key_id()
|
| /net/wireless/ |
| A D | wext-core.c | 1158 if (likely((stream + event_len) < ends)) { in iwe_stream_add_event()
1161 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_event()
1162 memcpy(stream + lcp_len, &iwe->u, in iwe_stream_add_event()
1164 stream += event_len; in iwe_stream_add_event()
1167 return stream; in iwe_stream_add_event()
1179 if (likely((stream + event_len) < ends)) { in iwe_stream_add_point()
1181 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_point()
1182 memcpy(stream + lcp_len, in iwe_stream_add_point()
1186 memcpy(stream + point_len, extra, iwe->u.data.length); in iwe_stream_add_point()
1187 stream += event_len; in iwe_stream_add_point()
[all …]
|
| /net/netfilter/ |
| A D | nf_conntrack_proto_udp.c | 109 bool stream = false; in nf_conntrack_udp_packet() local
114 stream = (status & IPS_ASSURED) == 0; in nf_conntrack_udp_packet()
124 if (stream && !test_and_set_bit(IPS_ASSURED_BIT, &ct->status)) in nf_conntrack_udp_packet()
|
| /net/bluetooth/rfcomm/ |
| A D | Kconfig | 6 RFCOMM provides connection oriented stream transport. RFCOMM
|
| /net/core/ |
| A D | Makefile | 6 obj-y := sock.o request_sock.o skbuff.o datagram.o stream.o scm.o \
|
| /net/rxrpc/ |
| A D | Kconfig | 34 bool "Inject packet loss into RxRPC packet stream"
|
| /net/xfrm/ |
| A D | Kconfig | 147 packet stream which in turn yields higher small-packet
|