Home
last modified time | relevance | path

Searched refs:chunk (Results 1 – 25 of 38) sorted by relevance

12

/net/sctp/
A Dinqueue.c45 chunk->skb = chunk->head_skb; in sctp_inq_chunk_free()
132 if (chunk->head_skb == chunk->skb) { in sctp_inq_pop()
133 chunk->skb = skb_shinfo(chunk->skb)->frag_list; in sctp_inq_pop()
137 chunk->skb = chunk->skb->next; in sctp_inq_pop()
147 skb_pull(chunk->skb, chunk->chunk_end - chunk->skb->data); in sctp_inq_pop()
169 chunk->head_skb = chunk->skb; in sctp_inq_pop()
172 if (chunk->head_skb && chunk->skb->data_len == chunk->skb->len) in sctp_inq_pop()
173 chunk->skb = skb_shinfo(chunk->skb)->frag_list; in sctp_inq_pop()
201 cb->chunk = head_cb->chunk; in sctp_inq_pop()
217 chunk->chunk_end = skb_tail_pointer(chunk->skb); in sctp_inq_pop()
[all …]
A Doutput.c124 if (chunk) in sctp_packet_config()
187 packet, packet->size, chunk, chunk->skb ? chunk->skb->len : -1); in sctp_packet_transmit_chunk()
203 chunk); in sctp_packet_transmit_chunk()
261 if (!chunk->auth) in sctp_packet_bundle_auth()
362 if (chunk->asoc) in __sctp_packet_append_chunk()
492 padding = SCTP_PAD4(chunk->skb->len) - chunk->skb->len; in sctp_packet_pack()
500 skb_put_data(nskb, chunk->skb->data, chunk->skb->len); in sctp_packet_pack()
503 chunk, in sctp_packet_pack()
506 chunk->has_tsn ? ntohl(chunk->subh.data_hdr->tsn) : 0, in sctp_packet_pack()
507 ntohs(chunk->chunk_hdr->length), chunk->skb->len, in sctp_packet_pack()
[all …]
A Dchunk.c60 struct sctp_chunk *chunk; in sctp_datamsg_free() local
66 sctp_chunk_free(chunk); in sctp_datamsg_free()
86 sctp_chunk_put(chunk); in sctp_datamsg_destroy()
90 asoc = chunk->asoc; in sctp_datamsg_destroy()
111 sctp_chunk_put(chunk); in sctp_datamsg_destroy()
135 chunk->msg = msg; in sctp_datamsg_assign()
264 if (!chunk) { in sctp_datamsg_from_user()
273 chunk->shkey = shkey; in sctp_datamsg_from_user()
276 __skb_pull(chunk->skb, (__u8 *)chunk->chunk_hdr - in sctp_datamsg_from_user()
308 if (!chunk->has_tsn && in sctp_chunk_abandoned()
[all …]
A Doutqueue.c230 sctp_chunk_free(chunk); in __sctp_outq_teardown()
239 sctp_chunk_free(chunk); in __sctp_outq_teardown()
248 sctp_chunk_free(chunk); in __sctp_outq_teardown()
257 sctp_chunk_free(chunk); in __sctp_outq_teardown()
263 sctp_chunk_free(chunk); in __sctp_outq_teardown()
286 chunk && chunk->chunk_hdr ? in sctp_outq_tail()
295 __func__, q, chunk, chunk && chunk->chunk_hdr ? in sctp_outq_tail()
499 if (chunk->transport) in sctp_retransmit_mark()
1104 __func__, ctx->q, chunk, chunk && chunk->chunk_hdr ? in sctp_outq_flush_data()
1107 chunk->skb ? chunk->skb->head : NULL, chunk->skb ? in sctp_outq_flush_data()
[all …]
A Dsm_statefuns.c376 (struct sctp_init_chunk *)chunk->chunk_hdr, chunk, in sctp_sf_do_5_1B_init()
405 chunk->subh.init_hdr = (struct sctp_inithdr *)chunk->skb->data; in sctp_sf_do_5_1B_init()
426 if (!sctp_process_init(new_asoc, chunk, sctp_source(chunk), in sctp_sf_do_5_1B_init()
544 chunk->subh.init_hdr = (struct sctp_inithdr *)chunk->skb->data; in sctp_sf_do_5_1C_ack()
549 (struct sctp_init_chunk *)chunk->chunk_hdr, chunk, in sctp_sf_do_5_1C_ack()
749 if (!pskb_pull(chunk->skb, ntohs(chunk->chunk_hdr->length) - in sctp_sf_do_5_1D_ce()
935 chunk->head_skb ?: chunk->skb)) in sctp_sf_do_5_1E_ca()
1560 (struct sctp_init_chunk *)chunk->chunk_hdr, chunk, in sctp_sf_do_unexpected_init()
1612 if (!sctp_process_init(new_asoc, chunk, sctp_source(chunk), in sctp_sf_do_unexpected_init()
2280 chunk->head_skb ?: chunk->skb)) { in sctp_sf_do_5_2_4_dupcook()
[all …]
A Dsm_make_chunk.c586 if (chunk) in sctp_make_cookie_echo()
627 if (retval && chunk && chunk->transport) in sctp_make_cookie_ack()
685 if (chunk) in sctp_make_cwr()
864 if (chunk) in sctp_make_shutdown()
938 if (chunk && chunk->chunk_hdr && in sctp_make_abort()
992 if (chunk) in sctp_make_abort_no_data()
1059 chunk->chunk_end = skb_tail_pointer(chunk->skb); in sctp_addto_param()
1209 if (chunk) in sctp_make_heartbeat_ack()
1266 if (chunk) in sctp_make_op_error_space()
1539 chunk->chunk_end = skb_tail_pointer(chunk->skb); in sctp_addto_chunk()
[all …]
A Dulpevent.c79 struct sctp_chunk *chunk = event->chunk; in sctp_ulpevent_set_owner() local
90 if (chunk && chunk->head_skb && !chunk->head_skb->sk) in sctp_ulpevent_set_owner()
126 if (chunk) { in sctp_ulpevent_make_assoc_change()
130 skb = skb_copy_expand(chunk->skb, in sctp_ulpevent_make_assoc_change()
398 skb_pull(chunk->skb, elen); in sctp_ulpevent_make_remote_error()
676 struct sctp_chunk *chunk, in sctp_ulpevent_make_rcvmsg() argument
710 chunk->transport)) in sctp_ulpevent_make_rcvmsg()
742 sctp_chunk_hold(chunk); in sctp_ulpevent_make_rcvmsg()
743 event->chunk = chunk; in sctp_ulpevent_make_rcvmsg()
1133 sctp_chunk_put(event->chunk); in sctp_ulpevent_release_data()
[all …]
A Dsm_sideeffect.c712 if (!sctp_process_init(asoc, chunk, sctp_source(chunk), peer_init, gfp)) in sctp_cmd_process_init()
860 if (chunk->transport) in sctp_cmd_setup_t2()
861 t = chunk->transport; in sctp_cmd_setup_t2()
865 chunk->transport = t; in sctp_cmd_setup_t2()
967 chunk->transport = t; in sctp_cmd_setup_t4()
978 while (chunk->chunk_end > chunk->skb->data) { in sctp_cmd_process_operr()
1298 chunk = event_arg; in sctp_cmd_interpreter()
1414 if (cmd->obj.chunk) in sctp_cmd_interpreter()
1517 chunk); in sctp_cmd_interpreter()
1571 chunk = cmd->obj.chunk; in sctp_cmd_interpreter()
[all …]
A Dendpointola.c334 struct sctp_chunk *chunk; in sctp_endpoint_bh_rcv() local
368 chunk->auth_chunk = skb_clone(chunk->skb, in sctp_endpoint_bh_rcv()
370 chunk->auth = 1; in sctp_endpoint_bh_rcv()
381 if (NULL == chunk->asoc) { in sctp_endpoint_bh_rcv()
383 sctp_source(chunk), in sctp_endpoint_bh_rcv()
385 chunk->asoc = asoc; in sctp_endpoint_bh_rcv()
386 chunk->transport = transport; in sctp_endpoint_bh_rcv()
390 if (sctp_auth_recv_cid(subtype.chunk, asoc) && !chunk->auth) in sctp_endpoint_bh_rcv()
404 if (chunk->transport) in sctp_endpoint_bh_rcv()
410 if (error && chunk) in sctp_endpoint_bh_rcv()
[all …]
A Dstream_interleave.c55 if (chunk->has_mid) in sctp_chunk_assign_mid()
58 sid = sctp_chunk_stream_no(chunk); in sctp_chunk_assign_mid()
59 stream = &chunk->asoc->stream; in sctp_chunk_assign_mid()
98 stream = &chunk->asoc->stream; in sctp_validate_data()
99 sid = sctp_chunk_stream_no(chunk); in sctp_validate_data()
117 stream = &chunk->asoc->stream; in sctp_validate_idata()
826 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpevent_idata()
1105 struct sctp_chunk *chunk; in sctp_generate_iftsn() local
1120 sctp_chunk_free(chunk); in sctp_generate_iftsn()
1173 sctp_walk_fwdtsn(skip, chunk) in sctp_validate_fwdtsn()
[all …]
A Dstream.c236 sctp_chunk_free(chunk); in sctp_send_reconf()
338 if (!chunk) { in sctp_send_reset_streams()
398 if (!chunk) in sctp_send_reset_assoc()
461 if (!chunk) { in sctp_send_add_streams()
490 if (!chunk) in sctp_chunk_lookup_strreset_param()
656 if (!chunk) in sctp_process_strreset_inreq()
676 if (!chunk) in sctp_process_strreset_inreq()
679 return chunk; in sctp_process_strreset_inreq()
894 if (!chunk) in sctp_process_strreset_addstrm_in()
908 if (!chunk) in sctp_process_strreset_addstrm_in()
[all …]
A Dinput.c95 struct sctp_chunk *chunk; in sctp_rcv() local
198 if (!chunk) in sctp_rcv()
200 SCTP_INPUT_CB(skb)->chunk = chunk; in sctp_rcv()
203 chunk->rcvr = rcvr; in sctp_rcv()
236 sctp_chunk_free(chunk); in sctp_rcv()
243 sctp_inq_push(&chunk->rcvr->inqueue, chunk); in sctp_rcv()
278 struct sctp_chunk *chunk = SCTP_INPUT_CB(skb)->chunk; in sctp_backlog_rcv() local
284 rcvr = chunk->rcvr; in sctp_backlog_rcv()
291 sctp_chunk_free(chunk); in sctp_backlog_rcv()
329 sctp_chunk_free(chunk); in sctp_backlog_rcv()
[all …]
A Dassociola.c911 struct sctp_chunk *chunk; in sctp_assoc_lookup_tsn() local
936 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn()
950 if (key == chunk->subh.data_hdr->tsn) { in sctp_assoc_lookup_tsn()
969 struct sctp_chunk *chunk; in sctp_assoc_bh_rcv() local
1000 chunk->auth_chunk = skb_clone(chunk->skb, in sctp_assoc_bh_rcv()
1002 chunk->auth = 1; in sctp_assoc_bh_rcv()
1015 if (sctp_auth_recv_cid(subtype.chunk, asoc) && !chunk->auth) in sctp_assoc_bh_rcv()
1021 if (sctp_chunk_is_data(chunk)) in sctp_assoc_bh_rcv()
1030 if (chunk->transport) in sctp_assoc_bh_rcv()
1044 if (error && chunk) in sctp_assoc_bh_rcv()
[all …]
A Dauth.c387 struct sctp_chunk *chunk; in sctp_auth_asoc_init_active_key() local
414 list_for_each_entry(chunk, &asoc->outqueue.out_chunk_list, list) { in sctp_auth_asoc_init_active_key()
415 if (sctp_auth_send_cid(chunk->chunk_hdr->type, asoc)) { in sctp_auth_asoc_init_active_key()
416 chunk->auth = 1; in sctp_auth_asoc_init_active_key()
417 if (!chunk->shkey) { in sctp_auth_asoc_init_active_key()
418 chunk->shkey = asoc->shkey; in sctp_auth_asoc_init_active_key()
419 sctp_auth_shkey_hold(chunk->shkey); in sctp_auth_asoc_init_active_key()
638 static int __sctp_auth_cid(enum sctp_cid chunk, struct sctp_chunks_param *param) in __sctp_auth_cid() argument
664 if (param->chunks[i] == chunk) in __sctp_auth_cid()
682 return __sctp_auth_cid(chunk, asoc->peer.peer_chunks); in sctp_auth_send_cid()
[all …]
A Ddebug.c50 if (cid.chunk <= SCTP_CID_BASE_MAX) in sctp_cname()
51 return sctp_cid_tbl[cid.chunk]; in sctp_cname()
53 switch (cid.chunk) { in sctp_cname()
A Dulpqueue.c82 int sctp_ulpq_tail_data(struct sctp_ulpq *ulpq, struct sctp_chunk *chunk, in sctp_ulpq_tail_data() argument
90 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpq_tail_data()
94 event->ssn = ntohs(chunk->subh.data_hdr->ssn); in sctp_ulpq_tail_data()
95 event->ppid = chunk->subh.data_hdr->ppid; in sctp_ulpq_tail_data()
1069 void sctp_ulpq_renege(struct sctp_ulpq *ulpq, struct sctp_chunk *chunk, in sctp_ulpq_renege() argument
1076 needed = ntohs(chunk->chunk_hdr->length) - in sctp_ulpq_renege()
1085 if (sk_rmem_schedule(asoc->base.sk, chunk->skb, needed) && in sctp_ulpq_renege()
1087 int retval = sctp_ulpq_tail_data(ulpq, chunk, gfp); in sctp_ulpq_renege()
A Dsocket.c134 if (chunk->shkey) in sctp_set_owner_w()
141 skb_shinfo(chunk->skb)->destructor_arg = chunk; in sctp_set_owner_w()
151 skb_orphan(chunk->skb); in sctp_clear_owner_w()
156 msg = chunk->msg; \
623 if (!chunk) { in sctp_send_asconf_add_ip()
776 chunk = NULL; in sctp_send_asconf_del_ip()
870 if (!chunk) { in sctp_send_asconf_del_ip()
1778 if (!chunk) in sctp_sendmsg_check_sflags()
2139 if (event->chunk && event->chunk->head_skb) in sctp_recvmsg()
3364 if (!chunk) in sctp_setsockopt_peer_primary_addr()
[all …]
A Dobjcnt.c37 SCTP_DBG_OBJCNT(chunk);
50 SCTP_DBG_OBJCNT_ENTRY(chunk),
/net/sunrpc/xprtrdma/
A Dsvc_rdma_pcl.c24 kfree(chunk); in pcl_free()
32 chunk = kmalloc(struct_size(chunk, ch_segments, segcount), GFP_KERNEL); in pcl_alloc_chunk()
33 if (!chunk) in pcl_alloc_chunk()
40 return chunk; in pcl_alloc_chunk()
74 segment = &chunk->ch_segments[chunk->ch_segcount]; in pcl_set_read_segment()
121 if (!chunk) in pcl_alloc_call()
174 if (!chunk) { in pcl_alloc_read()
176 if (!chunk) in pcl_alloc_read()
214 if (!chunk) in pcl_alloc_write()
277 if (!chunk || !chunk->ch_payload_length) in pcl_process_nonpayloads()
[all …]
A Dsvc_rdma_rw.c212 info->wi_chunk = chunk; in svc_rdma_write_info_alloc()
614 chunk->ch_payload_length)) in svc_rdma_send_write_chunk()
650 struct svc_rdma_chunk *chunk; in svc_rdma_send_write_list() local
654 if (!chunk->ch_payload_length) in svc_rdma_send_write_list()
891 chunk = pcl_first_chunk(pcl); in svc_rdma_read_multiple_chunks()
892 length = chunk->ch_position; in svc_rdma_read_multiple_chunks()
897 pcl_for_each_chunk(chunk, pcl) { in svc_rdma_read_multiple_chunks()
902 next = pcl_next_chunk(pcl, chunk); in svc_rdma_read_multiple_chunks()
1016 chunk = pcl_first_chunk(pcl); in svc_rdma_read_call_chunk()
1017 length = chunk->ch_position; in svc_rdma_read_call_chunk()
[all …]
A Dsvc_rdma_sendto.c469 u32 remaining = chunk->ch_payload_length; in svc_rdma_encode_write_chunk()
507 struct svc_rdma_chunk *chunk; in svc_rdma_encode_write_list() local
543 struct svc_rdma_chunk *chunk; in svc_rdma_encode_reply_chunk() local
549 if (length > chunk->ch_length) in svc_rdma_encode_reply_chunk()
552 chunk->ch_payload_length = length; in svc_rdma_encode_reply_chunk()
1097 struct svc_rdma_chunk *chunk; in svc_rdma_result_payload() local
1099 chunk = rctxt->rc_cur_result_payload; in svc_rdma_result_payload()
1100 if (!length || !chunk) in svc_rdma_result_payload()
1105 if (length > chunk->ch_length) in svc_rdma_result_payload()
1107 chunk->ch_position = offset; in svc_rdma_result_payload()
[all …]
A Dsvc_rdma_recvfrom.c612 struct svc_rdma_chunk *chunk; in svc_rdma_get_inv_rkey() local
621 pcl_for_each_chunk(chunk, &ctxt->rc_call_pcl) { in svc_rdma_get_inv_rkey()
622 pcl_for_each_segment(segment, chunk) { in svc_rdma_get_inv_rkey()
629 pcl_for_each_chunk(chunk, &ctxt->rc_read_pcl) { in svc_rdma_get_inv_rkey()
630 pcl_for_each_segment(segment, chunk) { in svc_rdma_get_inv_rkey()
637 pcl_for_each_chunk(chunk, &ctxt->rc_write_pcl) { in svc_rdma_get_inv_rkey()
638 pcl_for_each_segment(segment, chunk) { in svc_rdma_get_inv_rkey()
645 pcl_for_each_chunk(chunk, &ctxt->rc_reply_pcl) { in svc_rdma_get_inv_rkey()
646 pcl_for_each_segment(segment, chunk) { in svc_rdma_get_inv_rkey()
802 buf->head[0].iov_len = chunk->ch_position; in svc_rdma_read_complete_one()
[all …]
/net/tls/
A Dtls_strp.c183 len -= chunk; in tls_strp_msg_hold()
228 chunk)); in tls_strp_copyin_frag()
247 chunk -= over; in tls_strp_copyin_frag()
251 len -= chunk; in tls_strp_copyin_frag()
262 chunk = min_t(size_t, chunk, PAGE_SIZE - skb_frag_size(frag)); in tls_strp_copyin_frag()
266 chunk)); in tls_strp_copyin_frag()
272 len -= chunk; in tls_strp_copyin_frag()
286 size_t chunk; in tls_strp_copyin_skb() local
293 chunk = min(chunk, in_len); in tls_strp_copyin_skb()
327 chunk -= over; in tls_strp_copyin_skb()
[all …]
A Dtls_sw.c92 if (chunk > 0) { in __skb_nsg()
1884 msg, chunk); in process_rx_list()
1888 len = len - chunk; in process_rx_list()
2074 if (chunk > 0) { in tls_sw_recvmsg()
2076 len -= chunk; in tls_sw_recvmsg()
2146 len -= chunk; in tls_sw_recvmsg()
2166 chunk = len; in tls_sw_recvmsg()
2174 peeked += chunk; in tls_sw_recvmsg()
2187 decrypted += chunk; in tls_sw_recvmsg()
2188 len -= chunk; in tls_sw_recvmsg()
[all …]
/net/bluetooth/
A Daf_bluetooth.c434 int chunk; in bt_sock_stream_recvmsg() local
467 copied += chunk; in bt_sock_stream_recvmsg()
468 size -= chunk; in bt_sock_stream_recvmsg()
475 if (chunk <= skb_len) { in bt_sock_stream_recvmsg()
476 __skb_pull(skb, chunk); in bt_sock_stream_recvmsg()
481 chunk -= skb_len; in bt_sock_stream_recvmsg()
484 if (chunk <= frag->len) { in bt_sock_stream_recvmsg()
486 skb->len -= chunk; in bt_sock_stream_recvmsg()
487 skb->data_len -= chunk; in bt_sock_stream_recvmsg()
488 __skb_pull(frag, chunk); in bt_sock_stream_recvmsg()
[all …]

Completed in 85 milliseconds

12