| /* |
| * Copyright (C) 2016 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. |
| */ |
| |
| package com.android.server.recoverysystem; |
| |
| import static android.os.RecoverySystem.RESUME_ON_REBOOT_REBOOT_ERROR_INVALID_PACKAGE_NAME; |
| import static android.os.RecoverySystem.RESUME_ON_REBOOT_REBOOT_ERROR_LSKF_NOT_CAPTURED; |
| import static android.os.RecoverySystem.RESUME_ON_REBOOT_REBOOT_ERROR_NONE; |
| import static android.os.RecoverySystem.RESUME_ON_REBOOT_REBOOT_ERROR_PROVIDER_PREPARATION_FAILURE; |
| import static android.os.RecoverySystem.RESUME_ON_REBOOT_REBOOT_ERROR_SLOT_MISMATCH; |
| import static android.os.RecoverySystem.RESUME_ON_REBOOT_REBOOT_ERROR_UNSPECIFIED; |
| import static android.os.RecoverySystem.ResumeOnRebootRebootErrorCode; |
| import static android.os.UserHandle.USER_SYSTEM; |
| import static android.ota.nano.OtaPackageMetadata.ApexMetadata; |
| |
| import static com.android.internal.widget.LockSettingsInternal.ARM_REBOOT_ERROR_NONE; |
| import static com.android.internal.widget.LockSettingsInternal.ARM_REBOOT_ERROR_NO_PROVIDER; |
| |
| import android.annotation.IntDef; |
| import android.apex.CompressedApexInfo; |
| import android.apex.CompressedApexInfoList; |
| import android.content.Context; |
| import android.content.IntentSender; |
| import android.content.SharedPreferences; |
| import android.content.pm.PackageManager; |
| import android.hardware.boot.V1_0.IBootControl; |
| import android.net.LocalSocket; |
| import android.net.LocalSocketAddress; |
| import android.os.Binder; |
| import android.os.Environment; |
| import android.os.IRecoverySystem; |
| import android.os.IRecoverySystemProgressListener; |
| import android.os.PowerManager; |
| import android.os.Process; |
| import android.os.RecoverySystem; |
| import android.os.RemoteException; |
| import android.os.ResultReceiver; |
| import android.os.ShellCallback; |
| import android.os.SystemProperties; |
| import android.provider.DeviceConfig; |
| import android.sysprop.ApexProperties; |
| import android.util.ArrayMap; |
| import android.util.ArraySet; |
| import android.util.FastImmutableArraySet; |
| import android.util.Log; |
| import android.util.Slog; |
| |
| import com.android.internal.annotations.GuardedBy; |
| import com.android.internal.annotations.VisibleForTesting; |
| import com.android.internal.util.FrameworkStatsLog; |
| import com.android.internal.widget.LockSettingsInternal; |
| import com.android.internal.widget.RebootEscrowListener; |
| import com.android.server.LocalServices; |
| import com.android.server.SystemService; |
| import com.android.server.pm.ApexManager; |
| |
| import libcore.io.IoUtils; |
| |
| import java.io.DataInputStream; |
| import java.io.DataOutputStream; |
| import java.io.File; |
| import java.io.FileDescriptor; |
| import java.io.FileWriter; |
| import java.io.IOException; |
| import java.io.InputStream; |
| import java.nio.charset.StandardCharsets; |
| import java.util.ArrayList; |
| import java.util.Arrays; |
| import java.util.List; |
| import java.util.zip.ZipEntry; |
| import java.util.zip.ZipFile; |
| |
| /** |
| * The recovery system service is responsible for coordinating recovery related |
| * functions on the device. It sets up (or clears) the bootloader control block |
| * (BCB), which will be read by the bootloader and the recovery image. It also |
| * triggers /system/bin/uncrypt via init to de-encrypt an OTA package on the |
| * /data partition so that it can be accessed under the recovery image. |
| */ |
| public class RecoverySystemService extends IRecoverySystem.Stub implements RebootEscrowListener { |
| private static final String TAG = "RecoverySystemService"; |
| private static final boolean DEBUG = false; |
| |
| // The socket at /dev/socket/uncrypt to communicate with uncrypt. |
| private static final String UNCRYPT_SOCKET = "uncrypt"; |
| |
| // The init services that communicate with /system/bin/uncrypt. |
| @VisibleForTesting |
| static final String INIT_SERVICE_UNCRYPT = "init.svc.uncrypt"; |
| @VisibleForTesting |
| static final String INIT_SERVICE_SETUP_BCB = "init.svc.setup-bcb"; |
| @VisibleForTesting |
| static final String INIT_SERVICE_CLEAR_BCB = "init.svc.clear-bcb"; |
| @VisibleForTesting |
| static final String AB_UPDATE = "ro.build.ab_update"; |
| |
| private static final Object sRequestLock = new Object(); |
| |
| private static final int SOCKET_CONNECTION_MAX_RETRY = 30; |
| |
| static final String REQUEST_LSKF_TIMESTAMP_PREF_SUFFIX = "_request_lskf_timestamp"; |
| static final String REQUEST_LSKF_COUNT_PREF_SUFFIX = "_request_lskf_count"; |
| |
| static final String LSKF_CAPTURED_TIMESTAMP_PREF = "lskf_captured_timestamp"; |
| static final String LSKF_CAPTURED_COUNT_PREF = "lskf_captured_count"; |
| |
| private final Injector mInjector; |
| private final Context mContext; |
| |
| @GuardedBy("this") |
| private final ArrayMap<String, IntentSender> mCallerPendingRequest = new ArrayMap<>(); |
| @GuardedBy("this") |
| private final ArraySet<String> mCallerPreparedForReboot = new ArraySet<>(); |
| |
| /** |
| * Need to prepare for resume on reboot. |
| */ |
| private static final int ROR_NEED_PREPARATION = 0; |
| /** |
| * Resume on reboot has been prepared, notify the caller. |
| */ |
| private static final int ROR_SKIP_PREPARATION_AND_NOTIFY = 1; |
| /** |
| * Resume on reboot has been requested. Caller won't be notified until the preparation is done. |
| */ |
| private static final int ROR_SKIP_PREPARATION_NOT_NOTIFY = 2; |
| |
| /** |
| * The caller never requests for resume on reboot, no need for clear. |
| */ |
| private static final int ROR_NOT_REQUESTED = 0; |
| /** |
| * Clear the resume on reboot preparation state. |
| */ |
| private static final int ROR_REQUESTED_NEED_CLEAR = 1; |
| /** |
| * The caller has requested for resume on reboot. No need for clear since other callers may |
| * exist. |
| */ |
| private static final int ROR_REQUESTED_SKIP_CLEAR = 2; |
| |
| /** |
| * The action to perform upon new resume on reboot prepare request for a given client. |
| */ |
| @IntDef({ ROR_NEED_PREPARATION, |
| ROR_SKIP_PREPARATION_AND_NOTIFY, |
| ROR_SKIP_PREPARATION_NOT_NOTIFY }) |
| private @interface ResumeOnRebootActionsOnRequest {} |
| |
| /** |
| * The action to perform upon resume on reboot clear request for a given client. |
| */ |
| @IntDef({ ROR_NOT_REQUESTED, |
| ROR_REQUESTED_NEED_CLEAR, |
| ROR_REQUESTED_SKIP_CLEAR }) |
| private @interface ResumeOnRebootActionsOnClear {} |
| |
| /** |
| * Fatal arm escrow errors from lock settings that means the RoR is in a bad state. So clients |
| * need to prepare RoR again. |
| */ |
| static final FastImmutableArraySet<Integer> FATAL_ARM_ESCROW_ERRORS = |
| new FastImmutableArraySet<>(new Integer[]{ |
| LockSettingsInternal.ARM_REBOOT_ERROR_ESCROW_NOT_READY, |
| LockSettingsInternal.ARM_REBOOT_ERROR_NO_PROVIDER, |
| LockSettingsInternal.ARM_REBOOT_ERROR_PROVIDER_MISMATCH, |
| LockSettingsInternal.ARM_REBOOT_ERROR_NO_ESCROW_KEY, |
| LockSettingsInternal.ARM_REBOOT_ERROR_KEYSTORE_FAILURE, |
| }); |
| |
| /** |
| * The error details for ArmRebootEscrow. It contains error codes from RecoverySystemService |
| * and LockSettingsService. |
| */ |
| static class RebootPreparationError { |
| final @ResumeOnRebootRebootErrorCode int mRebootErrorCode; |
| final int mProviderErrorCode; // The supplemental error code from lock settings |
| |
| RebootPreparationError(int rebootErrorCode, int providerErrorCode) { |
| mRebootErrorCode = rebootErrorCode; |
| mProviderErrorCode = providerErrorCode; |
| } |
| |
| int getErrorCodeForMetrics() { |
| // The ResumeOnRebootRebootErrorCode are aligned with 1000; so it's safe to add them |
| // for metrics purpose. |
| return mRebootErrorCode + mProviderErrorCode; |
| } |
| } |
| |
| /** |
| * Manages shared preference, i.e. the storage used for metrics reporting. |
| */ |
| public static class PreferencesManager { |
| private static final String METRICS_DIR = "recovery_system"; |
| private static final String METRICS_PREFS_FILE = "RecoverySystemMetricsPrefs.xml"; |
| |
| protected final SharedPreferences mSharedPreferences; |
| private final File mMetricsPrefsFile; |
| |
| PreferencesManager(Context context) { |
| File prefsDir = new File(Environment.getDataSystemCeDirectory(USER_SYSTEM), |
| METRICS_DIR); |
| mMetricsPrefsFile = new File(prefsDir, METRICS_PREFS_FILE); |
| mSharedPreferences = context.getSharedPreferences(mMetricsPrefsFile, 0); |
| } |
| |
| /** Reads the value of a given key with type long. **/ |
| public long getLong(String key, long defaultValue) { |
| return mSharedPreferences.getLong(key, defaultValue); |
| } |
| |
| /** Reads the value of a given key with type int. **/ |
| public int getInt(String key, int defaultValue) { |
| return mSharedPreferences.getInt(key, defaultValue); |
| } |
| |
| /** Stores the value of a given key with type long. **/ |
| public void putLong(String key, long value) { |
| mSharedPreferences.edit().putLong(key, value).commit(); |
| } |
| |
| /** Stores the value of a given key with type int. **/ |
| public void putInt(String key, int value) { |
| mSharedPreferences.edit().putInt(key, value).commit(); |
| } |
| |
| /** Increments the value of a given key with type int. **/ |
| public synchronized void incrementIntKey(String key, int defaultInitialValue) { |
| int oldValue = getInt(key, defaultInitialValue); |
| putInt(key, oldValue + 1); |
| } |
| |
| /** Delete the preference file and cleanup all metrics storage. **/ |
| public void deletePrefsFile() { |
| if (!mMetricsPrefsFile.delete()) { |
| Slog.w(TAG, "Failed to delete metrics prefs"); |
| } |
| } |
| } |
| |
| static class Injector { |
| protected final Context mContext; |
| protected final PreferencesManager mPrefs; |
| |
| Injector(Context context) { |
| mContext = context; |
| mPrefs = new PreferencesManager(context); |
| } |
| |
| public Context getContext() { |
| return mContext; |
| } |
| |
| public LockSettingsInternal getLockSettingsService() { |
| return LocalServices.getService(LockSettingsInternal.class); |
| } |
| |
| public PowerManager getPowerManager() { |
| return (PowerManager) mContext.getSystemService(Context.POWER_SERVICE); |
| } |
| |
| public String systemPropertiesGet(String key) { |
| return SystemProperties.get(key); |
| } |
| |
| public void systemPropertiesSet(String key, String value) { |
| SystemProperties.set(key, value); |
| } |
| |
| public boolean uncryptPackageFileDelete() { |
| return RecoverySystem.UNCRYPT_PACKAGE_FILE.delete(); |
| } |
| |
| public String getUncryptPackageFileName() { |
| return RecoverySystem.UNCRYPT_PACKAGE_FILE.getName(); |
| } |
| |
| public FileWriter getUncryptPackageFileWriter() throws IOException { |
| return new FileWriter(RecoverySystem.UNCRYPT_PACKAGE_FILE); |
| } |
| |
| public UncryptSocket connectService() { |
| UncryptSocket socket = new UncryptSocket(); |
| if (!socket.connectService()) { |
| socket.close(); |
| return null; |
| } |
| return socket; |
| } |
| |
| /** |
| * Throws remote exception if there's an error getting the boot control HAL. |
| * Returns null if the boot control HAL's version is older than V1_2. |
| */ |
| public android.hardware.boot.V1_2.IBootControl getBootControl() throws RemoteException { |
| IBootControl bootControlV10 = IBootControl.getService(true); |
| if (bootControlV10 == null) { |
| throw new RemoteException("Failed to get boot control HAL V1_0."); |
| } |
| |
| android.hardware.boot.V1_2.IBootControl bootControlV12 = |
| android.hardware.boot.V1_2.IBootControl.castFrom(bootControlV10); |
| if (bootControlV12 == null) { |
| Slog.w(TAG, "Device doesn't implement boot control HAL V1_2."); |
| return null; |
| } |
| return bootControlV12; |
| } |
| |
| public void threadSleep(long millis) throws InterruptedException { |
| Thread.sleep(millis); |
| } |
| |
| public int getUidFromPackageName(String packageName) { |
| try { |
| return mContext.getPackageManager().getPackageUidAsUser(packageName, USER_SYSTEM); |
| } catch (PackageManager.NameNotFoundException e) { |
| Slog.w(TAG, "Failed to find uid for " + packageName); |
| } |
| return -1; |
| } |
| |
| public PreferencesManager getMetricsPrefs() { |
| return mPrefs; |
| } |
| |
| public long getCurrentTimeMillis() { |
| return System.currentTimeMillis(); |
| } |
| |
| public void reportRebootEscrowPreparationMetrics(int uid, |
| @ResumeOnRebootActionsOnRequest int requestResult, int requestedClientCount) { |
| FrameworkStatsLog.write(FrameworkStatsLog.REBOOT_ESCROW_PREPARATION_REPORTED, uid, |
| requestResult, requestedClientCount); |
| } |
| |
| public void reportRebootEscrowLskfCapturedMetrics(int uid, int requestedClientCount, |
| int requestedToLskfCapturedDurationInSeconds) { |
| FrameworkStatsLog.write(FrameworkStatsLog.REBOOT_ESCROW_LSKF_CAPTURE_REPORTED, uid, |
| requestedClientCount, requestedToLskfCapturedDurationInSeconds); |
| } |
| |
| public void reportRebootEscrowRebootMetrics(int errorCode, int uid, |
| int preparedClientCount, int requestCount, boolean slotSwitch, boolean serverBased, |
| int lskfCapturedToRebootDurationInSeconds, int lskfCapturedCounts) { |
| FrameworkStatsLog.write(FrameworkStatsLog.REBOOT_ESCROW_REBOOT_REPORTED, errorCode, |
| uid, preparedClientCount, requestCount, slotSwitch, serverBased, |
| lskfCapturedToRebootDurationInSeconds, lskfCapturedCounts); |
| } |
| } |
| |
| /** |
| * Handles the lifecycle events for the RecoverySystemService. |
| */ |
| public static final class Lifecycle extends SystemService { |
| private RecoverySystemService mRecoverySystemService; |
| |
| public Lifecycle(Context context) { |
| super(context); |
| } |
| |
| @Override |
| public void onBootPhase(int phase) { |
| if (phase == SystemService.PHASE_SYSTEM_SERVICES_READY) { |
| mRecoverySystemService.onSystemServicesReady(); |
| } |
| } |
| |
| @Override |
| public void onStart() { |
| mRecoverySystemService = new RecoverySystemService(getContext()); |
| publishBinderService(Context.RECOVERY_SERVICE, mRecoverySystemService); |
| } |
| } |
| |
| private RecoverySystemService(Context context) { |
| this(new Injector(context)); |
| } |
| |
| @VisibleForTesting |
| RecoverySystemService(Injector injector) { |
| mInjector = injector; |
| mContext = injector.getContext(); |
| } |
| |
| @VisibleForTesting |
| void onSystemServicesReady() { |
| LockSettingsInternal lockSettings = mInjector.getLockSettingsService(); |
| if (lockSettings == null) { |
| Slog.e(TAG, "Failed to get lock settings service, skipping set" |
| + " RebootEscrowListener"); |
| return; |
| } |
| lockSettings.setRebootEscrowListener(this); |
| } |
| |
| @Override // Binder call |
| public boolean uncrypt(String filename, IRecoverySystemProgressListener listener) { |
| if (DEBUG) Slog.d(TAG, "uncrypt: " + filename); |
| |
| synchronized (sRequestLock) { |
| mContext.enforceCallingOrSelfPermission(android.Manifest.permission.RECOVERY, null); |
| |
| if (!checkAndWaitForUncryptService()) { |
| Slog.e(TAG, "uncrypt service is unavailable."); |
| return false; |
| } |
| |
| // Write the filename into uncrypt package file to be read by |
| // uncrypt. |
| mInjector.uncryptPackageFileDelete(); |
| |
| try (FileWriter uncryptFile = mInjector.getUncryptPackageFileWriter()) { |
| uncryptFile.write(filename + "\n"); |
| } catch (IOException e) { |
| Slog.e(TAG, "IOException when writing \"" |
| + mInjector.getUncryptPackageFileName() + "\":", e); |
| return false; |
| } |
| |
| // Trigger uncrypt via init. |
| mInjector.systemPropertiesSet("ctl.start", "uncrypt"); |
| |
| // Connect to the uncrypt service socket. |
| UncryptSocket socket = mInjector.connectService(); |
| if (socket == null) { |
| Slog.e(TAG, "Failed to connect to uncrypt socket"); |
| return false; |
| } |
| |
| // Read the status from the socket. |
| try { |
| int lastStatus = Integer.MIN_VALUE; |
| while (true) { |
| int status = socket.getPercentageUncrypted(); |
| // Avoid flooding the log with the same message. |
| if (status == lastStatus && lastStatus != Integer.MIN_VALUE) { |
| continue; |
| } |
| lastStatus = status; |
| |
| if (status >= 0 && status <= 100) { |
| // Update status |
| Slog.i(TAG, "uncrypt read status: " + status); |
| if (listener != null) { |
| try { |
| listener.onProgress(status); |
| } catch (RemoteException ignored) { |
| Slog.w(TAG, "RemoteException when posting progress"); |
| } |
| } |
| if (status == 100) { |
| Slog.i(TAG, "uncrypt successfully finished."); |
| // Ack receipt of the final status code. uncrypt |
| // waits for the ack so the socket won't be |
| // destroyed before we receive the code. |
| socket.sendAck(); |
| break; |
| } |
| } else { |
| // Error in /system/bin/uncrypt. |
| Slog.e(TAG, "uncrypt failed with status: " + status); |
| // Ack receipt of the final status code. uncrypt waits |
| // for the ack so the socket won't be destroyed before |
| // we receive the code. |
| socket.sendAck(); |
| return false; |
| } |
| } |
| } catch (IOException e) { |
| Slog.e(TAG, "IOException when reading status: ", e); |
| return false; |
| } finally { |
| socket.close(); |
| } |
| |
| return true; |
| } |
| } |
| |
| @Override // Binder call |
| public boolean clearBcb() { |
| if (DEBUG) Slog.d(TAG, "clearBcb"); |
| synchronized (sRequestLock) { |
| return setupOrClearBcb(false, null); |
| } |
| } |
| |
| @Override // Binder call |
| public boolean setupBcb(String command) { |
| if (DEBUG) Slog.d(TAG, "setupBcb: [" + command + "]"); |
| synchronized (sRequestLock) { |
| return setupOrClearBcb(true, command); |
| } |
| } |
| |
| @Override // Binder call |
| public void rebootRecoveryWithCommand(String command) { |
| if (DEBUG) Slog.d(TAG, "rebootRecoveryWithCommand: [" + command + "]"); |
| synchronized (sRequestLock) { |
| if (!setupOrClearBcb(true, command)) { |
| return; |
| } |
| |
| // Having set up the BCB, go ahead and reboot. |
| PowerManager pm = mInjector.getPowerManager(); |
| pm.reboot(PowerManager.REBOOT_RECOVERY); |
| } |
| } |
| |
| private void enforcePermissionForResumeOnReboot() { |
| if (mContext.checkCallingOrSelfPermission(android.Manifest.permission.RECOVERY) |
| != PackageManager.PERMISSION_GRANTED |
| && mContext.checkCallingOrSelfPermission(android.Manifest.permission.REBOOT) |
| != PackageManager.PERMISSION_GRANTED) { |
| throw new SecurityException("Caller must have " + android.Manifest.permission.RECOVERY |
| + " or " + android.Manifest.permission.REBOOT + " for resume on reboot."); |
| } |
| } |
| |
| private void reportMetricsOnRequestLskf(String packageName, int requestResult) { |
| int uid = mInjector.getUidFromPackageName(packageName); |
| int pendingRequestCount; |
| synchronized (this) { |
| pendingRequestCount = mCallerPendingRequest.size(); |
| } |
| |
| // Save the timestamp and request count for new ror request |
| PreferencesManager prefs = mInjector.getMetricsPrefs(); |
| prefs.putLong(packageName + REQUEST_LSKF_TIMESTAMP_PREF_SUFFIX, |
| mInjector.getCurrentTimeMillis()); |
| prefs.incrementIntKey(packageName + REQUEST_LSKF_COUNT_PREF_SUFFIX, 0); |
| |
| mInjector.reportRebootEscrowPreparationMetrics(uid, requestResult, pendingRequestCount); |
| } |
| |
| @Override // Binder call |
| public boolean requestLskf(String packageName, IntentSender intentSender) { |
| enforcePermissionForResumeOnReboot(); |
| |
| if (packageName == null) { |
| Slog.w(TAG, "Missing packageName when requesting lskf."); |
| return false; |
| } |
| |
| @ResumeOnRebootActionsOnRequest int action = updateRoRPreparationStateOnNewRequest( |
| packageName, intentSender); |
| reportMetricsOnRequestLskf(packageName, action); |
| |
| switch (action) { |
| case ROR_SKIP_PREPARATION_AND_NOTIFY: |
| // We consider the preparation done if someone else has prepared. |
| sendPreparedForRebootIntentIfNeeded(intentSender); |
| return true; |
| case ROR_SKIP_PREPARATION_NOT_NOTIFY: |
| return true; |
| case ROR_NEED_PREPARATION: |
| final long origId = Binder.clearCallingIdentity(); |
| try { |
| LockSettingsInternal lockSettings = mInjector.getLockSettingsService(); |
| if (lockSettings == null) { |
| Slog.e(TAG, "Failed to get lock settings service, skipping" |
| + " prepareRebootEscrow"); |
| return false; |
| } |
| // Clear the RoR preparation state if lock settings reports an failure. |
| if (!lockSettings.prepareRebootEscrow()) { |
| clearRoRPreparationState(); |
| return false; |
| } |
| return true; |
| } finally { |
| Binder.restoreCallingIdentity(origId); |
| } |
| default: |
| throw new IllegalStateException("Unsupported action type on new request " + action); |
| } |
| } |
| |
| // Checks and updates the resume on reboot preparation state. |
| private synchronized @ResumeOnRebootActionsOnRequest int updateRoRPreparationStateOnNewRequest( |
| String packageName, IntentSender intentSender) { |
| if (!mCallerPreparedForReboot.isEmpty()) { |
| if (mCallerPreparedForReboot.contains(packageName)) { |
| Slog.i(TAG, "RoR already has prepared for " + packageName); |
| } |
| |
| // Someone else has prepared. Consider the preparation done, and send back the intent. |
| mCallerPreparedForReboot.add(packageName); |
| return ROR_SKIP_PREPARATION_AND_NOTIFY; |
| } |
| |
| boolean needPreparation = mCallerPendingRequest.isEmpty(); |
| if (mCallerPendingRequest.containsKey(packageName)) { |
| Slog.i(TAG, "Duplicate RoR preparation request for " + packageName); |
| } |
| // Update the request with the new intentSender. |
| mCallerPendingRequest.put(packageName, intentSender); |
| return needPreparation ? ROR_NEED_PREPARATION : ROR_SKIP_PREPARATION_NOT_NOTIFY; |
| } |
| |
| private void reportMetricsOnPreparedForReboot() { |
| long currentTimestamp = mInjector.getCurrentTimeMillis(); |
| |
| List<String> preparedClients; |
| synchronized (this) { |
| preparedClients = new ArrayList<>(mCallerPreparedForReboot); |
| } |
| |
| // Save the timestamp & lskf capture count for lskf capture |
| PreferencesManager prefs = mInjector.getMetricsPrefs(); |
| prefs.putLong(LSKF_CAPTURED_TIMESTAMP_PREF, currentTimestamp); |
| prefs.incrementIntKey(LSKF_CAPTURED_COUNT_PREF, 0); |
| |
| for (String packageName : preparedClients) { |
| int uid = mInjector.getUidFromPackageName(packageName); |
| |
| int durationSeconds = -1; |
| long requestLskfTimestamp = prefs.getLong( |
| packageName + REQUEST_LSKF_TIMESTAMP_PREF_SUFFIX, -1); |
| if (requestLskfTimestamp != -1 && currentTimestamp > requestLskfTimestamp) { |
| durationSeconds = (int) (currentTimestamp - requestLskfTimestamp) / 1000; |
| } |
| Slog.i(TAG, String.format("Reporting lskf captured, lskf capture takes %d seconds for" |
| + " package %s", durationSeconds, packageName)); |
| mInjector.reportRebootEscrowLskfCapturedMetrics(uid, preparedClients.size(), |
| durationSeconds); |
| } |
| } |
| |
| @Override |
| public void onPreparedForReboot(boolean ready) { |
| if (!ready) { |
| return; |
| } |
| updateRoRPreparationStateOnPreparedForReboot(); |
| reportMetricsOnPreparedForReboot(); |
| } |
| |
| private synchronized void updateRoRPreparationStateOnPreparedForReboot() { |
| if (!mCallerPreparedForReboot.isEmpty()) { |
| Slog.w(TAG, "onPreparedForReboot called when some clients have prepared."); |
| } |
| |
| if (mCallerPendingRequest.isEmpty()) { |
| Slog.w(TAG, "onPreparedForReboot called but no client has requested."); |
| } |
| |
| // Send intents to notify callers |
| for (int i = 0; i < mCallerPendingRequest.size(); i++) { |
| sendPreparedForRebootIntentIfNeeded(mCallerPendingRequest.valueAt(i)); |
| mCallerPreparedForReboot.add(mCallerPendingRequest.keyAt(i)); |
| } |
| mCallerPendingRequest.clear(); |
| } |
| |
| private void sendPreparedForRebootIntentIfNeeded(IntentSender intentSender) { |
| if (intentSender != null) { |
| try { |
| intentSender.sendIntent(null, 0, null, null, null); |
| } catch (IntentSender.SendIntentException e) { |
| Slog.w(TAG, "Could not send intent for prepared reboot: " + e.getMessage()); |
| } |
| } |
| } |
| |
| @Override // Binder call |
| public boolean clearLskf(String packageName) { |
| enforcePermissionForResumeOnReboot(); |
| if (packageName == null) { |
| Slog.w(TAG, "Missing packageName when clearing lskf."); |
| return false; |
| } |
| // TODO(179105110) Clear the RoR metrics for the given packageName. |
| |
| @ResumeOnRebootActionsOnClear int action = updateRoRPreparationStateOnClear(packageName); |
| switch (action) { |
| case ROR_NOT_REQUESTED: |
| Slog.w(TAG, "RoR clear called before preparation for caller " + packageName); |
| return true; |
| case ROR_REQUESTED_SKIP_CLEAR: |
| return true; |
| case ROR_REQUESTED_NEED_CLEAR: |
| final long origId = Binder.clearCallingIdentity(); |
| try { |
| LockSettingsInternal lockSettings = mInjector.getLockSettingsService(); |
| if (lockSettings == null) { |
| Slog.e(TAG, "Failed to get lock settings service, skipping" |
| + " clearRebootEscrow"); |
| return false; |
| } |
| |
| return lockSettings.clearRebootEscrow(); |
| } finally { |
| Binder.restoreCallingIdentity(origId); |
| } |
| default: |
| throw new IllegalStateException("Unsupported action type on clear " + action); |
| } |
| } |
| |
| private synchronized @ResumeOnRebootActionsOnClear int updateRoRPreparationStateOnClear( |
| String packageName) { |
| if (!mCallerPreparedForReboot.contains(packageName) && !mCallerPendingRequest.containsKey( |
| packageName)) { |
| Slog.w(TAG, packageName + " hasn't prepared for resume on reboot"); |
| return ROR_NOT_REQUESTED; |
| } |
| mCallerPendingRequest.remove(packageName); |
| mCallerPreparedForReboot.remove(packageName); |
| |
| // Check if others have prepared ROR. |
| boolean needClear = mCallerPendingRequest.isEmpty() && mCallerPreparedForReboot.isEmpty(); |
| return needClear ? ROR_REQUESTED_NEED_CLEAR : ROR_REQUESTED_SKIP_CLEAR; |
| } |
| |
| private boolean isAbDevice() { |
| return "true".equalsIgnoreCase(mInjector.systemPropertiesGet(AB_UPDATE)); |
| } |
| |
| private boolean verifySlotForNextBoot(boolean slotSwitch) { |
| if (!isAbDevice()) { |
| Slog.w(TAG, "Device isn't a/b, skipping slot verification."); |
| return true; |
| } |
| |
| android.hardware.boot.V1_2.IBootControl bootControl; |
| try { |
| bootControl = mInjector.getBootControl(); |
| } catch (RemoteException e) { |
| Slog.w(TAG, "Failed to get the boot control HAL " + e); |
| return false; |
| } |
| |
| // TODO(xunchang) enforce boot control V1_2 HAL on devices using multi client RoR |
| if (bootControl == null) { |
| Slog.w(TAG, "Cannot get the boot control HAL, skipping slot verification."); |
| return true; |
| } |
| |
| int current_slot; |
| int next_active_slot; |
| try { |
| current_slot = bootControl.getCurrentSlot(); |
| if (current_slot != 0 && current_slot != 1) { |
| throw new IllegalStateException("Current boot slot should be 0 or 1, got " |
| + current_slot); |
| } |
| next_active_slot = bootControl.getActiveBootSlot(); |
| } catch (RemoteException e) { |
| Slog.w(TAG, "Failed to query the active slots", e); |
| return false; |
| } |
| |
| int expected_active_slot = current_slot; |
| if (slotSwitch) { |
| expected_active_slot = current_slot == 0 ? 1 : 0; |
| } |
| if (next_active_slot != expected_active_slot) { |
| Slog.w(TAG, "The next active boot slot doesn't match the expected value, " |
| + "expected " + expected_active_slot + ", got " + next_active_slot); |
| return false; |
| } |
| return true; |
| } |
| |
| private RebootPreparationError armRebootEscrow(String packageName, |
| boolean slotSwitch) { |
| if (packageName == null) { |
| Slog.w(TAG, "Missing packageName when rebooting with lskf."); |
| return new RebootPreparationError( |
| RESUME_ON_REBOOT_REBOOT_ERROR_INVALID_PACKAGE_NAME, ARM_REBOOT_ERROR_NONE); |
| } |
| if (!isLskfCaptured(packageName)) { |
| return new RebootPreparationError(RESUME_ON_REBOOT_REBOOT_ERROR_LSKF_NOT_CAPTURED, |
| ARM_REBOOT_ERROR_NONE); |
| } |
| |
| if (!verifySlotForNextBoot(slotSwitch)) { |
| return new RebootPreparationError(RESUME_ON_REBOOT_REBOOT_ERROR_SLOT_MISMATCH, |
| ARM_REBOOT_ERROR_NONE); |
| } |
| |
| final long origId = Binder.clearCallingIdentity(); |
| int providerErrorCode; |
| try { |
| LockSettingsInternal lockSettings = mInjector.getLockSettingsService(); |
| if (lockSettings == null) { |
| Slog.e(TAG, "Failed to get lock settings service, skipping" |
| + " armRebootEscrow"); |
| return new RebootPreparationError( |
| RESUME_ON_REBOOT_REBOOT_ERROR_PROVIDER_PREPARATION_FAILURE, |
| ARM_REBOOT_ERROR_NO_PROVIDER); |
| } |
| providerErrorCode = lockSettings.armRebootEscrow(); |
| } finally { |
| Binder.restoreCallingIdentity(origId); |
| } |
| |
| if (providerErrorCode != ARM_REBOOT_ERROR_NONE) { |
| Slog.w(TAG, "Failure to escrow key for reboot, providerErrorCode: " |
| + providerErrorCode); |
| return new RebootPreparationError( |
| RESUME_ON_REBOOT_REBOOT_ERROR_PROVIDER_PREPARATION_FAILURE, providerErrorCode); |
| } |
| |
| return new RebootPreparationError(RESUME_ON_REBOOT_REBOOT_ERROR_NONE, |
| ARM_REBOOT_ERROR_NONE); |
| } |
| |
| private boolean useServerBasedRoR() { |
| final long origId = Binder.clearCallingIdentity(); |
| try { |
| return DeviceConfig.getBoolean(DeviceConfig.NAMESPACE_OTA, |
| "server_based_ror_enabled", false); |
| } finally { |
| Binder.restoreCallingIdentity(origId); |
| } |
| } |
| |
| private void reportMetricsOnRebootWithLskf(String packageName, boolean slotSwitch, |
| RebootPreparationError escrowError) { |
| int uid = mInjector.getUidFromPackageName(packageName); |
| boolean serverBased = useServerBasedRoR(); |
| int preparedClientCount; |
| synchronized (this) { |
| preparedClientCount = mCallerPreparedForReboot.size(); |
| } |
| |
| long currentTimestamp = mInjector.getCurrentTimeMillis(); |
| int durationSeconds = -1; |
| PreferencesManager prefs = mInjector.getMetricsPrefs(); |
| long lskfCapturedTimestamp = prefs.getLong(LSKF_CAPTURED_TIMESTAMP_PREF, -1); |
| if (lskfCapturedTimestamp != -1 && currentTimestamp > lskfCapturedTimestamp) { |
| durationSeconds = (int) (currentTimestamp - lskfCapturedTimestamp) / 1000; |
| } |
| |
| int requestCount = prefs.getInt(packageName + REQUEST_LSKF_COUNT_PREF_SUFFIX, -1); |
| int lskfCapturedCount = prefs.getInt(LSKF_CAPTURED_COUNT_PREF, -1); |
| |
| Slog.i(TAG, String.format("Reporting reboot with lskf, package name %s, client count %d," |
| + " request count %d, lskf captured count %d, duration since lskf captured" |
| + " %d seconds.", packageName, preparedClientCount, requestCount, |
| lskfCapturedCount, durationSeconds)); |
| mInjector.reportRebootEscrowRebootMetrics(escrowError.getErrorCodeForMetrics(), uid, |
| preparedClientCount, requestCount, slotSwitch, serverBased, durationSeconds, |
| lskfCapturedCount); |
| } |
| |
| private synchronized void clearRoRPreparationState() { |
| mCallerPendingRequest.clear(); |
| mCallerPreparedForReboot.clear(); |
| } |
| |
| private void clearRoRPreparationStateOnRebootFailure(RebootPreparationError escrowError) { |
| if (!FATAL_ARM_ESCROW_ERRORS.contains(escrowError.mProviderErrorCode)) { |
| return; |
| } |
| |
| Slog.w(TAG, "Clearing resume on reboot states for all clients on arm escrow error: " |
| + escrowError.mProviderErrorCode); |
| clearRoRPreparationState(); |
| } |
| |
| private @ResumeOnRebootRebootErrorCode int rebootWithLskfImpl(String packageName, String reason, |
| boolean slotSwitch) { |
| RebootPreparationError escrowError = armRebootEscrow(packageName, slotSwitch); |
| reportMetricsOnRebootWithLskf(packageName, slotSwitch, escrowError); |
| clearRoRPreparationStateOnRebootFailure(escrowError); |
| |
| @ResumeOnRebootRebootErrorCode int errorCode = escrowError.mRebootErrorCode; |
| if (errorCode != RESUME_ON_REBOOT_REBOOT_ERROR_NONE) { |
| return errorCode; |
| } |
| |
| // Clear the metrics prefs after a successful RoR reboot. |
| mInjector.getMetricsPrefs().deletePrefsFile(); |
| |
| PowerManager pm = mInjector.getPowerManager(); |
| pm.reboot(reason); |
| return RESUME_ON_REBOOT_REBOOT_ERROR_UNSPECIFIED; |
| } |
| |
| @Override // Binder call for the legacy rebootWithLskf |
| public @ResumeOnRebootRebootErrorCode int rebootWithLskfAssumeSlotSwitch(String packageName, |
| String reason) { |
| mContext.enforceCallingOrSelfPermission(android.Manifest.permission.RECOVERY, null); |
| return rebootWithLskfImpl(packageName, reason, true); |
| } |
| |
| @Override // Binder call |
| public @ResumeOnRebootRebootErrorCode int rebootWithLskf(String packageName, String reason, |
| boolean slotSwitch) { |
| enforcePermissionForResumeOnReboot(); |
| return rebootWithLskfImpl(packageName, reason, slotSwitch); |
| } |
| |
| public static boolean isUpdatableApexSupported() { |
| return ApexProperties.updatable().orElse(false); |
| } |
| |
| // Metadata should be no more than few MB, if it's larger than 100MB something is wrong. |
| private static final long APEX_INFO_SIZE_LIMIT = 24 * 1024 * 100; |
| |
| private static CompressedApexInfoList getCompressedApexInfoList(String packageFile) |
| throws IOException { |
| try (ZipFile zipFile = new ZipFile(packageFile)) { |
| final ZipEntry entry = zipFile.getEntry("apex_info.pb"); |
| if (entry == null) { |
| return null; |
| } |
| if (entry.getSize() >= APEX_INFO_SIZE_LIMIT) { |
| throw new IllegalArgumentException("apex_info.pb has size " |
| + entry.getSize() |
| + " which is larger than the permitted limit" + APEX_INFO_SIZE_LIMIT); |
| } |
| if (entry.getSize() == 0) { |
| CompressedApexInfoList infoList = new CompressedApexInfoList(); |
| infoList.apexInfos = new CompressedApexInfo[0]; |
| return infoList; |
| } |
| Log.i(TAG, "Allocating " + entry.getSize() |
| + " bytes of memory to store OTA Metadata"); |
| byte[] data = new byte[(int) entry.getSize()]; |
| |
| try (InputStream is = zipFile.getInputStream(entry)) { |
| int bytesRead = is.read(data); |
| String msg = "Read " + bytesRead + " when expecting " + data.length; |
| Log.e(TAG, msg); |
| if (bytesRead != data.length) { |
| throw new IOException(msg); |
| } |
| } |
| ApexMetadata metadata = ApexMetadata.parseFrom(data); |
| CompressedApexInfoList apexInfoList = new CompressedApexInfoList(); |
| apexInfoList.apexInfos = |
| Arrays.stream(metadata.apexInfo).filter(apex -> apex.isCompressed).map(apex -> { |
| CompressedApexInfo info = new CompressedApexInfo(); |
| info.moduleName = apex.packageName; |
| info.decompressedSize = apex.decompressedSize; |
| info.versionCode = apex.version; |
| return info; |
| }).toArray(CompressedApexInfo[]::new); |
| return apexInfoList; |
| } |
| } |
| |
| @Override |
| public boolean allocateSpaceForUpdate(String packageFile) { |
| mContext.enforceCallingOrSelfPermission(android.Manifest.permission.RECOVERY, null); |
| if (!isUpdatableApexSupported()) { |
| Log.i(TAG, "Updatable Apex not supported, " |
| + "allocateSpaceForUpdate does nothing."); |
| return true; |
| } |
| final long token = Binder.clearCallingIdentity(); |
| try { |
| CompressedApexInfoList apexInfoList = getCompressedApexInfoList(packageFile); |
| if (apexInfoList == null) { |
| Log.i(TAG, "apex_info.pb not present in OTA package. " |
| + "Assuming device doesn't support compressed" |
| + "APEX, continueing without allocating space."); |
| return true; |
| } |
| ApexManager apexManager = ApexManager.getInstance(); |
| apexManager.reserveSpaceForCompressedApex(apexInfoList); |
| return true; |
| } catch (RemoteException e) { |
| e.rethrowAsRuntimeException(); |
| } catch (IOException | UnsupportedOperationException e) { |
| Slog.e(TAG, "Failed to reserve space for compressed apex: ", e); |
| } finally { |
| Binder.restoreCallingIdentity(token); |
| } |
| return false; |
| } |
| |
| @Override // Binder call |
| public boolean isLskfCaptured(String packageName) { |
| enforcePermissionForResumeOnReboot(); |
| boolean captured; |
| synchronized (this) { |
| captured = mCallerPreparedForReboot.contains(packageName); |
| } |
| |
| if (!captured) { |
| Slog.i(TAG, "Reboot requested before prepare completed for caller " |
| + packageName); |
| return false; |
| } |
| return true; |
| } |
| |
| /** |
| * Check if any of the init services is still running. If so, we cannot |
| * start a new uncrypt/setup-bcb/clear-bcb service right away; otherwise |
| * it may break the socket communication since init creates / deletes |
| * the socket (/dev/socket/uncrypt) on service start / exit. |
| */ |
| private boolean checkAndWaitForUncryptService() { |
| for (int retry = 0; retry < SOCKET_CONNECTION_MAX_RETRY; retry++) { |
| final String uncryptService = mInjector.systemPropertiesGet(INIT_SERVICE_UNCRYPT); |
| final String setupBcbService = mInjector.systemPropertiesGet(INIT_SERVICE_SETUP_BCB); |
| final String clearBcbService = mInjector.systemPropertiesGet(INIT_SERVICE_CLEAR_BCB); |
| final boolean busy = "running".equals(uncryptService) |
| || "running".equals(setupBcbService) || "running".equals(clearBcbService); |
| if (DEBUG) { |
| Slog.i(TAG, "retry: " + retry + " busy: " + busy |
| + " uncrypt: [" + uncryptService + "]" |
| + " setupBcb: [" + setupBcbService + "]" |
| + " clearBcb: [" + clearBcbService + "]"); |
| } |
| |
| if (!busy) { |
| return true; |
| } |
| |
| try { |
| mInjector.threadSleep(1000); |
| } catch (InterruptedException e) { |
| Slog.w(TAG, "Interrupted:", e); |
| } |
| } |
| |
| return false; |
| } |
| |
| private boolean setupOrClearBcb(boolean isSetup, String command) { |
| mContext.enforceCallingOrSelfPermission(android.Manifest.permission.RECOVERY, null); |
| |
| final boolean available = checkAndWaitForUncryptService(); |
| if (!available) { |
| Slog.e(TAG, "uncrypt service is unavailable."); |
| return false; |
| } |
| |
| if (isSetup) { |
| mInjector.systemPropertiesSet("ctl.start", "setup-bcb"); |
| } else { |
| mInjector.systemPropertiesSet("ctl.start", "clear-bcb"); |
| } |
| |
| // Connect to the uncrypt service socket. |
| UncryptSocket socket = mInjector.connectService(); |
| if (socket == null) { |
| Slog.e(TAG, "Failed to connect to uncrypt socket"); |
| return false; |
| } |
| |
| try { |
| // Send the BCB commands if it's to setup BCB. |
| if (isSetup) { |
| socket.sendCommand(command); |
| } |
| |
| // Read the status from the socket. |
| int status = socket.getPercentageUncrypted(); |
| |
| // Ack receipt of the status code. uncrypt waits for the ack so |
| // the socket won't be destroyed before we receive the code. |
| socket.sendAck(); |
| |
| if (status == 100) { |
| Slog.i(TAG, "uncrypt " + (isSetup ? "setup" : "clear") |
| + " bcb successfully finished."); |
| } else { |
| // Error in /system/bin/uncrypt. |
| Slog.e(TAG, "uncrypt failed with status: " + status); |
| return false; |
| } |
| } catch (IOException e) { |
| Slog.e(TAG, "IOException when communicating with uncrypt:", e); |
| return false; |
| } finally { |
| socket.close(); |
| } |
| |
| return true; |
| } |
| |
| /** |
| * Provides a wrapper for the low-level details of framing packets sent to the uncrypt |
| * socket. |
| */ |
| public static class UncryptSocket { |
| private LocalSocket mLocalSocket; |
| private DataInputStream mInputStream; |
| private DataOutputStream mOutputStream; |
| |
| /** |
| * Attempt to connect to the uncrypt service. Connection will be retried for up to |
| * {@link #SOCKET_CONNECTION_MAX_RETRY} times. If the connection is unsuccessful, the |
| * socket will be closed. If the connection is successful, the connection must be closed |
| * by the caller. |
| * |
| * @return true if connection was successful, false if unsuccessful |
| */ |
| public boolean connectService() { |
| mLocalSocket = new LocalSocket(); |
| boolean done = false; |
| // The uncrypt socket will be created by init upon receiving the |
| // service request. It may not be ready by this point. So we will |
| // keep retrying until success or reaching timeout. |
| for (int retry = 0; retry < SOCKET_CONNECTION_MAX_RETRY; retry++) { |
| try { |
| mLocalSocket.connect(new LocalSocketAddress(UNCRYPT_SOCKET, |
| LocalSocketAddress.Namespace.RESERVED)); |
| done = true; |
| break; |
| } catch (IOException ignored) { |
| try { |
| Thread.sleep(1000); |
| } catch (InterruptedException e) { |
| Slog.w(TAG, "Interrupted:", e); |
| } |
| } |
| } |
| if (!done) { |
| Slog.e(TAG, "Timed out connecting to uncrypt socket"); |
| close(); |
| return false; |
| } |
| |
| try { |
| mInputStream = new DataInputStream(mLocalSocket.getInputStream()); |
| mOutputStream = new DataOutputStream(mLocalSocket.getOutputStream()); |
| } catch (IOException e) { |
| close(); |
| return false; |
| } |
| |
| return true; |
| } |
| |
| /** |
| * Sends a command to the uncrypt service. |
| * |
| * @param command command to send to the uncrypt service |
| * @throws IOException if there was an error writing to the socket |
| */ |
| public void sendCommand(String command) throws IOException { |
| byte[] cmdUtf8 = command.getBytes(StandardCharsets.UTF_8); |
| mOutputStream.writeInt(cmdUtf8.length); |
| mOutputStream.write(cmdUtf8, 0, cmdUtf8.length); |
| } |
| |
| /** |
| * Reads the status from the uncrypt service which is usually represented as a percentage. |
| * @return an integer representing the percentage completed |
| * @throws IOException if there was an error reading the socket |
| */ |
| public int getPercentageUncrypted() throws IOException { |
| return mInputStream.readInt(); |
| } |
| |
| /** |
| * Sends a confirmation to the uncrypt service. |
| * @throws IOException if there was an error writing to the socket |
| */ |
| public void sendAck() throws IOException { |
| mOutputStream.writeInt(0); |
| } |
| |
| /** |
| * Closes the socket and all underlying data streams. |
| */ |
| public void close() { |
| IoUtils.closeQuietly(mInputStream); |
| IoUtils.closeQuietly(mOutputStream); |
| IoUtils.closeQuietly(mLocalSocket); |
| } |
| } |
| |
| private boolean isCallerShell() { |
| final int callingUid = Binder.getCallingUid(); |
| return callingUid == Process.SHELL_UID || callingUid == Process.ROOT_UID; |
| } |
| |
| private void enforceShell() { |
| if (!isCallerShell()) { |
| throw new SecurityException("Caller must be shell"); |
| } |
| } |
| |
| @Override |
| public void onShellCommand(FileDescriptor in, FileDescriptor out, FileDescriptor err, |
| String[] args, ShellCallback callback, ResultReceiver resultReceiver) { |
| enforceShell(); |
| final long origId = Binder.clearCallingIdentity(); |
| try { |
| new RecoverySystemShellCommand(this).exec( |
| this, in, out, err, args, callback, resultReceiver); |
| } finally { |
| Binder.restoreCallingIdentity(origId); |
| } |
| } |
| } |
