| /net/sctp/ |
| D | stream_sched_rr.c | 25 static void sctp_sched_rr_unsched_all(struct sctp_stream *stream);
27 static void sctp_sched_rr_next_stream(struct sctp_stream *stream) in sctp_sched_rr_next_stream() argument
31 pos = stream->rr_next->rr_list.next; in sctp_sched_rr_next_stream()
32 if (pos == &stream->rr_list) in sctp_sched_rr_next_stream()
34 stream->rr_next = list_entry(pos, struct sctp_stream_out_ext, rr_list); in sctp_sched_rr_next_stream()
37 static void sctp_sched_rr_unsched(struct sctp_stream *stream, in sctp_sched_rr_unsched() argument
40 if (stream->rr_next == soute) in sctp_sched_rr_unsched()
42 sctp_sched_rr_next_stream(stream); in sctp_sched_rr_unsched()
47 if (list_empty(&stream->rr_list)) in sctp_sched_rr_unsched()
48 stream->rr_next = NULL; in sctp_sched_rr_unsched()
[all …]
|
| D | stream.c | 25 static void sctp_stream_shrink_out(struct sctp_stream *stream, __u16 outcnt) in sctp_stream_shrink_out() argument
31 asoc = container_of(stream, struct sctp_association, stream); in sctp_stream_shrink_out()
55 static void sctp_stream_free_ext(struct sctp_stream *stream, __u16 sid) in sctp_stream_free_ext() argument
59 if (!SCTP_SO(stream, sid)->ext) in sctp_stream_free_ext()
62 sched = sctp_sched_ops_from_stream(stream); in sctp_stream_free_ext()
63 sched->free_sid(stream, sid); in sctp_stream_free_ext()
64 kfree(SCTP_SO(stream, sid)->ext); in sctp_stream_free_ext()
65 SCTP_SO(stream, sid)->ext = NULL; in sctp_stream_free_ext()
72 static void sctp_stream_outq_migrate(struct sctp_stream *stream, in sctp_stream_outq_migrate() argument
77 if (stream->outcnt > outcnt) in sctp_stream_outq_migrate()
[all …]
|
| D | stream_sched_prio.c | 26 static void sctp_sched_prio_unsched_all(struct sctp_stream *stream);
41 struct sctp_stream *stream, int prio, gfp_t gfp) in sctp_sched_prio_new_head() argument
59 struct sctp_stream *stream, int prio, gfp_t gfp) in sctp_sched_prio_get_head() argument
67 list_for_each_entry(p, &stream->prio_list, prio_sched) { in sctp_sched_prio_get_head()
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()
79 p = SCTP_SO(stream, i)->ext->prio_head; in sctp_sched_prio_get_head()
90 return sctp_sched_prio_new_head(stream, prio, gfp); in sctp_sched_prio_get_head()
130 static void sctp_sched_prio_sched(struct sctp_stream *stream, in sctp_sched_prio_sched() argument
153 list_for_each_entry(prio, &stream->prio_list, prio_sched) { in sctp_sched_prio_sched()
[all …]
|
| D | stream_sched.c | 25 static int sctp_sched_fcfs_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_set() argument
31 static int sctp_sched_fcfs_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_get() argument
38 static int sctp_sched_fcfs_init(struct sctp_stream *stream) in sctp_sched_fcfs_init() argument
43 static int sctp_sched_fcfs_init_sid(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_init_sid() argument
49 static void sctp_sched_fcfs_free_sid(struct sctp_stream *stream, __u16 sid) in sctp_sched_fcfs_free_sid() argument
53 static void sctp_sched_fcfs_free(struct sctp_stream *stream) in sctp_sched_fcfs_free() argument
64 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fcfs_dequeue() local
71 if (stream->out_curr) { in sctp_sched_fcfs_dequeue()
72 ch = list_entry(stream->out_curr->ext->outq.next, in sctp_sched_fcfs_dequeue()
90 static void sctp_sched_fcfs_sched_all(struct sctp_stream *stream) in sctp_sched_fcfs_sched_all() argument
[all …]
|
| D | stream_interleave.c | 33 dp.stream = htons(sinfo->sinfo_stream); in sctp_make_idatafrag_empty()
50 struct sctp_stream *stream; in sctp_chunk_assign_mid() local
59 stream = &chunk->asoc->stream; in sctp_chunk_assign_mid()
76 sctp_mid_uo_next(stream, out, sid) : in sctp_chunk_assign_mid()
77 sctp_mid_uo_peek(stream, out, sid); in sctp_chunk_assign_mid()
80 sctp_mid_next(stream, out, sid) : in sctp_chunk_assign_mid()
81 sctp_mid_peek(stream, out, sid); in sctp_chunk_assign_mid()
89 struct sctp_stream *stream; in sctp_validate_data() local
98 stream = &chunk->asoc->stream; in sctp_validate_data()
102 return !SSN_lt(ssn, sctp_ssn_peek(stream, in, sid)); in sctp_validate_data()
[all …]
|
| D | ulpqueue.c | 751 struct sctp_stream *stream; in sctp_ulpq_retrieve_ordered() local
754 sid = event->stream; in sctp_ulpq_retrieve_ordered()
755 stream = &ulpq->asoc->stream; in sctp_ulpq_retrieve_ordered()
762 csid = cevent->stream; in sctp_ulpq_retrieve_ordered()
773 if (cssn != sctp_ssn_peek(stream, in, sid)) in sctp_ulpq_retrieve_ordered()
777 sctp_ssn_next(stream, in, sid); in sctp_ulpq_retrieve_ordered()
801 sid = event->stream; in sctp_ulpq_store_ordered()
805 csid = cevent->stream; in sctp_ulpq_store_ordered()
822 csid = cevent->stream; in sctp_ulpq_store_ordered()
840 struct sctp_stream *stream; in sctp_ulpq_order() local
[all …]
|
| 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()
361 streamout = SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_sent()
389 q->sched->unsched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
403 sout = SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_unsent()
407 if (asoc->stream.out_curr == sout && in sctp_prsctp_prune_unsent()
[all …]
|
| 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()
|
| 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()
|
| D | sm_sideeffect.c | 659 asoc->stream.si->abort_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_assoc_failed()
980 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_process_operr()
1054 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_assoc_change()
1064 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_peer_no_auth()
1076 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_adaptation_ind()
1347 asoc->stream.si->report_ftsn(&asoc->ulpq, cmd->obj.u32); in sctp_cmd_interpreter()
1351 asoc->stream.si->handle_ftsn(&asoc->ulpq, in sctp_cmd_interpreter()
1461 asoc->stream.si->ulpevent_data(&asoc->ulpq, in sctp_cmd_interpreter()
1471 asoc->stream.si->enqueue_event(&asoc->ulpq, in sctp_cmd_interpreter()
1722 asoc->stream.si->start_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_interpreter()
[all …]
|
| 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()
352 sctp_stream_free(&asoc->stream); in sctp_association_free()
1146 sctp_stream_clear(&asoc->stream); in sctp_assoc_update()
1172 sctp_stream_update(&asoc->stream, &new->stream); in sctp_assoc_update()
1402 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
1408 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
|
| D | Makefile | 14 output.o input.o debug.o stream.o auth.o \
|
| D | proc.c | 282 assoc->hbinterval, assoc->stream.incnt, in sctp_assocs_seq_show()
283 assoc->stream.outcnt, assoc->max_retrans, in sctp_assocs_seq_show()
|
| D | sm_statefuns.c | 3193 if (!sctp_chunk_length_valid(chunk, sctp_datachk_len(&asoc->stream))) in sctp_sf_eat_data_6_2()
3214 sctp_datahdr_len(&asoc->stream)); in sctp_sf_eat_data_6_2()
3313 if (!sctp_chunk_length_valid(chunk, sctp_datachk_len(&asoc->stream))) in sctp_sf_eat_data_fast_4_4()
3330 sctp_datahdr_len(&asoc->stream)); in sctp_sf_eat_data_fast_4_4()
4210 if (!sctp_chunk_length_valid(chunk, sctp_ftsnchk_len(&asoc->stream))) in sctp_sf_eat_fwd_tsn()
4229 if (!asoc->stream.si->validate_ftsn(chunk)) in sctp_sf_eat_fwd_tsn()
4233 if (len > sctp_ftsnhdr_len(&asoc->stream)) in sctp_sf_eat_fwd_tsn()
4277 if (!sctp_chunk_length_valid(chunk, sctp_ftsnchk_len(&asoc->stream))) in sctp_sf_eat_fwd_tsn_fast()
4296 if (!asoc->stream.si->validate_ftsn(chunk)) in sctp_sf_eat_fwd_tsn_fast()
4300 if (len > sctp_ftsnhdr_len(&asoc->stream)) in sctp_sf_eat_fwd_tsn_fast()
[all …]
|
| D | sm_make_chunk.c | 91 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_control_release_owner()
734 dp.stream = htons(sinfo->sinfo_stream); in sctp_make_datafrag_empty()
1581 struct sctp_stream *stream; in sctp_chunk_assign_ssn() local
1590 sid = ntohs(chunk->subh.data_hdr->stream); in sctp_chunk_assign_ssn()
1591 stream = &chunk->asoc->stream; in sctp_chunk_assign_ssn()
1602 ssn = sctp_ssn_next(stream, out, sid); in sctp_chunk_assign_ssn()
1604 ssn = sctp_ssn_peek(stream, out, sid); in sctp_chunk_assign_ssn()
2493 if (sctp_stream_init(&asoc->stream, asoc->c.sinit_num_ostreams, in sctp_process_init()
3588 skip.stream = skiplist[i].stream; in sctp_make_fwdtsn()
|
| D | output.c | 742 packet->overhead - sctp_datachk_len(&chunk->asoc->stream) - 4) in sctp_packet_can_append_data()
777 asoc->stream.si->assign_number(chunk); in sctp_packet_append_data()
|
| D | socket.c | 1115 err = sctp_stream_init(&asoc->stream, outcnt, 0, GFP_KERNEL); in sctp_connect_new_asoc()
1806 if (sinfo->sinfo_stream >= asoc->stream.outcnt) { in sctp_sendmsg_to_asoc()
1811 if (unlikely(!SCTP_SO(&asoc->stream, sinfo->sinfo_stream)->ext)) { in sctp_sendmsg_to_asoc()
1812 err = sctp_stream_init_ext(&asoc->stream, sinfo->sinfo_stream); in sctp_sendmsg_to_asoc()
1839 if (unlikely(sinfo->sinfo_stream >= asoc->stream.outcnt)) { in sctp_sendmsg_to_asoc()
2250 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_setsockopt_events()
3282 __u16 datasize = asoc ? sctp_datachk_len(&asoc->stream) : in sctp_setsockopt_maxseg()
4281 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_assoc_ulpevent_type_set()
5196 info->sctpi_instrms = asoc->stream.incnt; in sctp_get_sctp_info()
5197 info->sctpi_outstrms = asoc->stream.outcnt; in sctp_get_sctp_info()
[all …]
|
| D | auth.c | 1014 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_auth_deact_key_id()
|
| /net/wireless/ |
| D | wext-core.c | 1133 char *iwe_stream_add_event(struct iw_request_info *info, char *stream, in iwe_stream_add_event() argument
1141 if (likely((stream + event_len) < ends)) { in iwe_stream_add_event()
1144 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_event()
1145 memcpy(stream + lcp_len, &iwe->u, in iwe_stream_add_event()
1147 stream += event_len; in iwe_stream_add_event()
1150 return stream; in iwe_stream_add_event()
1154 char *iwe_stream_add_point(struct iw_request_info *info, char *stream, in iwe_stream_add_point() argument
1162 if (likely((stream + event_len) < ends)) { in iwe_stream_add_point()
1164 memcpy(stream, (char *) iwe, IW_EV_LCP_PK_LEN); in iwe_stream_add_point()
1165 memcpy(stream + lcp_len, in iwe_stream_add_point()
[all …]
|
| /net/netfilter/ |
| D | nf_conntrack_proto_udp.c | 107 bool stream = false; in nf_conntrack_udp_packet() local
112 stream = true; in nf_conntrack_udp_packet()
122 if (stream && !test_and_set_bit(IPS_ASSURED_BIT, &ct->status)) in nf_conntrack_udp_packet()
|
| /net/bluetooth/rfcomm/ |
| D | Kconfig | 6 RFCOMM provides connection oriented stream transport. RFCOMM
|
| /net/core/ |
| D | Makefile | 6 obj-y := sock.o request_sock.o skbuff.o datagram.o stream.o scm.o \
|
| /net/rxrpc/ |
| D | Kconfig | 34 bool "Inject packet loss into RxRPC packet stream"
|
| /net/ |
| D | Kconfig | 311 Enabling this allows a TCP stream parser to be used with
|