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

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

Merge "Handle CancellationException in BackupTransportClient" into tm-dev am:... 

Merge "Handle CancellationException in BackupTransportClient" into tm-dev am: 22f211ca am: 13f84fc0

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



Change-Id: Ie32ac1dbbd6f4835089b7e7483adb9c28bf88457
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents b0f5d9a8 13f84fc0

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

+8 −2
Original line number Diff line number Diff line
@@ -34,6 +34,7 @@ import java.util.HashSet; 
import java.util.List;

import java.util.Queue;

import java.util.Set;

import java.util.concurrent.CancellationException;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.TimeoutException;
@@ -374,7 +375,8 @@ public class BackupTransportClient { 
    private <T> T getFutureResult(AndroidFuture<T> future) {

        try {

            return future.get(600, TimeUnit.SECONDS);

        } catch (InterruptedException | ExecutionException | TimeoutException e) {

        } catch (InterruptedException | ExecutionException | TimeoutException

                | CancellationException e) {

            Slog.w(TAG, "Failed to get result from transport:", e);

            return null;

        } finally {
@@ -403,7 +405,11 @@ public class BackupTransportClient { 
        void cancelActiveFutures() {

            synchronized (mActiveFuturesLock) {

                for (AndroidFuture<?> future : mActiveFutures) {

                    try {

                        future.cancel(true);

                    } catch (CancellationException ignored) {

                        // This is expected, so ignore the exception.

                    }

                }

                mActiveFutures.clear();

            }

services/tests/servicestests/src/com/android/server/backup/transport/BackupTransportClientTest.java

+2 −5
Original line number Diff line number Diff line
@@ -110,10 +110,7 @@ public class BackupTransportClientTest { 


        Thread thread = new Thread(() -> {

            try {

                /*String name =*/ client.transportDirName();

                fail("transportDirName should be cancelled");

            } catch (CancellationException ex) {

                // This is expected.

                assertThat(client.transportDirName()).isNull();

            } catch (Exception ex) {

                fail("unexpected Exception: " + ex.getClass().getCanonicalName());

            }
@@ -189,7 +186,7 @@ public class BackupTransportClientTest { 
    }



    @Test

    public void testFinishBackup_canceledBeforeCompletion_throwsException() throws Exception {

    public void testFinishBackup_canceledBeforeCompletion_returnsError() throws Exception {

        TestCallbacksFakeTransportBinder binder = new TestCallbacksFakeTransportBinder();

        BackupTransportClient client = new BackupTransportClient(binder);