| /net/sctp/ |
| D | inqueue.c | 59 struct sctp_chunk *chunk, *tmp; in sctp_inq_free() local
62 list_for_each_entry_safe(chunk, tmp, &queue->in_chunk_list, list) { in sctp_inq_free()
63 list_del_init(&chunk->list); in sctp_inq_free()
64 sctp_chunk_free(chunk); in sctp_inq_free()
79 void sctp_inq_push(struct sctp_inq *q, struct sctp_chunk *chunk) in sctp_inq_push() argument
82 if (chunk->rcvr->dead) { in sctp_inq_push()
83 sctp_chunk_free(chunk); in sctp_inq_push()
92 list_add_tail(&chunk->list, &q->in_chunk_list); in sctp_inq_push()
93 if (chunk->asoc) in sctp_inq_push()
94 chunk->asoc->stats.ipackets++; in sctp_inq_push()
[all …]
|
| D | output.c | 61 struct sctp_chunk *chunk);
63 struct sctp_chunk *chunk);
65 struct sctp_chunk *chunk);
67 struct sctp_chunk *chunk,
87 struct sctp_chunk *chunk = NULL; in sctp_packet_config() local
94 chunk = sctp_get_ecne_prepend(packet->transport->asoc); in sctp_packet_config()
99 if (chunk) in sctp_packet_config()
100 sctp_packet_append_chunk(packet, chunk); in sctp_packet_config()
137 struct sctp_chunk *chunk, *tmp; in sctp_packet_free() local
141 list_for_each_entry_safe(chunk, tmp, &packet->chunk_list, list) { in sctp_packet_free()
[all …]
|
| D | outqueue.c | 218 struct sctp_chunk *chunk, *tmp; in __sctp_outq_teardown() local
224 chunk = list_entry(lchunk, struct sctp_chunk, in __sctp_outq_teardown()
227 sctp_chunk_fail(chunk, q->error); in __sctp_outq_teardown()
228 sctp_chunk_free(chunk); in __sctp_outq_teardown()
235 chunk = list_entry(lchunk, struct sctp_chunk, in __sctp_outq_teardown()
237 sctp_chunk_fail(chunk, q->error); in __sctp_outq_teardown()
238 sctp_chunk_free(chunk); in __sctp_outq_teardown()
244 chunk = list_entry(lchunk, struct sctp_chunk, in __sctp_outq_teardown()
246 sctp_chunk_fail(chunk, q->error); in __sctp_outq_teardown()
247 sctp_chunk_free(chunk); in __sctp_outq_teardown()
[all …]
|
| D | chunk.c | 75 struct sctp_chunk *chunk; in sctp_datamsg_free() local
80 list_for_each_entry(chunk, &msg->chunks, frag_list) in sctp_datamsg_free()
81 sctp_chunk_free(chunk); in sctp_datamsg_free()
90 struct sctp_chunk *chunk; in sctp_datamsg_destroy() local
102 chunk = list_entry(pos, struct sctp_chunk, frag_list); in sctp_datamsg_destroy()
105 asoc = chunk->asoc; in sctp_datamsg_destroy()
119 if (chunk->has_tsn) in sctp_datamsg_destroy()
124 ev = sctp_ulpevent_make_send_failed(asoc, chunk, sent, in sctp_datamsg_destroy()
130 sctp_chunk_put(chunk); in sctp_datamsg_destroy()
151 static void sctp_datamsg_assign(struct sctp_datamsg *msg, struct sctp_chunk *chunk) in sctp_datamsg_assign() argument
[all …]
|
| D | sm_statefuns.c | 65 struct sctp_chunk *chunk,
69 struct sctp_chunk *chunk,
73 const struct sctp_chunk *chunk);
77 const struct sctp_chunk *chunk,
98 static struct sctp_sackhdr *sctp_sm_pull_sack(struct sctp_chunk *chunk);
149 struct sctp_chunk *chunk);
166 sctp_chunk_length_valid(struct sctp_chunk *chunk, in sctp_chunk_length_valid() argument
169 __u16 chunk_length = ntohs(chunk->chunk_hdr->length); in sctp_chunk_length_valid()
172 if (unlikely(chunk->pdiscard)) in sctp_chunk_length_valid()
181 static inline bool sctp_err_chunk_valid(struct sctp_chunk *chunk) in sctp_err_chunk_valid() argument
[all …]
|
| D | sm_make_chunk.c | 79 static void *sctp_addto_param(struct sctp_chunk *chunk, int len,
90 static void sctp_control_set_owner_w(struct sctp_chunk *chunk) in sctp_control_set_owner_w() argument
92 struct sctp_association *asoc = chunk->asoc; in sctp_control_set_owner_w()
93 struct sk_buff *skb = chunk->skb; in sctp_control_set_owner_w()
107 int sctp_chunk_iif(const struct sctp_chunk *chunk) in sctp_chunk_iif() argument
112 af = sctp_get_af_specific(ipver2af(ip_hdr(chunk->skb)->version)); in sctp_chunk_iif()
114 iif = af->skb_iif(chunk->skb); in sctp_chunk_iif()
137 void sctp_init_cause(struct sctp_chunk *chunk, __be16 cause_code, in sctp_init_cause() argument
147 chunk->subh.err_hdr = sctp_addto_chunk(chunk, sizeof(sctp_errhdr_t), &err); in sctp_init_cause()
155 static int sctp_init_cause_fixed(struct sctp_chunk *chunk, __be16 cause_code, in sctp_init_cause_fixed() argument
[all …]
|
| D | sm_sideeffect.c | 102 struct sctp_chunk *chunk) in sctp_do_ecn_ecne_work() argument
134 repl = sctp_make_cwr(asoc, asoc->last_cwr_tsn, chunk); in sctp_do_ecn_ecne_work()
571 struct sctp_chunk *chunk, in sctp_cmd_assoc_failed() argument
579 if (event_type == SCTP_EVENT_T_CHUNK && subtype.chunk == SCTP_CID_ABORT) in sctp_cmd_assoc_failed()
581 (__u16)error, 0, 0, chunk, in sctp_cmd_assoc_failed()
592 abort = sctp_make_violation_max_retrans(asoc, chunk); in sctp_cmd_assoc_failed()
613 struct sctp_chunk *chunk, in sctp_cmd_process_init() argument
624 if (!sctp_process_init(asoc, chunk, sctp_source(chunk), peer_init, gfp)) in sctp_cmd_process_init()
690 struct sctp_chunk *chunk) in sctp_cmd_transport_on() argument
746 hbinfo = (sctp_sender_hb_info_t *) chunk->skb->data; in sctp_cmd_transport_on()
[all …]
|
| D | endpointola.c | 413 struct sctp_chunk *chunk; in sctp_endpoint_bh_rcv() local
428 while (NULL != (chunk = sctp_inq_pop(inqueue))) { in sctp_endpoint_bh_rcv()
429 subtype = SCTP_ST_CHUNK(chunk->chunk_hdr->type); in sctp_endpoint_bh_rcv()
434 if (first_time && (subtype.chunk == SCTP_CID_AUTH)) { in sctp_endpoint_bh_rcv()
447 chunk->auth_chunk = skb_clone(chunk->skb, in sctp_endpoint_bh_rcv()
449 chunk->auth = 1; in sctp_endpoint_bh_rcv()
460 if (NULL == chunk->asoc) { in sctp_endpoint_bh_rcv()
462 sctp_source(chunk), in sctp_endpoint_bh_rcv()
464 chunk->asoc = asoc; in sctp_endpoint_bh_rcv()
465 chunk->transport = transport; in sctp_endpoint_bh_rcv()
[all …]
|
| D | ulpevent.c | 129 __u16 inbound, struct sctp_chunk *chunk, gfp_t gfp) in sctp_ulpevent_make_assoc_change() argument
138 if (chunk) { in sctp_ulpevent_make_assoc_change()
142 skb = skb_copy_expand(chunk->skb, in sctp_ulpevent_make_assoc_change()
158 ntohs(chunk->chunk_hdr->length) - in sctp_ulpevent_make_assoc_change()
371 struct sctp_chunk *chunk, __u16 flags, in sctp_ulpevent_make_remote_error() argument
381 ch = (sctp_errhdr_t *)(chunk->skb->data); in sctp_ulpevent_make_remote_error()
386 skb_pull(chunk->skb, sizeof(sctp_errhdr_t)); in sctp_ulpevent_make_remote_error()
391 skb = skb_copy_expand(chunk->skb, sizeof(*sre), 0, gfp); in sctp_ulpevent_make_remote_error()
394 skb_pull(chunk->skb, elen); in sctp_ulpevent_make_remote_error()
427 const struct sctp_association *asoc, struct sctp_chunk *chunk, in sctp_ulpevent_make_send_failed() argument
[all …]
|
| D | input.c | 100 struct sctp_chunk *chunk; member
114 struct sctp_chunk *chunk; in sctp_rcv() local
224 chunk = sctp_chunkify(skb, asoc, sk); in sctp_rcv()
225 if (!chunk) in sctp_rcv()
227 SCTP_INPUT_CB(skb)->chunk = chunk; in sctp_rcv()
230 chunk->rcvr = rcvr; in sctp_rcv()
233 chunk->sctp_hdr = sh; in sctp_rcv()
236 sctp_init_addrs(chunk, &src, &dest); in sctp_rcv()
239 chunk->transport = transport; in sctp_rcv()
263 sctp_chunk_free(chunk); in sctp_rcv()
[all …]
|
| D | debug.c | 65 if (cid.chunk <= SCTP_CID_BASE_MAX) in sctp_cname()
66 return sctp_cid_tbl[cid.chunk]; in sctp_cname()
68 switch (cid.chunk) { in sctp_cname()
|
| D | associola.c | 923 struct sctp_chunk *chunk; in sctp_assoc_lookup_tsn() local
945 list_for_each_entry(chunk, &active->transmitted, in sctp_assoc_lookup_tsn()
948 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn()
960 list_for_each_entry(chunk, &transport->transmitted, in sctp_assoc_lookup_tsn()
962 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn()
1005 struct sctp_chunk *chunk; in sctp_assoc_bh_rcv() local
1017 while (NULL != (chunk = sctp_inq_pop(inqueue))) { in sctp_assoc_bh_rcv()
1019 subtype = SCTP_ST_CHUNK(chunk->chunk_hdr->type); in sctp_assoc_bh_rcv()
1024 if (first_time && subtype.chunk == SCTP_CID_AUTH) { in sctp_assoc_bh_rcv()
1037 chunk->auth_chunk = skb_clone(chunk->skb, in sctp_assoc_bh_rcv()
[all …]
|
| D | auth.c | 391 struct sctp_chunk *chunk; in sctp_auth_asoc_init_active_key() local
417 list_for_each_entry(chunk, &asoc->outqueue.out_chunk_list, list) { in sctp_auth_asoc_init_active_key()
418 if (sctp_auth_send_cid(chunk->chunk_hdr->type, asoc)) in sctp_auth_asoc_init_active_key()
419 chunk->auth = 1; in sctp_auth_asoc_init_active_key()
639 static int __sctp_auth_cid(sctp_cid_t chunk, struct sctp_chunks_param *param) in __sctp_auth_cid() argument
665 if (param->chunks[i] == chunk) in __sctp_auth_cid()
675 int sctp_auth_send_cid(sctp_cid_t chunk, const struct sctp_association *asoc) in sctp_auth_send_cid() argument
683 return __sctp_auth_cid(chunk, asoc->peer.peer_chunks); in sctp_auth_send_cid()
687 int sctp_auth_recv_cid(sctp_cid_t chunk, const struct sctp_association *asoc) in sctp_auth_recv_cid() argument
695 return __sctp_auth_cid(chunk, in sctp_auth_recv_cid()
|
| D | socket.c | 99 struct sctp_chunk *chunk);
148 static inline void sctp_set_owner_w(struct sctp_chunk *chunk) in sctp_set_owner_w() argument
150 struct sctp_association *asoc = chunk->asoc; in sctp_set_owner_w()
156 skb_set_owner_w(chunk->skb, sk); in sctp_set_owner_w()
158 chunk->skb->destructor = sctp_wfree; in sctp_set_owner_w()
160 skb_shinfo(chunk->skb)->destructor_arg = chunk; in sctp_set_owner_w()
162 asoc->sndbuf_used += SCTP_DATA_SNDSIZE(chunk) + in sctp_set_owner_w()
167 sk->sk_wmem_queued += chunk->skb->truesize; in sctp_set_owner_w()
168 sk_mem_charge(sk, chunk->skb->truesize); in sctp_set_owner_w()
171 static void sctp_clear_owner_w(struct sctp_chunk *chunk) in sctp_clear_owner_w() argument
[all …]
|
| D | ulpqueue.c | 95 int sctp_ulpq_tail_data(struct sctp_ulpq *ulpq, struct sctp_chunk *chunk, in sctp_ulpq_tail_data() argument
103 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpq_tail_data()
1080 void sctp_ulpq_renege(struct sctp_ulpq *ulpq, struct sctp_chunk *chunk, in sctp_ulpq_renege() argument
1088 if (chunk) { in sctp_ulpq_renege()
1089 needed = ntohs(chunk->chunk_hdr->length); in sctp_ulpq_renege()
1103 if (chunk && (freed >= needed)) { in sctp_ulpq_renege()
1105 retval = sctp_ulpq_tail_data(ulpq, chunk, gfp); in sctp_ulpq_renege()
|
| D | objcnt.c | 52 SCTP_DBG_OBJCNT(chunk);
66 SCTP_DBG_OBJCNT_ENTRY(chunk),
|
| D | probe.c | 137 struct sctp_chunk *chunk = arg; in jsctp_sf_eat_sack() local
138 struct sk_buff *skb = chunk->skb; in jsctp_sf_eat_sack()
|
| D | Makefile | 10 transport.o chunk.o sm_make_chunk.o ulpevent.o \
|
| /net/bluetooth/ |
| D | af_bluetooth.c | 335 int chunk; in bt_sock_stream_recvmsg() local
361 chunk = min_t(unsigned int, skb->len, size); in bt_sock_stream_recvmsg()
362 if (skb_copy_datagram_msg(skb, 0, msg, chunk)) { in bt_sock_stream_recvmsg()
368 copied += chunk; in bt_sock_stream_recvmsg()
369 size -= chunk; in bt_sock_stream_recvmsg()
376 if (chunk <= skb_len) { in bt_sock_stream_recvmsg()
377 __skb_pull(skb, chunk); in bt_sock_stream_recvmsg()
382 chunk -= skb_len; in bt_sock_stream_recvmsg()
385 if (chunk <= frag->len) { in bt_sock_stream_recvmsg()
387 skb->len -= chunk; in bt_sock_stream_recvmsg()
[all …]
|
| /net/rxrpc/ |
| D | ar-output.c | 547 size_t size, chunk, max, space; in rxrpc_send_data() local
566 chunk = max; in rxrpc_send_data()
567 if (chunk > msg_data_left(msg) && !more) in rxrpc_send_data()
568 chunk = msg_data_left(msg); in rxrpc_send_data()
570 space = chunk + call->conn->size_align; in rxrpc_send_data()
575 _debug("SIZE: %zu/%zu/%zu", chunk, space, size); in rxrpc_send_data()
594 sp->remain = chunk; in rxrpc_send_data()
|
| /net/core/ |
| D | datagram.c | 710 int chunk = skb->len - hlen; in skb_copy_and_csum_datagram_msg() local
712 if (!chunk) in skb_copy_and_csum_datagram_msg()
715 if (msg_data_left(msg) < chunk) { in skb_copy_and_csum_datagram_msg()
718 if (skb_copy_datagram_msg(skb, hlen, msg, chunk)) in skb_copy_and_csum_datagram_msg()
723 chunk, &csum)) in skb_copy_and_csum_datagram_msg()
|
| /net/ipv4/ |
| D | tcp.c | 1781 int chunk; in tcp_recvmsg() local
1785 chunk = len - tp->ucopy.len; in tcp_recvmsg()
1786 if (chunk != 0) { in tcp_recvmsg()
1787 NET_ADD_STATS_USER(sock_net(sk), LINUX_MIB_TCPDIRECTCOPYFROMBACKLOG, chunk); in tcp_recvmsg()
1788 len -= chunk; in tcp_recvmsg()
1789 copied += chunk; in tcp_recvmsg()
1797 chunk = len - tp->ucopy.len; in tcp_recvmsg()
1798 if (chunk != 0) { in tcp_recvmsg()
1799 NET_ADD_STATS_USER(sock_net(sk), LINUX_MIB_TCPDIRECTCOPYFROMPREQUEUE, chunk); in tcp_recvmsg()
1800 len -= chunk; in tcp_recvmsg()
[all …]
|
| /net/unix/ |
| D | af_unix.c | 2320 int chunk; in unix_stream_read_generic() local
2401 chunk = min_t(unsigned int, unix_skb_len(skb) - skip, size); in unix_stream_read_generic()
2403 chunk = state->recv_actor(skb, skip, chunk, state); in unix_stream_read_generic()
2407 if (chunk < 0) { in unix_stream_read_generic()
2412 copied += chunk; in unix_stream_read_generic()
2413 size -= chunk; in unix_stream_read_generic()
2429 UNIXCB(skb).consumed += chunk; in unix_stream_read_generic()
2431 sk_peek_offset_bwd(sk, chunk); in unix_stream_read_generic()
2450 sk_peek_offset_fwd(sk, chunk); in unix_stream_read_generic()
2477 int skip, int chunk, in unix_stream_read_actor() argument
[all …]
|
| /net/caif/ |
| D | caif_socket.c | 373 int chunk; in caif_stream_recvmsg() local
424 chunk = min_t(unsigned int, skb->len, size); in caif_stream_recvmsg()
425 if (memcpy_to_msg(msg, skb->data, chunk)) { in caif_stream_recvmsg()
431 copied += chunk; in caif_stream_recvmsg()
432 size -= chunk; in caif_stream_recvmsg()
436 skb_pull(skb, chunk); in caif_stream_recvmsg()
|
| /net/irda/ |
| D | af_irda.c | 1439 int chunk; in irda_recvmsg_stream() local
1479 chunk = min_t(unsigned int, skb->len, size); in irda_recvmsg_stream()
1480 if (memcpy_to_msg(msg, skb->data, chunk)) { in irda_recvmsg_stream()
1486 copied += chunk; in irda_recvmsg_stream()
1487 size -= chunk; in irda_recvmsg_stream()
1491 skb_pull(skb, chunk); in irda_recvmsg_stream()
|