| /linux/drivers/infiniband/sw/siw/ |
| H A D | siw_qp_rx.c | 29 static int siw_rx_umem(struct siw_rx_stream *srx, struct siw_umem *umem, in siw_rx_umem() argument
42 __func__, qp_id(rx_qp(srx)), in siw_rx_umem()
46 srx->skb_copied += copied; in siw_rx_umem()
47 srx->skb_new -= copied; in siw_rx_umem()
54 siw_dbg_qp(rx_qp(srx), "page %p, bytes=%u\n", p, bytes); in siw_rx_umem()
57 rv = skb_copy_bits(srx->skb, srx->skb_offset, dest + pg_off, in siw_rx_umem()
62 srx->skb_copied += copied; in siw_rx_umem()
63 srx->skb_new -= copied; in siw_rx_umem()
66 qp_id(rx_qp(srx)), __func__, len, p, rv); in siw_rx_umem()
70 if (srx->mpa_crc_enabled) { in siw_rx_umem()
[all …]
|
| H A D | siw.h | 696 static inline void siw_crc_skb(struct siw_rx_stream *srx, unsigned int len) in siw_crc_skb() argument
698 srx->mpa_crc = skb_crc32c(srx->skb, srx->skb_offset, len, srx->mpa_crc); in siw_crc_skb()
|
| /linux/net/rxrpc/ |
| H A D | peer_object.c | 31 const struct sockaddr_rxrpc *srx) in rxrpc_peer_hash_key() argument
40 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()
46 hash_key += (u16 __force)srx->transport.sin.sin_port; in rxrpc_peer_hash_key()
47 size = sizeof(srx->transport.sin.sin_addr); in rxrpc_peer_hash_key()
48 p = (u16 *)&srx->transport.sin.sin_addr; in rxrpc_peer_hash_key()
52 hash_key += (u16 __force)srx->transport.sin.sin_port; in rxrpc_peer_hash_key()
53 size = sizeof(srx->transport.sin6.sin6_addr); in rxrpc_peer_hash_key()
[all …]
|
| H A D | utils.c | 16 int rxrpc_extract_addr_from_skb(struct sockaddr_rxrpc *srx, struct sk_buff *skb) in rxrpc_extract_addr_from_skb() argument
18 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()
[all …]
|
| H A D | peer_event.c | 30 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()
48 srx->transport.sin.sin_port = serr->port; in rxrpc_lookup_peer_local_rcu()
51 memcpy(&srx->transport.sin.sin_addr, in rxrpc_lookup_peer_local_rcu()
[all …]
|
| H A D | local_event.c | 39 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 D | output.c | 261 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()
670 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_data_packet()
760 msg.msg_name = &conn->peer->srx.transport; in rxrpc_send_conn_abort()
761 msg.msg_namelen = conn->peer->srx.transport_len; in rxrpc_send_conn_abort()
809 struct sockaddr_rxrpc srx; in rxrpc_reject_packet() local
827 msg.msg_name = &srx.transport; in rxrpc_reject_packet()
[all …]
|
| H A D | conn_object.c | 98 struct sockaddr_rxrpc *srx, in rxrpc_find_client_connection_rcu()
121 switch (srx->transport.family) { in rxrpc_find_client_connection_rcu()
123 if (peer->srx.transport.sin.sin_port != in rxrpc_find_client_connection_rcu()
124 srx->transport.sin.sin_port) in rxrpc_find_client_connection_rcu()
129 if (peer->srx.transport.sin6.sin6_port != in rxrpc_find_client_connection_rcu()
130 srx->transport.sin6.sin6_port) in rxrpc_find_client_connection_rcu()
97 rxrpc_find_client_connection_rcu(struct rxrpc_local * local,struct sockaddr_rxrpc * srx,struct sk_buff * skb) rxrpc_find_client_connection_rcu() argument
|
| H A D | call_accept.c | 283 peer->srx = *peer_srx; in rxrpc_alloc_incoming_call()
318 call->dest_srx = peer->srx; in rxrpc_alloc_incoming_call()
359 if (!rx || (sp->hdr.serviceId != rx->srx.srx_service && in rxrpc_new_incoming_call()
|
| H A D | io_thread.c | 293 if (peer_srx.transport.family != local->srx.transport.family && in rxrpc_input_packet()
295 local->srx.transport.family != AF_INET6)) { in rxrpc_input_packet()
298 local->srx.transport.family); in rxrpc_input_packet()
|
| H A D | conn_event.c | 124 msg.msg_name = &conn->peer->srx.transport; in rxrpc_conn_retransmit_call()
125 msg.msg_namelen = conn->peer->srx.transport_len; in rxrpc_conn_retransmit_call()
|
| H A D | sendmsg.c | 618 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 D | ar-internal.h | 180 struct sockaddr_rxrpc srx; /* Primary Service/local addresses */ member
364 struct sockaddr_rxrpc srx; /* local address */ member
394 struct sockaddr_rxrpc srx; /* remote address */ member
1388 struct sockaddr_rxrpc *srx, gfp_t gfp);
|
| H A D | rxkad.c | 661 msg.msg_name = &conn->peer->srx.transport; in rxkad_issue_challenge()
662 msg.msg_namelen = conn->peer->srx.transport_len; in rxkad_issue_challenge()
|
| H A D | rxgk.c | 654 msg.msg_name = &conn->peer->srx.transport; in rxgk_issue_challenge()
655 msg.msg_namelen = conn->peer->srx.transport_len; in rxgk_issue_challenge()
|
| H A D | call_object.c | 206 call->dest_srx = cp->peer->srx; in rxrpc_alloc_client_call()
|
| /linux/include/trace/events/ |
| H A D | afs.h | 1295 TP_PROTO(struct afs_call *call, const struct sockaddr_rxrpc *srx),
1297 TP_ARGS(call, srx),
1302 __field_struct(struct sockaddr_rxrpc, srx)
1308 memcpy(&__entry->srx, srx, sizeof(__entry->srx));
1312 __entry->call, __entry->op_id, &__entry->srx.transport)
1681 __field_struct(struct sockaddr_rxrpc, srx)
1693 memcpy(&__entry->srx, rxrpc_kernel_remote_srx(alist->addrs[addr_index].peer),
1694 sizeof(__entry->srx));
1700 &__entry->srx.transport)
1717 __field_struct(struct sockaddr_rxrpc, srx)
[all …]
|
| H A D | rxrpc.h | 2035 __field_struct(struct sockaddr_rxrpc, srx)
2043 __entry->srx = call->dest_srx;
2051 &__entry->srx.transport)
2165 struct sockaddr_rxrpc *srx),
2167 TP_ARGS(peer, ee, srx),
2172 __field_struct(struct sockaddr_rxrpc, srx)
2178 memcpy(&__entry->srx, srx, sizeof(__entry->srx));
2189 &__entry->srx.transport)
|