|  | /* | 
|  | * Copyright (C) 2015 The Android Open Source Project | 
|  | * | 
|  | * Licensed under the Apache License, Version 2.0 (the "License"); | 
|  | * you may not use this file except in compliance with the License. | 
|  | * You may obtain a copy of the License at | 
|  | * | 
|  | *      http://www.apache.org/licenses/LICENSE-2.0 | 
|  | * | 
|  | * Unless required by applicable law or agreed to in writing, software | 
|  | * distributed under the License is distributed on an "AS IS" BASIS, | 
|  | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
|  | * See the License for the specific language governing permissions and | 
|  | * limitations under the License. | 
|  | */ | 
|  | #define LOG_TAG "gatekeeperd" | 
|  |  | 
|  | #include "gatekeeperd.h" | 
|  |  | 
|  | #include <endian.h> | 
|  | #include <errno.h> | 
|  | #include <fcntl.h> | 
|  | #include <unistd.h> | 
|  | #include <memory> | 
|  |  | 
|  | #include <KeyMintUtils.h> | 
|  | #include <android-base/logging.h> | 
|  | #include <android-base/properties.h> | 
|  | #include <android/binder_ibinder.h> | 
|  | #include <android/binder_manager.h> | 
|  | #include <binder/IPCThreadState.h> | 
|  | #include <binder/IServiceManager.h> | 
|  | #include <binder/PermissionCache.h> | 
|  | #include <gatekeeper/password_handle.h>  // for password_handle_t | 
|  | #include <hardware/hw_auth_token.h> | 
|  | #include <libgsi/libgsi.h> | 
|  | #include <log/log.h> | 
|  | #include <utils/String16.h> | 
|  |  | 
|  | #include <aidl/android/hardware/security/keymint/HardwareAuthToken.h> | 
|  | #include <aidl/android/security/authorization/IKeystoreAuthorization.h> | 
|  | #include <hidl/HidlSupport.h> | 
|  |  | 
|  | using android::sp; | 
|  | using android::hardware::Return; | 
|  | using android::hardware::gatekeeper::V1_0::GatekeeperResponse; | 
|  | using android::hardware::gatekeeper::V1_0::GatekeeperStatusCode; | 
|  |  | 
|  | using AidlGatekeeperEnrollResp = aidl::android::hardware::gatekeeper::GatekeeperEnrollResponse; | 
|  | using AidlGatekeeperVerifyResp = aidl::android::hardware::gatekeeper::GatekeeperVerifyResponse; | 
|  |  | 
|  | using GKResponseCode = ::android::service::gatekeeper::ResponseCode; | 
|  | using ::aidl::android::hardware::security::keymint::HardwareAuthenticatorType; | 
|  | using ::aidl::android::hardware::security::keymint::HardwareAuthToken; | 
|  | using ::aidl::android::hardware::security::keymint::km_utils::authToken2AidlVec; | 
|  | using ::aidl::android::security::authorization::IKeystoreAuthorization; | 
|  |  | 
|  | namespace android { | 
|  |  | 
|  | static const String16 KEYGUARD_PERMISSION("android.permission.ACCESS_KEYGUARD_SECURE_STORAGE"); | 
|  | static const String16 DUMP_PERMISSION("android.permission.DUMP"); | 
|  | constexpr const char gatekeeperServiceName[] = "android.hardware.gatekeeper.IGatekeeper/default"; | 
|  |  | 
|  | GateKeeperProxy::GateKeeperProxy() { | 
|  | clear_state_if_needed_done = false; | 
|  | if (AServiceManager_isDeclared(gatekeeperServiceName)) { | 
|  | ::ndk::SpAIBinder ks2Binder(AServiceManager_waitForService(gatekeeperServiceName)); | 
|  | aidl_hw_device = AidlIGatekeeper::fromBinder(ks2Binder); | 
|  | } | 
|  | if (!aidl_hw_device) { | 
|  | hw_device = IGatekeeper::getService(); | 
|  | } | 
|  | is_running_gsi = android::base::GetBoolProperty(android::gsi::kGsiBootedProp, false); | 
|  |  | 
|  | if (!aidl_hw_device && !hw_device) { | 
|  | LOG(ERROR) << "Could not find Gatekeeper device, which makes me very sad."; | 
|  | } | 
|  | } | 
|  |  | 
|  | void GateKeeperProxy::store_sid(uint32_t userId, uint64_t sid) { | 
|  | char filename[21]; | 
|  | snprintf(filename, sizeof(filename), "%u", userId); | 
|  | int fd = open(filename, O_WRONLY | O_TRUNC | O_CREAT, S_IRUSR | S_IWUSR); | 
|  | if (fd < 0) { | 
|  | ALOGE("could not open file: %s: %s", filename, strerror(errno)); | 
|  | return; | 
|  | } | 
|  | write(fd, &sid, sizeof(sid)); | 
|  | close(fd); | 
|  | } | 
|  |  | 
|  | void GateKeeperProxy::clear_state_if_needed() { | 
|  | if (clear_state_if_needed_done) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | if (mark_cold_boot() && !is_running_gsi) { | 
|  | ALOGI("cold boot: clearing state"); | 
|  | if (aidl_hw_device) { | 
|  | aidl_hw_device->deleteAllUsers(); | 
|  | } else if (hw_device) { | 
|  | hw_device->deleteAllUsers([](const GatekeeperResponse&) {}); | 
|  | } | 
|  | } | 
|  |  | 
|  | clear_state_if_needed_done = true; | 
|  | } | 
|  |  | 
|  | bool GateKeeperProxy::mark_cold_boot() { | 
|  | const char* filename = ".coldboot"; | 
|  | if (access(filename, F_OK) == -1) { | 
|  | int fd = open(filename, O_WRONLY | O_TRUNC | O_CREAT, S_IRUSR | S_IWUSR); | 
|  | if (fd < 0) { | 
|  | ALOGE("could not open file: %s : %s", filename, strerror(errno)); | 
|  | return false; | 
|  | } | 
|  | close(fd); | 
|  | return true; | 
|  | } | 
|  | return false; | 
|  | } | 
|  |  | 
|  | void GateKeeperProxy::maybe_store_sid(uint32_t userId, uint64_t sid) { | 
|  | char filename[21]; | 
|  | snprintf(filename, sizeof(filename), "%u", userId); | 
|  | if (access(filename, F_OK) == -1) { | 
|  | store_sid(userId, sid); | 
|  | } | 
|  | } | 
|  |  | 
|  | uint64_t GateKeeperProxy::read_sid(uint32_t userId) { | 
|  | char filename[21]; | 
|  | uint64_t sid; | 
|  | snprintf(filename, sizeof(filename), "%u", userId); | 
|  | int fd = open(filename, O_RDONLY); | 
|  | if (fd < 0) return 0; | 
|  | read(fd, &sid, sizeof(sid)); | 
|  | close(fd); | 
|  | return sid; | 
|  | } | 
|  |  | 
|  | void GateKeeperProxy::clear_sid(uint32_t userId) { | 
|  | char filename[21]; | 
|  | snprintf(filename, sizeof(filename), "%u", userId); | 
|  | if (remove(filename) < 0 && errno != ENOENT) { | 
|  | ALOGE("%s: could not remove file [%s], attempting 0 write", __func__, strerror(errno)); | 
|  | store_sid(userId, 0); | 
|  | } | 
|  | } | 
|  |  | 
|  | Status GateKeeperProxy::adjust_userId(uint32_t userId, uint32_t* hw_userId) { | 
|  | static constexpr uint32_t kGsiOffset = 1000000; | 
|  | if (userId >= kGsiOffset) { | 
|  | return Status::fromExceptionCode(Status::EX_ILLEGAL_ARGUMENT); | 
|  | } | 
|  |  | 
|  | if ((aidl_hw_device == nullptr) && (hw_device == nullptr)) { | 
|  | return Status::fromExceptionCode(Status::EX_ILLEGAL_STATE); | 
|  | } | 
|  |  | 
|  | if (is_running_gsi) { | 
|  | *hw_userId = userId + kGsiOffset; | 
|  | return Status::ok(); | 
|  | } | 
|  | *hw_userId = userId; | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | #define GK_ERROR *gkResponse = GKResponse::error(), Status::ok() | 
|  |  | 
|  | Status GateKeeperProxy::enroll(int32_t userId, | 
|  | const std::optional<std::vector<uint8_t>>& currentPasswordHandle, | 
|  | const std::optional<std::vector<uint8_t>>& currentPassword, | 
|  | const std::vector<uint8_t>& desiredPassword, | 
|  | GKResponse* gkResponse) { | 
|  | IPCThreadState* ipc = IPCThreadState::self(); | 
|  | const int calling_pid = ipc->getCallingPid(); | 
|  | const int calling_uid = ipc->getCallingUid(); | 
|  | if (!PermissionCache::checkPermission(KEYGUARD_PERMISSION, calling_pid, calling_uid)) { | 
|  | return GK_ERROR; | 
|  | } | 
|  |  | 
|  | // Make sure to clear any state from before factory reset as soon as a credential is | 
|  | // enrolled (which may happen during device setup). | 
|  | clear_state_if_needed(); | 
|  |  | 
|  | // need a desired password to enroll | 
|  | if (desiredPassword.size() == 0) return GK_ERROR; | 
|  |  | 
|  | if (!aidl_hw_device && !hw_device) { | 
|  | LOG(ERROR) << "has no HAL to talk to"; | 
|  | return GK_ERROR; | 
|  | } | 
|  |  | 
|  | android::hardware::hidl_vec<uint8_t> curPwdHandle; | 
|  | android::hardware::hidl_vec<uint8_t> curPwd; | 
|  |  | 
|  | if (currentPasswordHandle && currentPassword) { | 
|  | if (hw_device) { | 
|  | // Hidl Implementations expects passwordHandle to be in | 
|  | // gatekeeper::password_handle_t format. | 
|  | if (currentPasswordHandle->size() != sizeof(gatekeeper::password_handle_t)) { | 
|  | LOG(INFO) << "Password handle has wrong length"; | 
|  | return GK_ERROR; | 
|  | } | 
|  | } | 
|  | curPwdHandle.setToExternal(const_cast<uint8_t*>(currentPasswordHandle->data()), | 
|  | currentPasswordHandle->size()); | 
|  | curPwd.setToExternal(const_cast<uint8_t*>(currentPassword->data()), | 
|  | currentPassword->size()); | 
|  | } | 
|  |  | 
|  | android::hardware::hidl_vec<uint8_t> newPwd; | 
|  | newPwd.setToExternal(const_cast<uint8_t*>(desiredPassword.data()), desiredPassword.size()); | 
|  |  | 
|  | uint32_t hw_userId = 0; | 
|  | Status result = adjust_userId(userId, &hw_userId); | 
|  | if (!result.isOk()) { | 
|  | return result; | 
|  | } | 
|  |  | 
|  | uint64_t secureUserId = 0; | 
|  | if (aidl_hw_device) { | 
|  | // AIDL gatekeeper service | 
|  | AidlGatekeeperEnrollResp rsp; | 
|  | auto result = aidl_hw_device->enroll(hw_userId, curPwdHandle, curPwd, newPwd, &rsp); | 
|  | if (!result.isOk()) { | 
|  | LOG(ERROR) << "enroll transaction failed"; | 
|  | return GK_ERROR; | 
|  | } | 
|  | if (rsp.statusCode >= AidlIGatekeeper::STATUS_OK) { | 
|  | *gkResponse = GKResponse::ok({rsp.data.begin(), rsp.data.end()}); | 
|  | secureUserId = static_cast<uint64_t>(rsp.secureUserId); | 
|  | } else if (rsp.statusCode == AidlIGatekeeper::ERROR_RETRY_TIMEOUT && rsp.timeoutMs > 0) { | 
|  | *gkResponse = GKResponse::retry(rsp.timeoutMs); | 
|  | } else { | 
|  | *gkResponse = GKResponse::error(); | 
|  | } | 
|  | } else if (hw_device) { | 
|  | // HIDL gatekeeper service | 
|  | Return<void> hwRes = hw_device->enroll( | 
|  | hw_userId, curPwdHandle, curPwd, newPwd, | 
|  | [&gkResponse](const GatekeeperResponse& rsp) { | 
|  | if (rsp.code >= GatekeeperStatusCode::STATUS_OK) { | 
|  | *gkResponse = GKResponse::ok({rsp.data.begin(), rsp.data.end()}); | 
|  | } else if (rsp.code == GatekeeperStatusCode::ERROR_RETRY_TIMEOUT && | 
|  | rsp.timeout > 0) { | 
|  | *gkResponse = GKResponse::retry(rsp.timeout); | 
|  | } else { | 
|  | *gkResponse = GKResponse::error(); | 
|  | } | 
|  | }); | 
|  | if (!hwRes.isOk()) { | 
|  | LOG(ERROR) << "enroll transaction failed"; | 
|  | return GK_ERROR; | 
|  | } | 
|  | if (gkResponse->response_code() == GKResponseCode::OK) { | 
|  | if (gkResponse->payload().size() != sizeof(gatekeeper::password_handle_t)) { | 
|  | LOG(ERROR) << "HAL returned password handle of invalid length " | 
|  | << gkResponse->payload().size(); | 
|  | return GK_ERROR; | 
|  | } | 
|  |  | 
|  | const gatekeeper::password_handle_t* handle = | 
|  | reinterpret_cast<const gatekeeper::password_handle_t*>( | 
|  | gkResponse->payload().data()); | 
|  | secureUserId = handle->user_id; | 
|  | } | 
|  | } | 
|  |  | 
|  | if (gkResponse->response_code() == GKResponseCode::OK && !gkResponse->should_reenroll()) { | 
|  | store_sid(userId, secureUserId); | 
|  |  | 
|  | GKResponse verifyResponse; | 
|  | // immediately verify this password so we don't ask the user to enter it again | 
|  | // if they just created it. | 
|  | auto status = verify(userId, gkResponse->payload(), desiredPassword, &verifyResponse); | 
|  | if (!status.isOk() || verifyResponse.response_code() != GKResponseCode::OK) { | 
|  | LOG(ERROR) << "Failed to verify password after enrolling"; | 
|  | } | 
|  | } | 
|  |  | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | Status GateKeeperProxy::verify(int32_t userId, const ::std::vector<uint8_t>& enrolledPasswordHandle, | 
|  | const ::std::vector<uint8_t>& providedPassword, | 
|  | GKResponse* gkResponse) { | 
|  | return verifyChallenge(userId, 0 /* challenge */, enrolledPasswordHandle, providedPassword, | 
|  | gkResponse); | 
|  | } | 
|  |  | 
|  | Status GateKeeperProxy::verifyChallenge(int32_t userId, int64_t challenge, | 
|  | const std::vector<uint8_t>& enrolledPasswordHandle, | 
|  | const std::vector<uint8_t>& providedPassword, | 
|  | GKResponse* gkResponse) { | 
|  | IPCThreadState* ipc = IPCThreadState::self(); | 
|  | const int calling_pid = ipc->getCallingPid(); | 
|  | const int calling_uid = ipc->getCallingUid(); | 
|  | if (!PermissionCache::checkPermission(KEYGUARD_PERMISSION, calling_pid, calling_uid)) { | 
|  | return GK_ERROR; | 
|  | } | 
|  |  | 
|  | // can't verify if we're missing either param | 
|  | if (enrolledPasswordHandle.size() == 0 || providedPassword.size() == 0) return GK_ERROR; | 
|  |  | 
|  | if (!aidl_hw_device && !hw_device) { | 
|  | LOG(ERROR) << "has no HAL to talk to"; | 
|  | return GK_ERROR; | 
|  | } | 
|  |  | 
|  | if (hw_device) { | 
|  | // Hidl Implementations expects passwordHandle to be in gatekeeper::password_handle_t | 
|  | if (enrolledPasswordHandle.size() != sizeof(gatekeeper::password_handle_t)) { | 
|  | LOG(INFO) << "Password handle has wrong length"; | 
|  | return GK_ERROR; | 
|  | } | 
|  | } | 
|  |  | 
|  | uint32_t hw_userId = 0; | 
|  | Status result = adjust_userId(userId, &hw_userId); | 
|  | if (!result.isOk()) { | 
|  | return result; | 
|  | } | 
|  |  | 
|  | android::hardware::hidl_vec<uint8_t> curPwdHandle; | 
|  | curPwdHandle.setToExternal(const_cast<uint8_t*>(enrolledPasswordHandle.data()), | 
|  | enrolledPasswordHandle.size()); | 
|  | android::hardware::hidl_vec<uint8_t> enteredPwd; | 
|  | enteredPwd.setToExternal(const_cast<uint8_t*>(providedPassword.data()), | 
|  | providedPassword.size()); | 
|  |  | 
|  | uint64_t secureUserId = 0; | 
|  | if (aidl_hw_device) { | 
|  | // AIDL gatekeeper service | 
|  | AidlGatekeeperVerifyResp rsp; | 
|  | auto result = aidl_hw_device->verify(hw_userId, challenge, curPwdHandle, enteredPwd, &rsp); | 
|  | if (!result.isOk()) { | 
|  | LOG(ERROR) << "verify transaction failed"; | 
|  | return GK_ERROR; | 
|  | } | 
|  | if (rsp.statusCode >= AidlIGatekeeper::STATUS_OK) { | 
|  | secureUserId = rsp.hardwareAuthToken.userId; | 
|  | // Serialize HardwareAuthToken to a vector as hw_auth_token_t. | 
|  | *gkResponse = GKResponse::ok( | 
|  | authToken2AidlVec(rsp.hardwareAuthToken), | 
|  | rsp.statusCode == AidlIGatekeeper::STATUS_REENROLL /* reenroll */); | 
|  | } else if (rsp.statusCode == AidlIGatekeeper::ERROR_RETRY_TIMEOUT) { | 
|  | *gkResponse = GKResponse::retry(rsp.timeoutMs); | 
|  | } else { | 
|  | *gkResponse = GKResponse::error(); | 
|  | } | 
|  | } else if (hw_device) { | 
|  | // HIDL gatekeeper service | 
|  | Return<void> hwRes = hw_device->verify( | 
|  | hw_userId, challenge, curPwdHandle, enteredPwd, | 
|  | [&gkResponse](const GatekeeperResponse& rsp) { | 
|  | if (rsp.code >= GatekeeperStatusCode::STATUS_OK) { | 
|  | *gkResponse = GKResponse::ok( | 
|  | {rsp.data.begin(), rsp.data.end()}, | 
|  | rsp.code == GatekeeperStatusCode::STATUS_REENROLL /* reenroll */); | 
|  | } else if (rsp.code == GatekeeperStatusCode::ERROR_RETRY_TIMEOUT) { | 
|  | *gkResponse = GKResponse::retry(rsp.timeout); | 
|  | } else { | 
|  | *gkResponse = GKResponse::error(); | 
|  | } | 
|  | }); | 
|  |  | 
|  | if (!hwRes.isOk()) { | 
|  | LOG(ERROR) << "verify transaction failed"; | 
|  | return GK_ERROR; | 
|  | } | 
|  | const gatekeeper::password_handle_t* handle = | 
|  | reinterpret_cast<const gatekeeper::password_handle_t*>( | 
|  | enrolledPasswordHandle.data()); | 
|  | secureUserId = handle->user_id; | 
|  | } | 
|  |  | 
|  | if (gkResponse->response_code() == GKResponseCode::OK) { | 
|  | if (gkResponse->payload().size() != 0) { | 
|  | // try to connect to IKeystoreAuthorization AIDL service first. | 
|  | AIBinder* authzAIBinder = AServiceManager_getService("android.security.authorization"); | 
|  | ::ndk::SpAIBinder authzBinder(authzAIBinder); | 
|  | auto authzService = IKeystoreAuthorization::fromBinder(authzBinder); | 
|  | if (authzService) { | 
|  | if (gkResponse->payload().size() != sizeof(hw_auth_token_t)) { | 
|  | LOG(ERROR) << "Incorrect size of AuthToken payload."; | 
|  | return GK_ERROR; | 
|  | } | 
|  |  | 
|  | const hw_auth_token_t* hwAuthToken = | 
|  | reinterpret_cast<const hw_auth_token_t*>(gkResponse->payload().data()); | 
|  | HardwareAuthToken authToken; | 
|  |  | 
|  | authToken.timestamp.milliSeconds = betoh64(hwAuthToken->timestamp); | 
|  | authToken.challenge = hwAuthToken->challenge; | 
|  | authToken.userId = hwAuthToken->user_id; | 
|  | authToken.authenticatorId = hwAuthToken->authenticator_id; | 
|  | authToken.authenticatorType = static_cast<HardwareAuthenticatorType>( | 
|  | betoh32(hwAuthToken->authenticator_type)); | 
|  | authToken.mac.assign(&hwAuthToken->hmac[0], &hwAuthToken->hmac[32]); | 
|  | auto result = authzService->addAuthToken(authToken); | 
|  | if (!result.isOk()) { | 
|  | LOG(ERROR) << "Failure in sending AuthToken to AuthorizationService."; | 
|  | return GK_ERROR; | 
|  | } | 
|  | } else { | 
|  | LOG(ERROR) << "Cannot deliver auth token. Unable to communicate with " | 
|  | "Keystore."; | 
|  | return GK_ERROR; | 
|  | } | 
|  | } | 
|  |  | 
|  | maybe_store_sid(userId, secureUserId); | 
|  | } | 
|  |  | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | Status GateKeeperProxy::getSecureUserId(int32_t userId, int64_t* sid) { | 
|  | *sid = read_sid(userId); | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | Status GateKeeperProxy::clearSecureUserId(int32_t userId) { | 
|  | IPCThreadState* ipc = IPCThreadState::self(); | 
|  | const int calling_pid = ipc->getCallingPid(); | 
|  | const int calling_uid = ipc->getCallingUid(); | 
|  | if (!PermissionCache::checkPermission(KEYGUARD_PERMISSION, calling_pid, calling_uid)) { | 
|  | ALOGE("%s: permission denied for [%d:%d]", __func__, calling_pid, calling_uid); | 
|  | return Status::ok(); | 
|  | } | 
|  | clear_sid(userId); | 
|  |  | 
|  | uint32_t hw_userId = 0; | 
|  | Status result = adjust_userId(userId, &hw_userId); | 
|  | if (!result.isOk()) { | 
|  | return result; | 
|  | } | 
|  |  | 
|  | if (aidl_hw_device) { | 
|  | aidl_hw_device->deleteUser(hw_userId); | 
|  | } else if (hw_device) { | 
|  | hw_device->deleteUser(hw_userId, [](const GatekeeperResponse&) {}); | 
|  | } | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | Status GateKeeperProxy::reportDeviceSetupComplete() { | 
|  | IPCThreadState* ipc = IPCThreadState::self(); | 
|  | const int calling_pid = ipc->getCallingPid(); | 
|  | const int calling_uid = ipc->getCallingUid(); | 
|  | if (!PermissionCache::checkPermission(KEYGUARD_PERMISSION, calling_pid, calling_uid)) { | 
|  | ALOGE("%s: permission denied for [%d:%d]", __func__, calling_pid, calling_uid); | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | clear_state_if_needed(); | 
|  | return Status::ok(); | 
|  | } | 
|  |  | 
|  | status_t GateKeeperProxy::dump(int fd, const Vector<String16>&) { | 
|  | IPCThreadState* ipc = IPCThreadState::self(); | 
|  | const int pid = ipc->getCallingPid(); | 
|  | const int uid = ipc->getCallingUid(); | 
|  | if (!PermissionCache::checkPermission(DUMP_PERMISSION, pid, uid)) { | 
|  | return PERMISSION_DENIED; | 
|  | } | 
|  |  | 
|  | if (aidl_hw_device == nullptr && hw_device == nullptr) { | 
|  | const char* result = "Device not available"; | 
|  | write(fd, result, strlen(result) + 1); | 
|  | } else { | 
|  | const char* result = "OK"; | 
|  | write(fd, result, strlen(result) + 1); | 
|  | } | 
|  |  | 
|  | return OK; | 
|  | } | 
|  | }  // namespace android |