/* * * Wireless daemon for Linux * * Copyright (C) 2013-2018 Intel Corporation. All rights reserved. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA * */ #ifdef HAVE_CONFIG_H #include #endif #include #include #include #include #include #include "eap.h" #include "eap-private.h" enum radius_attr { RADIUS_ATTR_EAP_MESSAGE = 79, }; struct phase2_method { void *state; bool (*init)(struct eap_state *eap); bool (*handle_avp)(struct eap_state *eap, enum radius_attr type, uint32_t vendor_id, const uint8_t *data, size_t len); bool (*load_settings)(struct eap_state *eap, struct l_settings *settings, const char *prefix); void (*destroy)(struct eap_state *eap); bool (*reset)(struct eap_state *eap); }; struct eap_ttls_state { char *ca_cert; char *client_cert; char *client_key; char *passphrase; struct l_tls *tls; uint8_t *rx_pkt_buf; size_t rx_pkt_received, rx_pkt_len; uint8_t *tx_pkt_buf; size_t tx_pkt_len, tx_pkt_capacity, tx_pkt_offset; uint8_t *avp_buf; size_t avp_received, avp_capacity; bool completed; struct eap_state *phase2_eap; uint8_t negotiated_version; struct phase2_method *phase2; }; static void __eap_ttls_reset_state(struct eap_ttls_state *ttls) { ttls->completed = false; l_free(ttls->rx_pkt_buf); ttls->rx_pkt_buf = NULL; ttls->rx_pkt_received = 0; ttls->rx_pkt_len = 0; l_free(ttls->tx_pkt_buf); ttls->tx_pkt_buf = NULL; ttls->tx_pkt_capacity = 0; ttls->tx_pkt_len = 0; ttls->tx_pkt_offset = 0; l_free(ttls->avp_buf); ttls->avp_buf = NULL; ttls->avp_received = 0; ttls->avp_capacity = 0; if (ttls->tls) { l_tls_free(ttls->tls); ttls->tls = NULL; } } static bool eap_ttls_reset_state(struct eap_state *eap) { struct eap_ttls_state *ttls = eap_get_data(eap); if (ttls->phase2->reset) ttls->phase2->reset(eap); __eap_ttls_reset_state(ttls); return true; } static void eap_ttls_free(struct eap_state *eap) { struct eap_ttls_state *ttls = eap_get_data(eap); __eap_ttls_reset_state(ttls); if (ttls->phase2->destroy) ttls->phase2->destroy(eap); eap_set_data(eap, NULL); l_free(ttls->ca_cert); l_free(ttls->client_cert); l_free(ttls->client_key); if (ttls->passphrase) { memset(ttls->passphrase, 0, strlen(ttls->passphrase)); l_free(ttls->passphrase); } l_free(ttls); } #define EAP_TTLS_RESPONSE_HEADER_LEN 10 #define EAP_TTLS_FLAG_L (1 << 7) #define EAP_TTLS_FLAG_M (1 << 6) #define EAP_TTLS_FLAG_S (1 << 5) #define EAP_TTLS_FLAG_MASK \ (EAP_TTLS_FLAG_L | EAP_TTLS_FLAG_M | EAP_TTLS_FLAG_S) static void eap_ttls_phase2_eap_send_response(const uint8_t *data, size_t len, void *user_data) { } static void eap_ttls_phase2_eap_complete(enum eap_result result, void *user_data) { struct eap_state *eap = user_data; struct eap_ttls_state *ttls = eap_get_data(eap); ttls->completed = true; } static bool eap_ttls_phase2_eap_load_settings(struct eap_state *eap, struct l_settings *settings, const char *prefix) { struct eap_ttls_state *ttls = eap_get_data(eap); ttls->phase2->state = eap_new(eap_ttls_phase2_eap_send_response, eap_ttls_phase2_eap_complete, eap); if (!ttls->phase2->state) { l_error("Could not create the TTLS Phase 2 EAP instance"); return false; } if (!eap_load_settings(ttls->phase2->state, settings, prefix)) { eap_free(ttls->phase2->state); return false; } return true; } static bool eap_ttls_phase2_eap_init(struct eap_state *eap) { struct eap_ttls_state *ttls = eap_get_data(eap); uint8_t packet[5] = { EAP_CODE_REQUEST, 0, 0, 5, EAP_TYPE_IDENTITY }; if (!ttls->phase2->state) return false; /* * Consume a fake Request/Identity packet so that the EAP instance * starts with its Response/Identity right away. */ eap_rx_packet(ttls->phase2->state, packet, sizeof(packet)); return true; } static bool eap_ttls_phase2_eap_handle_avp(struct eap_state *eap, enum radius_attr type, uint32_t vendor_id, const uint8_t *data, size_t len) { return true; } static void eap_ttls_phase2_eap_destroy(struct eap_state *eap) { struct eap_ttls_state *ttls = eap_get_data(eap); if (!ttls->phase2->state) return; eap_reset(ttls->phase2->state); eap_free(ttls->phase2->state); ttls->phase2->state = NULL; } static bool eap_ttls_phase2_eap_reset(struct eap_state *eap) { struct eap_ttls_state *ttls = eap_get_data(eap); if (!ttls->phase2->state) return false; return eap_reset(ttls->phase2->state); } static struct phase2_method phase2_eap = { .load_settings = eap_ttls_phase2_eap_load_settings, .init = eap_ttls_phase2_eap_init, .handle_avp = eap_ttls_phase2_eap_handle_avp, .destroy = eap_ttls_phase2_eap_destroy, .reset = eap_ttls_phase2_eap_reset, }; static uint8_t *eap_ttls_tx_buf_reserve(struct eap_ttls_state *ttls, size_t size) { int offset = ttls->tx_pkt_offset + ttls->tx_pkt_len; size_t end_offset = offset + size; ttls->tx_pkt_len += size; if (end_offset > ttls->tx_pkt_capacity) { ttls->tx_pkt_capacity = end_offset + 1024; ttls->tx_pkt_buf = l_realloc(ttls->tx_pkt_buf, ttls->tx_pkt_capacity); } return ttls->tx_pkt_buf + offset; } static void eap_ttls_tx_cb(const uint8_t *data, size_t len, void *user_data) { struct eap_state *eap = user_data; struct eap_ttls_state *ttls = eap_get_data(eap); memcpy(eap_ttls_tx_buf_reserve(ttls, len), data, len); } struct eap_ttls_avp { __be32 avp_code; uint8_t avp_flags; uint8_t avp_len[3]; uint8_t data[0]; } __attribute__ ((packed)); #define EAP_TTLS_AVP_FLAG_V (1 << 7) #define EAP_TTLS_AVP_FLAG_M (1 << 6) #define RADIUS_AVP_EAP_MESSAGE 79 static bool eap_ttls_handle_avp(struct eap_state *eap, struct eap_ttls_avp *avp) { struct eap_ttls_state *ttls = eap_get_data(eap); uint8_t *data; uint64_t code; size_t data_len; data = avp->data; data_len = ((avp->avp_len[0] << 16) | (avp->avp_len[1] << 8) | (avp->avp_len[2] << 0)) - sizeof(struct eap_ttls_avp); code = l_get_be32(&avp->avp_code); if (avp->avp_flags & EAP_TTLS_AVP_FLAG_V) { if (data_len < 4) goto avp_err; code |= (uint64_t) l_get_be32(data) << 32; data += 4; data_len -= 4; } switch (code) { /* EAP-Message attribute, actually defined in RFC2869 5.13 */ case RADIUS_AVP_EAP_MESSAGE: if (!ttls->phase2_eap) goto avp_err; /* TODO: split if necessary */ eap_rx_packet(ttls->phase2_eap, data, data_len); break; default: if (avp->avp_flags & EAP_TTLS_AVP_FLAG_M) goto avp_err; break; } return true; avp_err: l_tls_close(ttls->tls); return false; } static size_t avp_min_len(const uint8_t *buf, size_t len) { struct eap_ttls_avp *avp; if (len < sizeof(struct eap_ttls_avp)) return sizeof(struct eap_ttls_avp); avp = (struct eap_ttls_avp *) buf; return (((avp->avp_len[0] << 16) | (avp->avp_len[1] << 8) | (avp->avp_len[2] << 0)) + 3) & ~3; } static void eap_ttls_data_cb(const uint8_t *data, size_t len, void *user_data) { struct eap_state *eap = user_data; struct eap_ttls_state *ttls = eap_get_data(eap); struct eap_ttls_avp *avp; size_t avp_len, chunk_len; /* Continue assembling the AVP that we have buffered */ while (ttls->avp_received) { avp_len = avp_min_len(ttls->avp_buf, ttls->avp_received); chunk_len = avp_len - ttls->avp_received; if (chunk_len > len) chunk_len = len; if (ttls->avp_received + chunk_len > ttls->avp_capacity) { ttls->avp_capacity = avp_len; ttls->avp_buf = l_realloc(ttls->avp_buf, ttls->avp_capacity); } memcpy(ttls->avp_buf + ttls->avp_received, data, chunk_len); ttls->avp_received += chunk_len; if (avp_len > ttls->avp_received) /* Wait for more data */ return; /* Do we have a full AVP or just the header */ if (ttls->avp_received - chunk_len >= sizeof(struct eap_ttls_avp)) { ttls->avp_received = 0; avp = (struct eap_ttls_avp *) ttls->avp_buf; if (!eap_ttls_handle_avp(eap, avp)) return; data += chunk_len; len -= chunk_len; } } /* Handle all the AVPs fully contained in the newly received data */ while (len) { avp_len = avp_min_len(data, len); if (len < avp_len || len < sizeof(struct eap_ttls_avp)) break; avp = (struct eap_ttls_avp *) data; if (!eap_ttls_handle_avp(eap, avp)) return; data += avp_len; len -= avp_len; } if (!len) return; /* Store the remaining bytes */ if (ttls->avp_capacity < len) { ttls->avp_capacity = avp_len; ttls->avp_buf = l_realloc(ttls->avp_buf, ttls->avp_capacity); } memcpy(ttls->avp_buf, data, len); ttls->avp_received = len; } static void eap_ttls_ready_cb(const char *peer_identity, void *user_data) { struct eap_state *eap = user_data; struct eap_ttls_state *ttls = eap_get_data(eap); uint8_t msk_emsk[128]; uint8_t seed[64]; /* TODO: if we have a CA certificate require non-NULL peer_identity */ /* * TTLSv0 seems to assume that the TLS handshake phase authenticates * the server to the client enough that the inner method success or * failure status doesn't matter as long as the server lets us in, * although in various places it says the client may also have a * specific policy. */ eap_method_success(eap); /* MSK, EMSK and challenge derivation */ memcpy(seed + 0, ttls->tls->pending.client_random, 32); memcpy(seed + 32, ttls->tls->pending.server_random, 32); tls_prf_get_bytes(ttls->tls, L_CHECKSUM_SHA256, 32, ttls->tls->pending.master_secret, sizeof(ttls->tls->pending.master_secret), "ttls keying material", seed, 64, msk_emsk, 128); memset(seed, 0, 64); eap_set_key_material(eap, msk_emsk + 0, 64, msk_emsk + 64, 64, NULL, 0); if (!ttls->phase2->state) goto err; if (ttls->phase2->init) ttls->phase2->init(eap); return; err: l_tls_close(ttls->tls); } static void eap_ttls_disconnect_cb(enum l_tls_alert_desc reason, bool remote, void *user_data) { struct eap_state *eap = user_data; struct eap_ttls_state *ttls = eap_get_data(eap); ttls->completed = true; } static void eap_ttls_handle_request(struct eap_state *eap, const uint8_t *pkt, size_t len) { uint8_t flags; uint32_t total_len; struct eap_ttls_state *ttls = eap_get_data(eap); size_t fragment_len; uint8_t *tx_buf; if (len < 1) { l_error("EAP-TTLS request too short"); goto err; } flags = pkt[0]; pkt += 1; len -= 1; if (!(flags & EAP_TTLS_FLAG_S) && (flags & 7) != ttls->negotiated_version) { l_error("Non-zero EAP-TTLS version: %i", flags & 7); goto err; } /* Check if we're expecting a fragment ACK */ if (ttls->tx_pkt_len) { if ((flags & EAP_TTLS_FLAG_MASK) || len) { l_error("EAP-TTLS request is not an ACK"); goto err; } /* Send next response fragment, prepend the 6-byte header */ tx_buf = &ttls->tx_pkt_buf[ttls->tx_pkt_offset - 6]; fragment_len = eap_get_mtu(eap) - 6; tx_buf[5] = EAP_TTLS_FLAG_M | ttls->negotiated_version; /* Flags */ if (ttls->tx_pkt_len <= fragment_len) { fragment_len = ttls->tx_pkt_len; tx_buf[5] = ttls->negotiated_version; /* Flags */ } eap_send_response(eap, EAP_TYPE_TTLS, tx_buf, fragment_len + 6); ttls->tx_pkt_len -= fragment_len; ttls->tx_pkt_offset += fragment_len; return; } /* Complain if S bit is not correct */ if (!(flags & EAP_TTLS_FLAG_S) == !ttls->tls) { l_error("EAP-TTLS request S flag invalid"); goto err; } /* Method can't be restarted */ if ((flags & EAP_TTLS_FLAG_S) && ttls->completed) { l_error("EAP-TTLS start after completed"); goto err; } if (flags & EAP_TTLS_FLAG_L) { if (len < 7) { l_error("EAP-TTLS request with L flag too short"); goto err; } total_len = l_get_be32(pkt); pkt += 4; len -= 4; if (ttls->rx_pkt_buf) { l_error("EAP-TTLS request L flag invalid"); l_free(ttls->rx_pkt_buf); ttls->rx_pkt_buf = NULL; goto err; } if (!(flags & EAP_TTLS_FLAG_M) && total_len != len) { l_error("EAP-TTLS request Length value invalid"); goto err; } } if (!ttls->rx_pkt_buf && (flags & EAP_TTLS_FLAG_M)) { if (!(flags & EAP_TTLS_FLAG_L)) { l_error("EAP-TTLS request 1st fragment with no length"); goto err; } ttls->rx_pkt_buf = l_malloc(total_len); ttls->rx_pkt_len = total_len; ttls->rx_pkt_received = 0; } if (ttls->rx_pkt_buf) { if ( ((flags & EAP_TTLS_FLAG_M) && ttls->rx_pkt_received + len >= ttls->rx_pkt_len) || (!(flags & EAP_TTLS_FLAG_M) && ttls->rx_pkt_received + len != ttls->rx_pkt_len)) { l_error("EAP-TTLS request fragment length mismatch"); l_free(ttls->rx_pkt_buf); ttls->rx_pkt_buf = NULL; goto err; } memcpy(ttls->rx_pkt_buf + ttls->rx_pkt_received, pkt, len); ttls->rx_pkt_received += len; } if (flags & EAP_TTLS_FLAG_M) { uint8_t buf[6]; /* Send an empty response as ACK */ buf[5] = 0; eap_send_response(eap, EAP_TYPE_TTLS, buf, 6); return; } if (ttls->rx_pkt_buf) { pkt = ttls->rx_pkt_buf; len = ttls->rx_pkt_len; } eap_ttls_tx_buf_reserve(ttls, EAP_TTLS_RESPONSE_HEADER_LEN); ttls->tx_pkt_offset = ttls->tx_pkt_len; ttls->tx_pkt_len = 0; if (flags & EAP_TTLS_FLAG_S) { ttls->tls = l_tls_new(false, eap_ttls_data_cb, eap_ttls_tx_cb, eap_ttls_ready_cb, eap_ttls_disconnect_cb, eap); if (!ttls->tls) { l_error("Creating a TLS instance failed"); goto err; } l_tls_set_auth_data(ttls->tls, ttls->client_cert, ttls->client_key, ttls->passphrase); if (ttls->ca_cert) l_tls_set_cacert(ttls->tls, ttls->ca_cert); /* * RFC5281 section 9.1: "For all packets other than a * Start packet, the Data field consists of the raw * TLS message sequence or fragment thereof. For a * Start packet, the Data field may optionally * contain an AVP sequence." * We ignore the unencrypted AVP sequence if there is * any. */ len = 0; } /* * Here we take advantage of knowing that ell will send all the * records corresponding to the current handshake step from within * the l_tls_handle_rx call because it doesn't use any other context * such as timers - basic TLS specifies no timeouts. Otherwise we * would need to analyze the record types in eap_ttls_tx_cb to decide * when we're ready to send out a response. */ if (len) l_tls_handle_rx(ttls->tls, pkt, len); if (ttls->rx_pkt_buf) { l_free(ttls->rx_pkt_buf); ttls->rx_pkt_buf = NULL; } /* * Note if ttls->completed && !eap->method_success we can send an empty * response instead of passing the TLS alert. */ if (ttls->tx_pkt_len + 6 <= eap_get_mtu(eap)) { /* * Response fits in a single response packet, prepend the * 6-byte header (no length) before the data. */ tx_buf = &ttls->tx_pkt_buf[ttls->tx_pkt_offset - 6]; tx_buf[5] = ttls->negotiated_version; /* Flags */ eap_send_response(eap, EAP_TYPE_TTLS, tx_buf, ttls->tx_pkt_len + 6); ttls->tx_pkt_len = 0; } else { /* * Fragmentation needed, prepend the 10-byte header * (4 EAP header + 2 response + 4 length) to build the * initial fragment packet. */ tx_buf = &ttls->tx_pkt_buf[ttls->tx_pkt_offset - 10]; tx_buf[5] = EAP_TTLS_FLAG_L | EAP_TTLS_FLAG_M | ttls->negotiated_version; /* Flags */ l_put_be32(ttls->tx_pkt_len, &tx_buf[6]); fragment_len = eap_get_mtu(eap) - 10; eap_send_response(eap, EAP_TYPE_TTLS, tx_buf, fragment_len + 10); ttls->tx_pkt_len -= fragment_len; ttls->tx_pkt_offset += fragment_len; } if (ttls->completed) { l_tls_free(ttls->tls); ttls->tls = NULL; if (ttls->phase2_eap) { eap_free(ttls->phase2_eap); ttls->phase2_eap = NULL; } } return; err: ttls->completed = true; l_tls_free(ttls->tls); ttls->tls = NULL; eap_method_error(eap); } static int eap_ttls_check_settings(struct l_settings *settings, struct l_queue *secrets, const char *prefix, struct l_queue **out_missing) { char setting[64], client_cert_setting[64], passphrase_setting[64]; L_AUTO_FREE_VAR(char *, path) = NULL; L_AUTO_FREE_VAR(char *, client_cert) = NULL; L_AUTO_FREE_VAR(char *, passphrase) = NULL; uint8_t *cert; size_t size; snprintf(setting, sizeof(setting), "%sTTLS-CACert", prefix); path = l_settings_get_string(settings, "Security", setting); if (path) { cert = l_pem_load_certificate(path, &size); if (!cert) { l_error("Failed to load %s", path); return -EIO; } l_free(cert); } snprintf(client_cert_setting, sizeof(client_cert_setting), "%sTTLS-ClientCert", prefix); client_cert = l_settings_get_string(settings, "Security", client_cert_setting); if (client_cert) { cert = l_pem_load_certificate(client_cert, &size); if (!cert) { l_error("Failed to load %s", client_cert); return -EIO; } l_free(cert); } l_free(path); snprintf(setting, sizeof(setting), "%sTTLS-ClientKey", prefix); path = l_settings_get_string(settings, "Security", setting); if (path && !client_cert) { l_error("%s present but no client certificate (%s)", setting, client_cert_setting); return -ENOENT; } snprintf(passphrase_setting, sizeof(passphrase_setting), "%sTTLS-ClientKeyPassphrase", prefix); passphrase = l_settings_get_string(settings, "Security", passphrase_setting); if (!passphrase) { const struct eap_secret_info *secret; secret = l_queue_find(secrets, eap_secret_info_match, passphrase_setting); if (secret) passphrase = l_strdup(secret->value); } if (path) { bool encrypted; uint8_t *priv_key; size_t size; priv_key = l_pem_load_private_key(path, passphrase, &encrypted, &size); if (!priv_key) { if (!encrypted) { l_error("Error loading client private key %s", path); return -EIO; } if (passphrase) { l_error("Error loading encrypted client " "private key %s", path); return -EACCES; } /* * We've got an encrypted key and passphrase was not * saved in the network settings, need to request * the passphrase. */ eap_append_secret(out_missing, EAP_SECRET_LOCAL_PKEY_PASSPHRASE, passphrase_setting, NULL, path, EAP_CACHE_TEMPORARY); } else { memset(priv_key, 0, size); l_free(priv_key); if (passphrase && !encrypted) { l_error("%s present but client private " "key %s is not encrypted", passphrase_setting, path); return -EIO; } } } else if (passphrase) { l_error("%s present but no client private key path set (%s)", passphrase_setting, setting); return -ENOENT; } snprintf(setting, sizeof(setting), "%sTTLS-Phase2-", prefix); return __eap_check_settings(settings, secrets, setting, false, out_missing); } static bool eap_ttls_load_settings(struct eap_state *eap, struct l_settings *settings, const char *prefix) { struct eap_ttls_state *ttls; char setting[64]; ttls = l_new(struct eap_ttls_state, 1); snprintf(setting, sizeof(setting), "%sTTLS-CACert", prefix); ttls->ca_cert = l_settings_get_string(settings, "Security", setting); snprintf(setting, sizeof(setting), "%sTTLS-ClientCert", prefix); ttls->client_cert = l_settings_get_string(settings, "Security", setting); snprintf(setting, sizeof(setting), "%sTTLS-ClientKey", prefix); ttls->client_key = l_settings_get_string(settings, "Security", setting); snprintf(setting, sizeof(setting), "%sTTLS-ClientKeyPassphrase", prefix); ttls->passphrase = l_settings_get_string(settings, "Security", setting); ttls->phase2 = &phase2_eap; eap_set_data(eap, ttls); snprintf(setting, sizeof(setting), "%sTTLS-Phase2-", prefix); if (ttls->phase2->load_settings && !ttls->phase2->load_settings(eap, settings, setting)) goto err; return true; err: eap_set_data(eap, NULL); l_free(ttls->ca_cert); l_free(ttls->client_cert); l_free(ttls->client_key); if (ttls->passphrase) memset(ttls->passphrase, 0, strlen(ttls->passphrase)); l_free(ttls->passphrase); l_free(ttls); return false; } static struct eap_method eap_ttls = { .request_type = EAP_TYPE_TTLS, .exports_msk = true, .name = "TTLS", .free = eap_ttls_free, .handle_request = eap_ttls_handle_request, .check_settings = eap_ttls_check_settings, .load_settings = eap_ttls_load_settings, .reset_state = eap_ttls_reset_state, }; static int eap_ttls_init(void) { l_debug(""); return eap_register_method(&eap_ttls); } static void eap_ttls_exit(void) { l_debug(""); eap_unregister_method(&eap_ttls); } EAP_METHOD_BUILTIN(eap_ttls, eap_ttls_init, eap_ttls_exit)