/Linux-v5.4/drivers/infiniband/sw/siw/ |
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 %pK, 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_hd) { in siw_rx_umem() [all …]
|
D | siw.h | 704 static inline void siw_crc_skb(struct siw_rx_stream *srx, unsigned int len) in siw_crc_skb() argument 710 __wsum crc = *(u32 *)shash_desc_ctx(srx->mpa_crc_hd); in siw_crc_skb() 712 crc = __skb_checksum(srx->skb, srx->skb_offset, len, crc, in siw_crc_skb() 714 *(u32 *)shash_desc_ctx(srx->mpa_crc_hd) = crc; in siw_crc_skb()
|
/Linux-v5.4/net/rxrpc/ |
D | peer_object.c | 29 const struct sockaddr_rxrpc *srx) in rxrpc_peer_hash_key() argument 38 hash_key += srx->transport_type; in rxrpc_peer_hash_key() 39 hash_key += srx->transport_len; in rxrpc_peer_hash_key() 40 hash_key += srx->transport.family; in rxrpc_peer_hash_key() 42 switch (srx->transport.family) { in rxrpc_peer_hash_key() 44 hash_key += (u16 __force)srx->transport.sin.sin_port; in rxrpc_peer_hash_key() 45 size = sizeof(srx->transport.sin.sin_addr); in rxrpc_peer_hash_key() 46 p = (u16 *)&srx->transport.sin.sin_addr; in rxrpc_peer_hash_key() 50 hash_key += (u16 __force)srx->transport.sin.sin_port; in rxrpc_peer_hash_key() 51 size = sizeof(srx->transport.sin6.sin6_addr); in rxrpc_peer_hash_key() [all …]
|
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 …]
|
D | local_object.c | 35 const struct sockaddr_rxrpc *srx) in rxrpc_local_cmp_key() argument 39 diff = ((local->srx.transport_type - srx->transport_type) ?: in rxrpc_local_cmp_key() 40 (local->srx.transport_len - srx->transport_len) ?: in rxrpc_local_cmp_key() 41 (local->srx.transport.family - srx->transport.family)); in rxrpc_local_cmp_key() 45 switch (srx->transport.family) { in rxrpc_local_cmp_key() 50 return ((u16 __force)local->srx.transport.sin.sin_port - in rxrpc_local_cmp_key() 51 (u16 __force)srx->transport.sin.sin_port) ?: in rxrpc_local_cmp_key() 52 memcmp(&local->srx.transport.sin.sin_addr, in rxrpc_local_cmp_key() 53 &srx->transport.sin.sin_addr, in rxrpc_local_cmp_key() 60 return ((u16 __force)local->srx.transport.sin6.sin6_port - in rxrpc_local_cmp_key() [all …]
|
D | peer_event.c | 30 struct sockaddr_rxrpc *srx) in rxrpc_lookup_peer_icmp_rcu() argument 36 memset(srx, 0, sizeof(*srx)); in rxrpc_lookup_peer_icmp_rcu() 37 srx->transport_type = local->srx.transport_type; in rxrpc_lookup_peer_icmp_rcu() 38 srx->transport_len = local->srx.transport_len; in rxrpc_lookup_peer_icmp_rcu() 39 srx->transport.family = local->srx.transport.family; in rxrpc_lookup_peer_icmp_rcu() 44 switch (srx->transport.family) { in rxrpc_lookup_peer_icmp_rcu() 46 srx->transport_len = sizeof(srx->transport.sin); in rxrpc_lookup_peer_icmp_rcu() 47 srx->transport.family = AF_INET; in rxrpc_lookup_peer_icmp_rcu() 48 srx->transport.sin.sin_port = serr->port; in rxrpc_lookup_peer_icmp_rcu() 52 memcpy(&srx->transport.sin.sin_addr, in rxrpc_lookup_peer_icmp_rcu() [all …]
|
D | af_rxrpc.c | 77 struct sockaddr_rxrpc *srx, in rxrpc_validate_address() argument 85 if (srx->srx_family != AF_RXRPC) in rxrpc_validate_address() 88 if (srx->transport_type != SOCK_DGRAM) in rxrpc_validate_address() 92 if (srx->transport_len < sizeof(sa_family_t) || in rxrpc_validate_address() 93 srx->transport_len > len) in rxrpc_validate_address() 96 if (srx->transport.family != rx->family && in rxrpc_validate_address() 97 srx->transport.family == AF_INET && rx->family != AF_INET6) in rxrpc_validate_address() 100 switch (srx->transport.family) { in rxrpc_validate_address() 102 if (srx->transport_len < sizeof(struct sockaddr_in)) in rxrpc_validate_address() 109 if (srx->transport_len < sizeof(struct sockaddr_in6)) in rxrpc_validate_address() [all …]
|
D | conn_object.c | 80 struct sockaddr_rxrpc srx; in rxrpc_find_connection_rcu() local 85 if (rxrpc_extract_addr_from_skb(&srx, skb) < 0) in rxrpc_find_connection_rcu() 88 if (srx.transport.family != local->srx.transport.family && in rxrpc_find_connection_rcu() 89 (srx.transport.family == AF_INET && in rxrpc_find_connection_rcu() 90 local->srx.transport.family != AF_INET6)) { in rxrpc_find_connection_rcu() 92 srx.transport.family, in rxrpc_find_connection_rcu() 93 local->srx.transport.family); in rxrpc_find_connection_rcu() 105 peer = rxrpc_lookup_peer_rcu(local, &srx); in rxrpc_find_connection_rcu() 130 switch (srx.transport.family) { in rxrpc_find_connection_rcu() 132 if (peer->srx.transport.sin.sin_port != in rxrpc_find_connection_rcu() [all …]
|
D | local_event.c | 30 struct sockaddr_rxrpc srx; in rxrpc_send_version_request() local 38 if (rxrpc_extract_addr_from_skb(&srx, skb) < 0) in rxrpc_send_version_request() 41 msg.msg_name = &srx.transport; in rxrpc_send_version_request() 42 msg.msg_namelen = srx.transport_len; in rxrpc_send_version_request()
|
D | output.c | 155 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_ack_packet() 156 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_ack_packet() 281 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_abort_packet() 282 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_abort_packet() 362 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_data_packet() 363 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_data_packet() 485 switch (conn->params.local->srx.transport.family) { in rxrpc_send_data_packet() 543 struct sockaddr_rxrpc srx; in rxrpc_reject_packets() local 560 msg.msg_name = &srx.transport; in rxrpc_reject_packets() 588 if (rxrpc_extract_addr_from_skb(&srx, skb) == 0) { in rxrpc_reject_packets() [all …]
|
D | proc.c | 81 sprintf(lbuff, "%pISpc", &local->srx.transport); in rxrpc_call_seq_show() 90 sprintf(rbuff, "%pISpc", &peer->srx.transport); in rxrpc_call_seq_show() 180 sprintf(lbuff, "%pISpc", &conn->params.local->srx.transport); in rxrpc_connection_seq_show() 182 sprintf(rbuff, "%pISpc", &conn->params.peer->srx.transport); in rxrpc_connection_seq_show() 232 sprintf(lbuff, "%pISpc", &peer->local->srx.transport); in rxrpc_peer_seq_show() 234 sprintf(rbuff, "%pISpc", &peer->srx.transport); in rxrpc_peer_seq_show()
|
D | call_object.c | 170 struct sockaddr_rxrpc *srx, in rxrpc_alloc_client_call() argument 183 call->service_id = srx->srx_service; in rxrpc_alloc_client_call() 218 struct sockaddr_rxrpc *srx, in rxrpc_new_client_call() argument 233 call = rxrpc_alloc_client_call(rx, srx, gfp, debug_id); in rxrpc_new_client_call() 290 ret = rxrpc_connect_call(rx, call, cp, srx, gfp); in rxrpc_new_client_call()
|
D | conn_event.c | 55 msg.msg_name = &conn->params.peer->srx.transport; in rxrpc_conn_retransmit_call() 56 msg.msg_namelen = conn->params.peer->srx.transport_len; in rxrpc_conn_retransmit_call() 216 msg.msg_name = &conn->params.peer->srx.transport; in rxrpc_abort_connection() 217 msg.msg_namelen = conn->params.peer->srx.transport_len; in rxrpc_abort_connection()
|
D | recvmsg.c | 545 struct sockaddr_rxrpc *srx = msg->msg_name; in rxrpc_recvmsg() local 546 size_t len = sizeof(call->peer->srx); in rxrpc_recvmsg() 548 memcpy(msg->msg_name, &call->peer->srx, len); in rxrpc_recvmsg() 549 srx->srx_service = call->service_id; in rxrpc_recvmsg()
|
D | security.c | 129 if (rx && (rx->srx.srx_service == conn->service_id || in rxrpc_init_server_conn_security()
|
D | conn_client.c | 278 struct sockaddr_rxrpc *srx, in rxrpc_get_client_conn() argument 289 cp->peer = rxrpc_lookup_peer(rx, cp->local, srx, gfp); in rxrpc_get_client_conn() 690 struct sockaddr_rxrpc *srx, in rxrpc_connect_call() argument 701 ret = rxrpc_get_client_conn(rx, call, cp, srx, gfp); in rxrpc_connect_call()
|
D | sendmsg.c | 575 DECLARE_SOCKADDR(struct sockaddr_rxrpc *, srx, msg->msg_name); in rxrpc_new_client_call_for_sendmsg() 594 cp.service_id = srx->srx_service; in rxrpc_new_client_call_for_sendmsg() 595 call = rxrpc_new_client_call(rx, &cp, srx, &p->call, GFP_KERNEL, in rxrpc_new_client_call_for_sendmsg()
|
D | ar-internal.h | 157 struct sockaddr_rxrpc srx; /* Primary Service/local addresses */ member 283 struct sockaddr_rxrpc srx; /* local address */ member 307 struct sockaddr_rxrpc srx; /* remote address */ member
|
D | rxkad.c | 664 msg.msg_name = &conn->params.peer->srx.transport; in rxkad_issue_challenge() 665 msg.msg_namelen = conn->params.peer->srx.transport_len; in rxkad_issue_challenge() 723 msg.msg_name = &conn->params.peer->srx.transport; in rxkad_send_response() 724 msg.msg_namelen = conn->params.peer->srx.transport_len; in rxkad_send_response()
|
/Linux-v5.4/fs/afs/ |
D | addr_list.c | 48 struct sockaddr_rxrpc *srx = &alist->addrs[i]; in afs_alloc_addrlist() local 49 srx->srx_family = AF_RXRPC; in afs_alloc_addrlist() 50 srx->srx_service = service; in afs_alloc_addrlist() 51 srx->transport_type = SOCK_DGRAM; in afs_alloc_addrlist() 52 srx->transport_len = sizeof(srx->transport.sin6); in afs_alloc_addrlist() 53 srx->transport.sin6.sin6_family = AF_INET6; in afs_alloc_addrlist() 54 srx->transport.sin6.sin6_port = htons(port); in afs_alloc_addrlist() 276 struct sockaddr_rxrpc *srx; in afs_merge_fs_addr4() local 301 srx = &alist->addrs[i]; in afs_merge_fs_addr4() 302 srx->srx_family = AF_RXRPC; in afs_merge_fs_addr4() [all …]
|
D | rxrpc.c | 39 struct sockaddr_rxrpc srx; in afs_open_socket() local 53 memset(&srx, 0, sizeof(srx)); in afs_open_socket() 54 srx.srx_family = AF_RXRPC; in afs_open_socket() 55 srx.srx_service = CM_SERVICE; in afs_open_socket() 56 srx.transport_type = SOCK_DGRAM; in afs_open_socket() 57 srx.transport_len = sizeof(srx.transport.sin6); in afs_open_socket() 58 srx.transport.sin6.sin6_family = AF_INET6; in afs_open_socket() 59 srx.transport.sin6.sin6_port = htons(AFS_CM_PORT); 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() [all …]
|
D | server.c | 33 const struct sockaddr_rxrpc *srx) in afs_find_server() argument 35 const struct sockaddr_in6 *a = &srx->transport.sin6, *b; in afs_find_server() 42 if (srx->transport.sin6.sin6_addr.s6_addr32[0] == 0 || in afs_find_server() 43 srx->transport.sin6.sin6_addr.s6_addr32[1] == 0 || in afs_find_server() 44 srx->transport.sin6.sin6_addr.s6_addr32[2] == htonl(0xffff)) in afs_find_server()
|
D | cmservice.c | 201 struct sockaddr_rxrpc srx; in afs_find_cm_server_by_peer() local 204 rxrpc_kernel_get_peer(call->net->socket, call->rxcall, &srx); in afs_find_cm_server_by_peer() 206 server = afs_find_server(call->net, &srx); in afs_find_cm_server_by_peer() 208 trace_afs_cm_no_server(call, &srx); in afs_find_cm_server_by_peer()
|
/Linux-v5.4/include/trace/events/ |
D | afs.h | 1064 TP_PROTO(struct afs_call *call, struct sockaddr_rxrpc *srx), 1066 TP_ARGS(call, srx), 1071 __field_struct(struct sockaddr_rxrpc, srx ) 1077 memcpy(&__entry->srx, srx, sizeof(__entry->srx)); 1081 __entry->call, __entry->op_id, &__entry->srx.transport)
|
D | rxrpc.h | 1441 struct sockaddr_rxrpc *srx), 1443 TP_ARGS(peer, ee, srx), 1448 __field_struct(struct sockaddr_rxrpc, srx ) 1454 memcpy(&__entry->srx, srx, sizeof(__entry->srx)); 1465 &__entry->srx.transport)
|