Loading services/companion/java/com/android/server/companion/datatransfer/continuity/TaskContinuityManagerService.java +2 −1 Original line number Diff line number Diff line Loading @@ -71,7 +71,8 @@ public final class TaskContinuityManagerService mRemoteTaskStore = new RemoteTaskStore(); mOutboundHandoffRequestController = new OutboundHandoffRequestController( context, mTaskContinuityMessenger); mTaskContinuityMessenger, mRemoteTaskStore); mInboundHandoffRequestController = new InboundHandoffRequestController( mTaskContinuityMessenger); } Loading services/companion/java/com/android/server/companion/datatransfer/continuity/handoff/OutboundHandoffRequestController.java +7 −1 Original line number Diff line number Diff line Loading @@ -26,6 +26,7 @@ import com.android.server.companion.datatransfer.continuity.messages.HandoffRequ import com.android.server.companion.datatransfer.continuity.messages.HandoffRequestResultMessage; import com.android.server.companion.datatransfer.continuity.handoff.HandoffActivityStarter; import com.android.server.companion.datatransfer.continuity.handoff.HandoffRequestCallbackHolder; import com.android.server.companion.datatransfer.continuity.tasks.RemoteTaskStore; import android.annotation.NonNull; import android.app.HandoffActivityData; Loading Loading @@ -54,19 +55,23 @@ public class OutboundHandoffRequestController { private final Context mContext; private final TaskContinuityMessenger mTaskContinuityMessenger; private final RemoteTaskStore mRemoteTaskStore; private final HandoffRequestCallbackHolder mHandoffRequestCallbackHolder = new HandoffRequestCallbackHolder(); private final Set<PendingHandoffRequest> mPendingHandoffRequests = new HashSet<>(); public OutboundHandoffRequestController( @NonNull Context context, @NonNull TaskContinuityMessenger taskContinuityMessenger) { @NonNull TaskContinuityMessenger taskContinuityMessenger, @NonNull RemoteTaskStore remoteTaskStore) { Objects.requireNonNull(context); Objects.requireNonNull(taskContinuityMessenger); Objects.requireNonNull(remoteTaskStore); mContext = context; mTaskContinuityMessenger = taskContinuityMessenger; mRemoteTaskStore = remoteTaskStore; } public void requestHandoff(int associationId, int taskId, IHandoffRequestCallback callback) { Loading Loading @@ -157,6 +162,7 @@ public class OutboundHandoffRequestController { mPendingHandoffRequests.remove(request); mHandoffRequestCallbackHolder .notifyAndRemoveCallbacks(associationId, taskId, statusCode); mRemoteTaskStore.removeTask(associationId, taskId); } } } No newline at end of file services/tests/servicestests/src/com/android/server/companion/datatransfer/continuity/handoff/OutboundHandoffRequestControllerTest.java +7 −1 Original line number Diff line number Diff line Loading @@ -30,6 +30,7 @@ import static org.mockito.ArgumentMatchers.any; import com.android.server.companion.datatransfer.continuity.connectivity.TaskContinuityMessenger; import com.android.server.companion.datatransfer.continuity.messages.HandoffRequestMessage; import com.android.server.companion.datatransfer.continuity.messages.HandoffRequestResultMessage; import com.android.server.companion.datatransfer.continuity.tasks.RemoteTaskStore; import android.app.ActivityManager; import android.app.HandoffActivityData; Loading @@ -56,6 +57,7 @@ public class OutboundHandoffRequestControllerTest { @Mock private Context mMockContext; @Mock private TaskContinuityMessenger mMockTaskContinuityMessenger; @Mock private PackageManager mMockPackageManager; @Mock private RemoteTaskStore mMockRemoteTaskStore; private OutboundHandoffRequestController mOutboundHandoffRequestController; Loading @@ -65,7 +67,8 @@ public class OutboundHandoffRequestControllerTest { doReturn(mMockPackageManager).when(mMockContext).getPackageManager(); mOutboundHandoffRequestController = new OutboundHandoffRequestController( mMockContext, mMockTaskContinuityMessenger); mMockTaskContinuityMessenger, mMockRemoteTaskStore); } @Test Loading Loading @@ -130,6 +133,9 @@ public class OutboundHandoffRequestControllerTest { associationId, taskId, TaskContinuityManager.HANDOFF_REQUEST_RESULT_SUCCESS); // Verify the task was removed from the store. verify(mMockRemoteTaskStore).removeTask(associationId, taskId); } @Test Loading Loading
services/companion/java/com/android/server/companion/datatransfer/continuity/TaskContinuityManagerService.java +2 −1 Original line number Diff line number Diff line Loading @@ -71,7 +71,8 @@ public final class TaskContinuityManagerService mRemoteTaskStore = new RemoteTaskStore(); mOutboundHandoffRequestController = new OutboundHandoffRequestController( context, mTaskContinuityMessenger); mTaskContinuityMessenger, mRemoteTaskStore); mInboundHandoffRequestController = new InboundHandoffRequestController( mTaskContinuityMessenger); } Loading
services/companion/java/com/android/server/companion/datatransfer/continuity/handoff/OutboundHandoffRequestController.java +7 −1 Original line number Diff line number Diff line Loading @@ -26,6 +26,7 @@ import com.android.server.companion.datatransfer.continuity.messages.HandoffRequ import com.android.server.companion.datatransfer.continuity.messages.HandoffRequestResultMessage; import com.android.server.companion.datatransfer.continuity.handoff.HandoffActivityStarter; import com.android.server.companion.datatransfer.continuity.handoff.HandoffRequestCallbackHolder; import com.android.server.companion.datatransfer.continuity.tasks.RemoteTaskStore; import android.annotation.NonNull; import android.app.HandoffActivityData; Loading Loading @@ -54,19 +55,23 @@ public class OutboundHandoffRequestController { private final Context mContext; private final TaskContinuityMessenger mTaskContinuityMessenger; private final RemoteTaskStore mRemoteTaskStore; private final HandoffRequestCallbackHolder mHandoffRequestCallbackHolder = new HandoffRequestCallbackHolder(); private final Set<PendingHandoffRequest> mPendingHandoffRequests = new HashSet<>(); public OutboundHandoffRequestController( @NonNull Context context, @NonNull TaskContinuityMessenger taskContinuityMessenger) { @NonNull TaskContinuityMessenger taskContinuityMessenger, @NonNull RemoteTaskStore remoteTaskStore) { Objects.requireNonNull(context); Objects.requireNonNull(taskContinuityMessenger); Objects.requireNonNull(remoteTaskStore); mContext = context; mTaskContinuityMessenger = taskContinuityMessenger; mRemoteTaskStore = remoteTaskStore; } public void requestHandoff(int associationId, int taskId, IHandoffRequestCallback callback) { Loading Loading @@ -157,6 +162,7 @@ public class OutboundHandoffRequestController { mPendingHandoffRequests.remove(request); mHandoffRequestCallbackHolder .notifyAndRemoveCallbacks(associationId, taskId, statusCode); mRemoteTaskStore.removeTask(associationId, taskId); } } } No newline at end of file
services/tests/servicestests/src/com/android/server/companion/datatransfer/continuity/handoff/OutboundHandoffRequestControllerTest.java +7 −1 Original line number Diff line number Diff line Loading @@ -30,6 +30,7 @@ import static org.mockito.ArgumentMatchers.any; import com.android.server.companion.datatransfer.continuity.connectivity.TaskContinuityMessenger; import com.android.server.companion.datatransfer.continuity.messages.HandoffRequestMessage; import com.android.server.companion.datatransfer.continuity.messages.HandoffRequestResultMessage; import com.android.server.companion.datatransfer.continuity.tasks.RemoteTaskStore; import android.app.ActivityManager; import android.app.HandoffActivityData; Loading @@ -56,6 +57,7 @@ public class OutboundHandoffRequestControllerTest { @Mock private Context mMockContext; @Mock private TaskContinuityMessenger mMockTaskContinuityMessenger; @Mock private PackageManager mMockPackageManager; @Mock private RemoteTaskStore mMockRemoteTaskStore; private OutboundHandoffRequestController mOutboundHandoffRequestController; Loading @@ -65,7 +67,8 @@ public class OutboundHandoffRequestControllerTest { doReturn(mMockPackageManager).when(mMockContext).getPackageManager(); mOutboundHandoffRequestController = new OutboundHandoffRequestController( mMockContext, mMockTaskContinuityMessenger); mMockTaskContinuityMessenger, mMockRemoteTaskStore); } @Test Loading Loading @@ -130,6 +133,9 @@ public class OutboundHandoffRequestControllerTest { associationId, taskId, TaskContinuityManager.HANDOFF_REQUEST_RESULT_SUCCESS); // Verify the task was removed from the store. verify(mMockRemoteTaskStore).removeTask(associationId, taskId); } @Test Loading