| /net/sctp/ |
| D | inqueue.c | 66 struct sctp_chunk *chunk, *tmp; in sctp_inq_free() local
69 list_for_each_entry_safe(chunk, tmp, &queue->in_chunk_list, list) { in sctp_inq_free()
70 list_del_init(&chunk->list); in sctp_inq_free()
71 sctp_chunk_free(chunk); in sctp_inq_free()
86 void sctp_inq_push(struct sctp_inq *q, struct sctp_chunk *chunk) in sctp_inq_push() argument
89 if (chunk->rcvr->dead) { in sctp_inq_push()
90 sctp_chunk_free(chunk); in sctp_inq_push()
99 list_add_tail(&chunk->list, &q->in_chunk_list); in sctp_inq_push()
100 if (chunk->asoc) in sctp_inq_push()
101 chunk->asoc->stats.ipackets++; in sctp_inq_push()
[all …]
|
| D | output.c | 68 struct sctp_chunk *chunk);
70 struct sctp_chunk *chunk);
72 struct sctp_chunk *chunk);
74 struct sctp_chunk *chunk,
94 struct sctp_chunk *chunk = NULL; in sctp_packet_config() local
102 chunk = sctp_get_ecne_prepend(packet->transport->asoc); in sctp_packet_config()
107 if (chunk) in sctp_packet_config()
108 sctp_packet_append_chunk(packet, chunk); in sctp_packet_config()
146 struct sctp_chunk *chunk, *tmp; in sctp_packet_free() local
150 list_for_each_entry_safe(chunk, tmp, &packet->chunk_list, list) { in sctp_packet_free()
[all …]
|
| D | outqueue.c | 227 struct sctp_chunk *chunk, *tmp; in __sctp_outq_teardown() local
233 chunk = list_entry(lchunk, struct sctp_chunk, in __sctp_outq_teardown()
236 sctp_chunk_fail(chunk, q->error); in __sctp_outq_teardown()
237 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()
253 chunk = list_entry(lchunk, struct sctp_chunk, in __sctp_outq_teardown()
255 sctp_chunk_fail(chunk, q->error); in __sctp_outq_teardown()
256 sctp_chunk_free(chunk); in __sctp_outq_teardown()
[all …]
|
| D | chunk.c | 82 struct sctp_chunk *chunk; in sctp_datamsg_free() local
87 list_for_each_entry(chunk, &msg->chunks, frag_list) in sctp_datamsg_free()
88 sctp_chunk_free(chunk); in sctp_datamsg_free()
97 struct sctp_chunk *chunk; in sctp_datamsg_destroy() local
109 chunk = list_entry(pos, struct sctp_chunk, frag_list); in sctp_datamsg_destroy()
112 asoc = chunk->asoc; in sctp_datamsg_destroy()
126 if (chunk->has_tsn) in sctp_datamsg_destroy()
131 ev = sctp_ulpevent_make_send_failed(asoc, chunk, sent, in sctp_datamsg_destroy()
137 sctp_chunk_put(chunk); in sctp_datamsg_destroy()
158 static void sctp_datamsg_assign(struct sctp_datamsg *msg, struct sctp_chunk *chunk) in sctp_datamsg_assign() argument
[all …]
|
| D | sm_statefuns.c | 72 struct sctp_chunk *chunk,
76 struct sctp_chunk *chunk,
80 const struct sctp_chunk *chunk);
84 const struct sctp_chunk *chunk,
105 static struct sctp_sackhdr *sctp_sm_pull_sack(struct sctp_chunk *chunk);
158 struct sctp_chunk *chunk);
175 sctp_chunk_length_valid(struct sctp_chunk *chunk, in sctp_chunk_length_valid() argument
178 __u16 chunk_length = ntohs(chunk->chunk_hdr->length); in sctp_chunk_length_valid()
228 struct sctp_chunk *chunk = arg; in sctp_sf_do_4_C() local
231 if (!sctp_vtag_verify_either(chunk, asoc)) in sctp_sf_do_4_C()
[all …]
|
| D | sm_make_chunk.c | 83 static void *sctp_addto_param(struct sctp_chunk *chunk, int len,
87 int sctp_chunk_iif(const struct sctp_chunk *chunk) in sctp_chunk_iif() argument
92 af = sctp_get_af_specific(ipver2af(ip_hdr(chunk->skb)->version)); in sctp_chunk_iif()
94 iif = af->skb_iif(chunk->skb); in sctp_chunk_iif()
117 void sctp_init_cause(struct sctp_chunk *chunk, __be16 cause_code, in sctp_init_cause() argument
127 chunk->subh.err_hdr = sctp_addto_chunk(chunk, sizeof(sctp_errhdr_t), &err); in sctp_init_cause()
135 static int sctp_init_cause_fixed(struct sctp_chunk *chunk, __be16 cause_code, in sctp_init_cause_fixed() argument
146 if (skb_tailroom(chunk->skb) < len) in sctp_init_cause_fixed()
148 chunk->subh.err_hdr = sctp_addto_chunk_fixed(chunk, in sctp_init_cause_fixed()
362 const struct sctp_chunk *chunk, in sctp_make_init_ack() argument
[all …]
|
| D | sm_sideeffect.c | 109 struct sctp_chunk *chunk) in sctp_do_ecn_ecne_work() argument
141 repl = sctp_make_cwr(asoc, asoc->last_cwr_tsn, chunk); in sctp_do_ecn_ecne_work()
577 struct sctp_chunk *chunk, in sctp_cmd_assoc_failed() argument
585 if (event_type == SCTP_EVENT_T_CHUNK && subtype.chunk == SCTP_CID_ABORT) in sctp_cmd_assoc_failed()
587 (__u16)error, 0, 0, chunk, in sctp_cmd_assoc_failed()
598 abort = sctp_make_violation_max_retrans(asoc, chunk); in sctp_cmd_assoc_failed()
619 struct sctp_chunk *chunk, in sctp_cmd_process_init() argument
630 if (!sctp_process_init(asoc, chunk, sctp_source(chunk), peer_init, gfp)) in sctp_cmd_process_init()
696 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 | ulpevent.c | 136 __u16 inbound, struct sctp_chunk *chunk, gfp_t gfp) in sctp_ulpevent_make_assoc_change() argument
145 if (chunk) { in sctp_ulpevent_make_assoc_change()
149 skb = skb_copy_expand(chunk->skb, in sctp_ulpevent_make_assoc_change()
165 ntohs(chunk->chunk_hdr->length) - in sctp_ulpevent_make_assoc_change()
377 const struct sctp_association *asoc, struct sctp_chunk *chunk, in sctp_ulpevent_make_remote_error() argument
387 ch = (sctp_errhdr_t *)(chunk->skb->data); in sctp_ulpevent_make_remote_error()
392 skb_pull(chunk->skb, sizeof(sctp_errhdr_t)); in sctp_ulpevent_make_remote_error()
397 skb = skb_copy_expand(chunk->skb, sizeof(struct sctp_remote_error), in sctp_ulpevent_make_remote_error()
401 skb_pull(chunk->skb, elen); in sctp_ulpevent_make_remote_error()
475 const struct sctp_association *asoc, struct sctp_chunk *chunk, in sctp_ulpevent_make_send_failed() argument
[all …]
|
| D | endpointola.c | 414 struct sctp_chunk *chunk; in sctp_endpoint_bh_rcv() local
429 while (NULL != (chunk = sctp_inq_pop(inqueue))) { in sctp_endpoint_bh_rcv()
430 subtype = SCTP_ST_CHUNK(chunk->chunk_hdr->type); in sctp_endpoint_bh_rcv()
435 if (first_time && (subtype.chunk == SCTP_CID_AUTH)) { in sctp_endpoint_bh_rcv()
448 chunk->auth_chunk = skb_clone(chunk->skb, in sctp_endpoint_bh_rcv()
450 chunk->auth = 1; in sctp_endpoint_bh_rcv()
461 if (NULL == chunk->asoc) { in sctp_endpoint_bh_rcv()
463 sctp_source(chunk), in sctp_endpoint_bh_rcv()
465 chunk->asoc = asoc; in sctp_endpoint_bh_rcv()
466 chunk->transport = transport; in sctp_endpoint_bh_rcv()
[all …]
|
| D | input.c | 115 struct sctp_chunk *chunk; member
129 struct sctp_chunk *chunk; in sctp_rcv() local
236 chunk = sctp_chunkify(skb, asoc, sk); in sctp_rcv()
237 if (!chunk) in sctp_rcv()
239 SCTP_INPUT_CB(skb)->chunk = chunk; in sctp_rcv()
242 chunk->rcvr = rcvr; in sctp_rcv()
245 chunk->sctp_hdr = sh; in sctp_rcv()
248 sctp_init_addrs(chunk, &src, &dest); in sctp_rcv()
251 chunk->transport = transport; in sctp_rcv()
275 sctp_chunk_free(chunk); in sctp_rcv()
[all …]
|
| D | debug.c | 76 if (cid.chunk <= SCTP_CID_BASE_MAX) in sctp_cname()
77 return sctp_cid_tbl[cid.chunk]; in sctp_cname()
79 switch (cid.chunk) { in sctp_cname()
|
| D | associola.c | 1013 struct sctp_chunk *chunk; in sctp_get_ecne_prepend() local
1019 chunk = sctp_make_ecne(asoc, asoc->last_ecne_tsn); in sctp_get_ecne_prepend()
1021 chunk = NULL; in sctp_get_ecne_prepend()
1023 return chunk; in sctp_get_ecne_prepend()
1035 struct sctp_chunk *chunk; in sctp_assoc_lookup_tsn() local
1057 list_for_each_entry(chunk, &active->transmitted, in sctp_assoc_lookup_tsn()
1060 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn()
1072 list_for_each_entry(chunk, &transport->transmitted, in sctp_assoc_lookup_tsn()
1074 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn()
1117 struct sctp_chunk *chunk; in sctp_assoc_bh_rcv() local
[all …]
|
| D | socket.c | 108 struct sctp_chunk *chunk);
162 static inline void sctp_set_owner_w(struct sctp_chunk *chunk) in sctp_set_owner_w() argument
164 struct sctp_association *asoc = chunk->asoc; in sctp_set_owner_w()
170 skb_set_owner_w(chunk->skb, sk); in sctp_set_owner_w()
172 chunk->skb->destructor = sctp_wfree; in sctp_set_owner_w()
174 *((struct sctp_chunk **)(chunk->skb->cb)) = chunk; in sctp_set_owner_w()
176 asoc->sndbuf_used += SCTP_DATA_SNDSIZE(chunk) + in sctp_set_owner_w()
181 sk->sk_wmem_queued += chunk->skb->truesize; in sctp_set_owner_w()
182 sk_mem_charge(sk, chunk->skb->truesize); in sctp_set_owner_w()
430 struct sctp_chunk *chunk) in sctp_send_asconf() argument
[all …]
|
| D | ulpqueue.c | 101 int sctp_ulpq_tail_data(struct sctp_ulpq *ulpq, struct sctp_chunk *chunk, in sctp_ulpq_tail_data() argument
109 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpq_tail_data()
1081 void sctp_ulpq_renege(struct sctp_ulpq *ulpq, struct sctp_chunk *chunk, in sctp_ulpq_renege() argument
1089 if (chunk) { in sctp_ulpq_renege()
1090 needed = ntohs(chunk->chunk_hdr->length); in sctp_ulpq_renege()
1104 if (chunk && (freed >= needed)) { in sctp_ulpq_renege()
1106 retval = sctp_ulpq_tail_data(ulpq, chunk, gfp); in sctp_ulpq_renege()
|
| D | objcnt.c | 59 SCTP_DBG_OBJCNT(chunk);
73 SCTP_DBG_OBJCNT_ENTRY(chunk),
|
| D | auth.c | 642 static int __sctp_auth_cid(sctp_cid_t chunk, struct sctp_chunks_param *param) in __sctp_auth_cid() argument
668 if (param->chunks[i] == chunk) in __sctp_auth_cid()
678 int sctp_auth_send_cid(sctp_cid_t chunk, const struct sctp_association *asoc) in sctp_auth_send_cid() argument
688 return __sctp_auth_cid(chunk, asoc->peer.peer_chunks); in sctp_auth_send_cid()
692 int sctp_auth_recv_cid(sctp_cid_t chunk, const struct sctp_association *asoc) in sctp_auth_recv_cid() argument
702 return __sctp_auth_cid(chunk, in sctp_auth_recv_cid()
|
| 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_iovec(skb, 0, msg->msg_iov, 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/core/ |
| D | datagram.c | 697 int chunk = skb->len - hlen; in skb_copy_and_csum_datagram_iovec() local
699 if (!chunk) in skb_copy_and_csum_datagram_iovec()
708 if (iov->iov_len < chunk) { in skb_copy_and_csum_datagram_iovec()
711 if (skb_copy_datagram_iovec(skb, hlen, iov, chunk)) in skb_copy_and_csum_datagram_iovec()
716 chunk, &csum)) in skb_copy_and_csum_datagram_iovec()
722 iov->iov_len -= chunk; in skb_copy_and_csum_datagram_iovec()
723 iov->iov_base += chunk; in skb_copy_and_csum_datagram_iovec()
|
| /net/rxrpc/ |
| D | ar-output.c | 567 size_t size, chunk, max, space; in rxrpc_send_data() local
586 chunk = max; in rxrpc_send_data()
587 if (chunk > len && !more) in rxrpc_send_data()
588 chunk = len; in rxrpc_send_data()
590 space = chunk + call->conn->size_align; in rxrpc_send_data()
595 _debug("SIZE: %zu/%zu/%zu", chunk, space, size); in rxrpc_send_data()
614 sp->remain = chunk; in rxrpc_send_data()
|
| /net/caif/ |
| D | caif_socket.c | 383 int chunk; in caif_stream_recvmsg() local
434 chunk = min_t(unsigned int, skb->len, size); in caif_stream_recvmsg()
435 if (memcpy_toiovec(msg->msg_iov, skb->data, chunk)) { in caif_stream_recvmsg()
441 copied += chunk; in caif_stream_recvmsg()
442 size -= chunk; in caif_stream_recvmsg()
446 skb_pull(skb, chunk); in caif_stream_recvmsg()
|
| /net/ipv4/ |
| D | tcp.c | 1778 int chunk; in tcp_recvmsg() local
1782 if ((chunk = len - tp->ucopy.len) != 0) { in tcp_recvmsg()
1783 NET_ADD_STATS_USER(sock_net(sk), LINUX_MIB_TCPDIRECTCOPYFROMBACKLOG, chunk); in tcp_recvmsg()
1784 len -= chunk; in tcp_recvmsg()
1785 copied += chunk; in tcp_recvmsg()
1793 if ((chunk = len - tp->ucopy.len) != 0) { in tcp_recvmsg()
1794 NET_ADD_STATS_USER(sock_net(sk), LINUX_MIB_TCPDIRECTCOPYFROMPREQUEUE, chunk); in tcp_recvmsg()
1795 len -= chunk; in tcp_recvmsg()
1796 copied += chunk; in tcp_recvmsg()
1908 int chunk; in tcp_recvmsg() local
[all …]
|
| /net/unix/ |
| D | af_unix.c | 2090 int chunk; in unix_stream_recvmsg() local
2164 chunk = min_t(unsigned int, skb->len - skip, size); in unix_stream_recvmsg()
2165 if (memcpy_toiovec(msg->msg_iov, skb->data + skip, chunk)) { in unix_stream_recvmsg()
2170 copied += chunk; in unix_stream_recvmsg()
2171 size -= chunk; in unix_stream_recvmsg()
2175 skb_pull(skb, chunk); in unix_stream_recvmsg()
2177 sk_peek_offset_bwd(sk, chunk); in unix_stream_recvmsg()
2196 sk_peek_offset_fwd(sk, chunk); in unix_stream_recvmsg()
|
| /net/irda/ |
| D | af_irda.c | 1457 int chunk; in irda_recvmsg_stream() local
1497 chunk = min_t(unsigned int, skb->len, size); in irda_recvmsg_stream()
1498 if (memcpy_toiovec(msg->msg_iov, skb->data, chunk)) { in irda_recvmsg_stream()
1504 copied += chunk; in irda_recvmsg_stream()
1505 size -= chunk; in irda_recvmsg_stream()
1509 skb_pull(skb, chunk); in irda_recvmsg_stream()
|
| /net/decnet/ |
| D | af_decnet.c | 1756 unsigned int chunk = skb->len; in dn_recvmsg() local
1759 if ((chunk + copied) > size) in dn_recvmsg()
1760 chunk = size - copied; in dn_recvmsg()
1762 if (memcpy_toiovec(msg->msg_iov, skb->data, chunk)) { in dn_recvmsg()
1766 copied += chunk; in dn_recvmsg()
1769 skb_pull(skb, chunk); in dn_recvmsg()
|