Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 190e8734 authored by Ruslan Tkhakokhov's avatar Ruslan Tkhakokhov Committed by Automerger Merge Worker
Browse files

Merge "Make BackupTransport more resilient" into tm-dev am: a3a65735 

Original change: https://googleplex-android-review.googlesource.com/c/platform/frameworks/base/+/18321342



Change-Id: Ib0591ac8015af0b65658000d214f94710ddb9b9d
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents 3e2ab1be a3a65735

core/java/android/app/backup/BackupTransport.java

+163 −55
Original line number Diff line number Diff line
@@ -665,184 +665,292 @@ public class BackupTransport { 


        @Override

        public void name(AndroidFuture<String> resultFuture) throws RemoteException {

            try {

                String result = BackupTransport.this.name();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void configurationIntent(AndroidFuture<Intent> resultFuture)

                throws RemoteException {

            try {

                Intent result = BackupTransport.this.configurationIntent();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void currentDestinationString(AndroidFuture<String> resultFuture)

                throws RemoteException {

            try {

                String result = BackupTransport.this.currentDestinationString();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void dataManagementIntent(AndroidFuture<Intent> resultFuture)

                throws RemoteException {

            try {

                Intent result = BackupTransport.this.dataManagementIntent();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void dataManagementIntentLabel(AndroidFuture<CharSequence> resultFuture)

                throws RemoteException {

            try {

                CharSequence result = BackupTransport.this.dataManagementIntentLabel();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void transportDirName(AndroidFuture<String> resultFuture) throws RemoteException {

            try {

                String result = BackupTransport.this.transportDirName();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void requestBackupTime(AndroidFuture<Long> resultFuture) throws RemoteException {

            try {

                long result = BackupTransport.this.requestBackupTime();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void initializeDevice(ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.initializeDevice();

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void performBackup(PackageInfo packageInfo, ParcelFileDescriptor inFd, int flags,

                ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.performBackup(packageInfo, inFd, flags);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void clearBackupData(PackageInfo packageInfo, ITransportStatusCallback callback)

                throws RemoteException {

            try {

                int result = BackupTransport.this.clearBackupData(packageInfo);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void finishBackup(ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.finishBackup();

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void getAvailableRestoreSets(AndroidFuture<List<RestoreSet>> resultFuture)

                throws RemoteException {

            try {

                RestoreSet[] result = BackupTransport.this.getAvailableRestoreSets();

                resultFuture.complete(Arrays.asList(result));

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void getCurrentRestoreSet(AndroidFuture<Long> resultFuture)

                throws RemoteException {

            try {

                long result = BackupTransport.this.getCurrentRestoreSet();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void startRestore(long token, PackageInfo[] packages,

                ITransportStatusCallback callback)  throws RemoteException {

            try {

                int result = BackupTransport.this.startRestore(token, packages);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void nextRestorePackage(AndroidFuture<RestoreDescription> resultFuture)

                throws RemoteException {

            try {

                RestoreDescription result = BackupTransport.this.nextRestorePackage();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void getRestoreData(ParcelFileDescriptor outFd,

                ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.getRestoreData(outFd);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void finishRestore(ITransportStatusCallback callback)

                throws RemoteException {

            try {

                BackupTransport.this.finishRestore();

                callback.onOperationComplete();

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void requestFullBackupTime(AndroidFuture<Long> resultFuture)

                throws RemoteException {

            try {

                long result = BackupTransport.this.requestFullBackupTime();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void performFullBackup(PackageInfo targetPackage, ParcelFileDescriptor socket,

                int flags, ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.performFullBackup(targetPackage, socket, flags);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void checkFullBackupSize(long size, ITransportStatusCallback callback)

                throws RemoteException {

            try {

                int result = BackupTransport.this.checkFullBackupSize(size);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

            callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void sendBackupData(int numBytes, ITransportStatusCallback callback)

                throws RemoteException {

            try {

                int result = BackupTransport.this.sendBackupData(numBytes);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void cancelFullBackup(ITransportStatusCallback callback) throws RemoteException {

            try {

                BackupTransport.this.cancelFullBackup();

                callback.onOperationComplete();

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void isAppEligibleForBackup(PackageInfo targetPackage, boolean isFullBackup,

                AndroidFuture<Boolean> resultFuture) throws RemoteException {

            try {

                boolean result = BackupTransport.this.isAppEligibleForBackup(targetPackage,

                        isFullBackup);

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void getBackupQuota(String packageName, boolean isFullBackup,

                AndroidFuture<Long> resultFuture) throws RemoteException {

            try {

                long result = BackupTransport.this.getBackupQuota(packageName, isFullBackup);

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void getTransportFlags(AndroidFuture<Integer> resultFuture) throws RemoteException {

            try {

                int result = BackupTransport.this.getTransportFlags();

                resultFuture.complete(result);

            } catch (RuntimeException e) {

                resultFuture.cancel(/* mayInterruptIfRunning */ true);

            }

        }



        @Override

        public void getNextFullRestoreDataChunk(ParcelFileDescriptor socket,

                ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.getNextFullRestoreDataChunk(socket);

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }



        @Override

        public void abortFullRestore(ITransportStatusCallback callback) throws RemoteException {

            try {

                int result = BackupTransport.this.abortFullRestore();

                callback.onOperationCompleteWithStatus(result);

            } catch (RuntimeException e) {

                callback.onOperationCompleteWithStatus(BackupTransport.TRANSPORT_ERROR);

            }

        }

    }

}

services/backup/backuplib/java/com/android/server/backup/transport/TransportStatusCallback.java

+1 −1
Original line number Diff line number Diff line
@@ -26,7 +26,7 @@ import com.android.internal.backup.ITransportStatusCallback; 


public class TransportStatusCallback extends ITransportStatusCallback.Stub {

    private static final String TAG = "TransportStatusCallback";

    private static final int TIMEOUT_MILLIS = 600 * 1000; // 10 minutes.

    private static final int TIMEOUT_MILLIS = 300 * 1000; // 5 minutes.

    private static final int OPERATION_STATUS_DEFAULT = 0;



    private final int mOperationTimeout;