Home
last modified time | relevance | path

Searched refs:srx (Results 1 – 25 of 26) sorted by relevance

12

/linux-6.15/drivers/infiniband/sw/siw/
H A Dsiw_qp_rx.c192 qp_id(rx_qp(srx)), sink_stag, srx->ddp_stag); in siw_rresp_check_ntoh()
562 bytes = min(srx->fpdu_part_rem, srx->skb_new); in siw_proc_write()
607 srx->ddp_to + srx->fpdu_part_rcvd, bytes); in siw_proc_write()
618 srx->ddp_to += srx->fpdu_part_rcvd; in siw_proc_write()
847 bytes = min(srx->fpdu_part_rem, srx->skb_new); in siw_proc_rresp()
860 srx->ddp_to += srx->fpdu_part_rcvd; in siw_proc_rresp()
955 u8 *tbuf = (u8 *)&srx->trailer.crc - srx->pad; in siw_get_trailer()
959 srx->fpdu_part_rem, srx->skb_new, srx->pad); in siw_get_trailer()
1354 srx->skb_copied += srx->skb_new; in siw_tcp_rx_data()
1366 srx->pad = -srx->fpdu_part_rem & 0x3; in siw_tcp_rx_data()
[all …]
H A Dsiw.h708 static inline void siw_crc_skb(struct siw_rx_stream *srx, unsigned int len) in siw_crc_skb() argument
714 __wsum crc = (__force __wsum)srx->mpa_crc; in siw_crc_skb()
716 crc = __skb_checksum(srx->skb, srx->skb_offset, len, crc, in siw_crc_skb()
718 srx->mpa_crc = (__force u32)crc; in siw_crc_skb()
H A Dsiw_qp.c370 struct siw_rx_stream *srx = &qp->rx_stream; in siw_send_terminate() local
371 union iwarp_hdr *rx_hdr = &srx->hdr; in siw_send_terminate()
/linux-6.15/net/rxrpc/
H A Dutils.c18 memset(srx, 0, sizeof(*srx)); in rxrpc_extract_addr_from_skb()
22 srx->transport_type = SOCK_DGRAM; in rxrpc_extract_addr_from_skb()
23 srx->transport_len = sizeof(srx->transport.sin); in rxrpc_extract_addr_from_skb()
24 srx->transport.sin.sin_family = AF_INET; in rxrpc_extract_addr_from_skb()
25 srx->transport.sin.sin_port = udp_hdr(skb)->source; in rxrpc_extract_addr_from_skb()
26 srx->transport.sin.sin_addr.s_addr = ip_hdr(skb)->saddr; in rxrpc_extract_addr_from_skb()
31 srx->transport_type = SOCK_DGRAM; in rxrpc_extract_addr_from_skb()
32 srx->transport_len = sizeof(srx->transport.sin6); in rxrpc_extract_addr_from_skb()
33 srx->transport.sin6.sin6_family = AF_INET6; in rxrpc_extract_addr_from_skb()
34 srx->transport.sin6.sin6_port = udp_hdr(skb)->source; in rxrpc_extract_addr_from_skb()
[all …]
H A Dpeer_object.c40 hash_key += srx->transport_type; in rxrpc_peer_hash_key()
41 hash_key += srx->transport_len; in rxrpc_peer_hash_key()
42 hash_key += srx->transport.family; in rxrpc_peer_hash_key()
44 switch (srx->transport.family) { in rxrpc_peer_hash_key()
87 (peer->srx.transport_type - srx->transport_type) ?: in rxrpc_peer_cmp_key()
88 (peer->srx.transport_len - srx->transport_len) ?: in rxrpc_peer_cmp_key()
89 (peer->srx.transport.family - srx->transport.family)); in rxrpc_peer_cmp_key()
93 switch (srx->transport.family) { in rxrpc_peer_cmp_key()
118 const struct sockaddr_rxrpc *srx, in __rxrpc_lookup_peer_rcu() argument
298 memcpy(&peer->srx, srx, sizeof(*srx)); in rxrpc_create_peer()
[all …]
H A Dlocal_object.c64 diff = ((local->srx.transport_type - srx->transport_type) ?: in rxrpc_local_cmp_key()
65 (local->srx.transport_len - srx->transport_len) ?: in rxrpc_local_cmp_key()
66 (local->srx.transport.family - srx->transport.family)); in rxrpc_local_cmp_key()
70 switch (srx->transport.family) { in rxrpc_local_cmp_key()
140 memcpy(&local->srx, srx, sizeof(*srx)); in rxrpc_alloc_local()
141 local->srx.srx_service = 0; in rxrpc_alloc_local()
165 struct sockaddr_rxrpc *srx = &local->srx; in rxrpc_open_socket() local
172 local, srx->transport_type, srx->transport.family); in rxrpc_open_socket()
203 switch (srx->transport.family) { in rxrpc_open_socket()
257 srx->transport_type, srx->transport.family, &srx->transport); in rxrpc_lookup_local()
[all …]
H A Dpeer_event.c30 struct sockaddr_rxrpc *srx) in rxrpc_lookup_peer_local_rcu() argument
36 memset(srx, 0, sizeof(*srx)); in rxrpc_lookup_peer_local_rcu()
37 srx->transport_type = local->srx.transport_type; in rxrpc_lookup_peer_local_rcu()
38 srx->transport_len = local->srx.transport_len; in rxrpc_lookup_peer_local_rcu()
39 srx->transport.family = local->srx.transport.family; in rxrpc_lookup_peer_local_rcu()
44 switch (srx->transport.family) { in rxrpc_lookup_peer_local_rcu()
46 srx->transport_len = sizeof(srx->transport.sin); in rxrpc_lookup_peer_local_rcu()
47 srx->transport.family = AF_INET; in rxrpc_lookup_peer_local_rcu()
77 srx->transport_len = sizeof(srx->transport.sin); in rxrpc_lookup_peer_local_rcu()
78 srx->transport.family = AF_INET; in rxrpc_lookup_peer_local_rcu()
[all …]
H A Daf_rxrpc.c77 struct sockaddr_rxrpc *srx, in rxrpc_validate_address() argument
85 if (srx->srx_family != AF_RXRPC) in rxrpc_validate_address()
93 srx->transport_len > len) in rxrpc_validate_address()
143 service_id = srx->srx_service; in rxrpc_bind()
149 rx->srx = *srx; in rxrpc_bind()
179 srx->srx_service = rx->srx.srx_service; in rxrpc_bind()
180 if (memcmp(srx, &rx->srx, sizeof(*srx)) != 0) in rxrpc_bind()
276 ret = rxrpc_validate_address(rx, srx, sizeof(*srx)); in rxrpc_kernel_lookup_peer()
549 rx->connect_srx = *srx; in rxrpc_connect()
592 rx->srx.srx_service = 0; in rxrpc_sendmsg()
[all …]
H A Dlocal_event.c39 struct sockaddr_rxrpc srx; in rxrpc_send_version_request() local
47 if (rxrpc_extract_addr_from_skb(&srx, skb) < 0) in rxrpc_send_version_request()
50 msg.msg_name = &srx.transport; in rxrpc_send_version_request()
51 msg.msg_namelen = srx.transport_len; in rxrpc_send_version_request()
H A Drxperf.c181 struct sockaddr_rxrpc srx; in rxperf_open_socket() local
193 memset(&srx, 0, sizeof(srx)); in rxperf_open_socket()
194 srx.srx_family = AF_RXRPC; in rxperf_open_socket()
195 srx.srx_service = RX_PERF_SERVICE; in rxperf_open_socket()
196 srx.transport_type = SOCK_DGRAM; in rxperf_open_socket()
197 srx.transport_len = sizeof(srx.transport.sin6); in rxperf_open_socket()
198 srx.transport.sin6.sin6_family = AF_INET6; in rxperf_open_socket()
199 srx.transport.sin6.sin6_port = htons(RXPERF_PORT); in rxperf_open_socket()
208 ret = kernel_bind(socket, (struct sockaddr *)&srx, sizeof(srx)); in rxperf_open_socket()
H A Doutput.c261 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_ack_packet()
262 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_ack_packet()
388 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_abort_packet()
389 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_abort_packet()
669 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_data_packet()
760 msg.msg_name = &conn->peer->srx.transport; in rxrpc_send_conn_abort()
809 struct sockaddr_rxrpc srx; in rxrpc_reject_packet() local
824 msg.msg_name = &srx.transport; in rxrpc_reject_packet()
848 msg.msg_namelen = srx.transport_len; in rxrpc_reject_packet()
882 msg.msg_name = &peer->srx.transport; in rxrpc_send_keepalive()
[all …]
H A Dconn_object.c97 struct sockaddr_rxrpc *srx, in rxrpc_find_client_connection_rcu() argument
120 switch (srx->transport.family) { in rxrpc_find_client_connection_rcu()
122 if (peer->srx.transport.sin.sin_port != in rxrpc_find_client_connection_rcu()
123 srx->transport.sin.sin_port) in rxrpc_find_client_connection_rcu()
128 if (peer->srx.transport.sin6.sin6_port != in rxrpc_find_client_connection_rcu()
129 srx->transport.sin6.sin6_port) in rxrpc_find_client_connection_rcu()
H A Dproc.c72 sprintf(lbuff, "%pISpc", &local->srx.transport); in rxrpc_call_seq_show()
164 sprintf(lbuff, "%pISpc", &conn->local->srx.transport); in rxrpc_connection_seq_show()
165 sprintf(rbuff, "%pISpc", &conn->peer->srx.transport); in rxrpc_connection_seq_show()
245 sprintf(lbuff, "%pISpc", &bundle->local->srx.transport); in rxrpc_bundle_seq_show()
246 sprintf(rbuff, "%pISpc", &bundle->peer->srx.transport); in rxrpc_bundle_seq_show()
293 sprintf(lbuff, "%pISpc", &peer->local->srx.transport); in rxrpc_peer_seq_show()
295 sprintf(rbuff, "%pISpc", &peer->srx.transport); in rxrpc_peer_seq_show()
415 sprintf(lbuff, "%pISpc", &local->srx.transport); in rxrpc_local_seq_show()
H A Dcall_accept.c277 peer->srx = *peer_srx; in rxrpc_alloc_incoming_call()
312 call->dest_srx = peer->srx; in rxrpc_alloc_incoming_call()
353 if (!rx || (sp->hdr.serviceId != rx->srx.srx_service && in rxrpc_new_incoming_call()
H A Dio_thread.c279 if (peer_srx.transport.family != local->srx.transport.family && in rxrpc_input_packet()
281 local->srx.transport.family != AF_INET6)) { in rxrpc_input_packet()
284 local->srx.transport.family); in rxrpc_input_packet()
H A Dconn_event.c116 msg.msg_name = &conn->peer->srx.transport; in rxrpc_conn_retransmit_call()
117 msg.msg_namelen = conn->peer->srx.transport_len; in rxrpc_conn_retransmit_call()
H A Dsendmsg.c618 DECLARE_SOCKADDR(struct sockaddr_rxrpc *, srx, msg->msg_name); in rxrpc_new_client_call_for_sendmsg()
627 peer = rxrpc_lookup_peer(rx->local, srx, GFP_KERNEL); in rxrpc_new_client_call_for_sendmsg()
644 cp.service_id = srx->srx_service; in rxrpc_new_client_call_for_sendmsg()
H A Dar-internal.h174 struct sockaddr_rxrpc srx; /* Primary Service/local addresses */ member
325 struct sockaddr_rxrpc srx; /* local address */ member
352 struct sockaddr_rxrpc srx; /* remote address */ member
1317 struct sockaddr_rxrpc *srx, gfp_t gfp);
H A Drxkad.c659 msg.msg_name = &conn->peer->srx.transport; in rxkad_issue_challenge()
660 msg.msg_namelen = conn->peer->srx.transport_len; in rxkad_issue_challenge()
717 msg.msg_name = &conn->peer->srx.transport; in rxkad_send_response()
718 msg.msg_namelen = conn->peer->srx.transport_len; in rxkad_send_response()
/linux-6.15/fs/afs/
H A Daddr_list.c286 struct sockaddr_rxrpc srx; in afs_merge_fs_addr4() local
293 srx.srx_family = AF_RXRPC; in afs_merge_fs_addr4()
294 srx.transport_type = SOCK_DGRAM; in afs_merge_fs_addr4()
295 srx.transport_len = sizeof(srx.transport.sin); in afs_merge_fs_addr4()
296 srx.transport.sin.sin_family = AF_INET; in afs_merge_fs_addr4()
297 srx.transport.sin.sin_port = htons(port); in afs_merge_fs_addr4()
298 srx.transport.sin.sin_addr.s_addr = xdr; in afs_merge_fs_addr4()
330 struct sockaddr_rxrpc srx; in afs_merge_fs_addr6() local
337 srx.srx_family = AF_RXRPC; in afs_merge_fs_addr6()
338 srx.transport_type = SOCK_DGRAM; in afs_merge_fs_addr6()
[all …]
H A Drxrpc.c41 struct sockaddr_rxrpc srx; in afs_open_socket() local
54 memset(&srx, 0, sizeof(srx)); in afs_open_socket()
55 srx.srx_family = AF_RXRPC; in afs_open_socket()
56 srx.srx_service = CM_SERVICE; in afs_open_socket()
57 srx.transport_type = SOCK_DGRAM; in afs_open_socket()
58 srx.transport_len = sizeof(srx.transport.sin6); in afs_open_socket()
67 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx)); in afs_open_socket()
69 srx.transport.sin6.sin6_port = 0; in afs_open_socket()
70 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx)); in afs_open_socket()
75 srx.srx_service = YFS_CM_SERVICE; in afs_open_socket()
[all …]
/linux-6.15/include/trace/events/
H A Dafs.h1284 TP_ARGS(call, srx),
1289 __field_struct(struct sockaddr_rxrpc, srx)
1295 memcpy(&__entry->srx, srx, sizeof(__entry->srx));
1668 __field_struct(struct sockaddr_rxrpc, srx)
1681 sizeof(__entry->srx));
1687 &__entry->srx.transport)
1715 sizeof(__entry->srx));
1721 &__entry->srx.transport)
1777 sizeof(__entry->srx));
1785 &__entry->srx.transport,
[all …]
H A Drxrpc.h1898 __field_struct(struct sockaddr_rxrpc, srx)
1906 __entry->srx = call->dest_srx;
1914 &__entry->srx.transport)
2028 struct sockaddr_rxrpc *srx),
2030 TP_ARGS(peer, ee, srx),
2035 __field_struct(struct sockaddr_rxrpc, srx)
2041 memcpy(&__entry->srx, srx, sizeof(__entry->srx));
2052 &__entry->srx.transport)
/linux-6.15/include/net/
H A Daf_rxrpc.h66 struct sockaddr_rxrpc *srx, gfp_t gfp);
/linux-6.15/Documentation/networking/
H A Drxrpc.rst558 struct sockaddr_rxrpc srx = {
566 bind(client, &srx, sizeof(srx));
588 struct sockaddr_rxrpc srx = {
596 connect(client, &srx, sizeof(srx));
669 struct sockaddr_rxrpc srx = {
677 bind(server, &srx, sizeof(srx));
804 struct sockaddr_rxrpc *srx,
817 connected client socket unless an alternative is supplied (srx is

12