| // SPDX-License-Identifier: GPL-2.0-or-later | |
| /* RxRPC security handling | |
| * | |
| * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved. | |
| * Written by David Howells (dhowells@redhat.com) | |
| */ | |
| #include <linux/module.h> | |
| #include <linux/net.h> | |
| #include <linux/skbuff.h> | |
| #include <linux/udp.h> | |
| #include <linux/crypto.h> | |
| #include <net/sock.h> | |
| #include <net/af_rxrpc.h> | |
| #include <keys/rxrpc-type.h> | |
| #include "ar-internal.h" | |
| static const struct rxrpc_security *rxrpc_security_types[] = { | |
| [RXRPC_SECURITY_NONE] = &rxrpc_no_security, | |
| #ifdef CONFIG_RXKAD | |
| [RXRPC_SECURITY_RXKAD] = &rxkad, | |
| #endif | |
| }; | |
| int __init rxrpc_init_security(void) | |
| { | |
| int i, ret; | |
| for (i = 0; i < ARRAY_SIZE(rxrpc_security_types); i++) { | |
| if (rxrpc_security_types[i]) { | |
| ret = rxrpc_security_types[i]->init(); | |
| if (ret < 0) | |
| goto failed; | |
| } | |
| } | |
| return 0; | |
| failed: | |
| for (i--; i >= 0; i--) | |
| if (rxrpc_security_types[i]) | |
| rxrpc_security_types[i]->exit(); | |
| return ret; | |
| } | |
| void rxrpc_exit_security(void) | |
| { | |
| int i; | |
| for (i = 0; i < ARRAY_SIZE(rxrpc_security_types); i++) | |
| if (rxrpc_security_types[i]) | |
| rxrpc_security_types[i]->exit(); | |
| } | |
| /* | |
| * look up an rxrpc security module | |
| */ | |
| const struct rxrpc_security *rxrpc_security_lookup(u8 security_index) | |
| { | |
| if (security_index >= ARRAY_SIZE(rxrpc_security_types)) | |
| return NULL; | |
| return rxrpc_security_types[security_index]; | |
| } | |
| /* | |
| * initialise the security on a client connection | |
| */ | |
| int rxrpc_init_client_conn_security(struct rxrpc_connection *conn) | |
| { | |
| const struct rxrpc_security *sec; | |
| struct rxrpc_key_token *token; | |
| struct key *key = conn->params.key; | |
| int ret; | |
| _enter("{%d},{%x}", conn->debug_id, key_serial(key)); | |
| if (!key) | |
| return 0; | |
| ret = key_validate(key); | |
| if (ret < 0) | |
| return ret; | |
| for (token = key->payload.data[0]; token; token = token->next) { | |
| sec = rxrpc_security_lookup(token->security_index); | |
| if (sec) | |
| goto found; | |
| } | |
| return -EKEYREJECTED; | |
| found: | |
| conn->security = sec; | |
| ret = conn->security->init_connection_security(conn, token); | |
| if (ret < 0) { | |
| conn->security = &rxrpc_no_security; | |
| return ret; | |
| } | |
| _leave(" = 0"); | |
| return 0; | |
| } | |
| /* | |
| * Set the ops a server connection. | |
| */ | |
| const struct rxrpc_security *rxrpc_get_incoming_security(struct rxrpc_sock *rx, | |
| struct sk_buff *skb) | |
| { | |
| const struct rxrpc_security *sec; | |
| struct rxrpc_skb_priv *sp = rxrpc_skb(skb); | |
| _enter(""); | |
| sec = rxrpc_security_lookup(sp->hdr.securityIndex); | |
| if (!sec) { | |
| trace_rxrpc_abort(0, "SVS", | |
| sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, | |
| RX_INVALID_OPERATION, EKEYREJECTED); | |
| skb->mark = RXRPC_SKB_MARK_REJECT_ABORT; | |
| skb->priority = RX_INVALID_OPERATION; | |
| return NULL; | |
| } | |
| if (sp->hdr.securityIndex != RXRPC_SECURITY_NONE && | |
| !rx->securities) { | |
| trace_rxrpc_abort(0, "SVR", | |
| sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, | |
| RX_INVALID_OPERATION, EKEYREJECTED); | |
| skb->mark = RXRPC_SKB_MARK_REJECT_ABORT; | |
| skb->priority = sec->no_key_abort; | |
| return NULL; | |
| } | |
| return sec; | |
| } | |
| /* | |
| * Find the security key for a server connection. | |
| */ | |
| struct key *rxrpc_look_up_server_security(struct rxrpc_connection *conn, | |
| struct sk_buff *skb, | |
| u32 kvno, u32 enctype) | |
| { | |
| struct rxrpc_skb_priv *sp = rxrpc_skb(skb); | |
| struct rxrpc_sock *rx; | |
| struct key *key = ERR_PTR(-EKEYREJECTED); | |
| key_ref_t kref = NULL; | |
| char kdesc[5 + 1 + 3 + 1 + 12 + 1 + 12 + 1]; | |
| int ret; | |
| _enter(""); | |
| if (enctype) | |
| sprintf(kdesc, "%u:%u:%u:%u", | |
| sp->hdr.serviceId, sp->hdr.securityIndex, kvno, enctype); | |
| else if (kvno) | |
| sprintf(kdesc, "%u:%u:%u", | |
| sp->hdr.serviceId, sp->hdr.securityIndex, kvno); | |
| else | |
| sprintf(kdesc, "%u:%u", | |
| sp->hdr.serviceId, sp->hdr.securityIndex); | |
| rcu_read_lock(); | |
| rx = rcu_dereference(conn->params.local->service); | |
| if (!rx) | |
| goto out; | |
| /* look through the service's keyring */ | |
| kref = keyring_search(make_key_ref(rx->securities, 1UL), | |
| &key_type_rxrpc_s, kdesc, true); | |
| if (IS_ERR(kref)) { | |
| key = ERR_CAST(kref); | |
| goto out; | |
| } | |
| key = key_ref_to_ptr(kref); | |
| ret = key_validate(key); | |
| if (ret < 0) { | |
| key_put(key); | |
| key = ERR_PTR(ret); | |
| goto out; | |
| } | |
| out: | |
| rcu_read_unlock(); | |
| return key; | |
| } |