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

Commit 954e0d86 authored by Patrick Rohr's avatar Patrick Rohr
Browse files

Change Ethernet API to use OutcomeReceiver 

This change addresses API review feedback. In addition, it changes the
returned result from Network to the interface name. The current API
returning a Network object is racy and cannot be implemented correctly.
Users should instead use the ConnectivityManager#requestNetwork() API to
get hold of the Network for a given interface.

CP note: the Merged-In ID is not the actual Change-Id of this change in
tm-dev. This change was originally merged in aosp, but was subsequently
reverted and cherry-picked into tm-dev. The cherry-pick falsely reused
the Change-Id of the (now reverted) original change. This causes
automerger to skip this change on all branches between aosp-master and
tm-dev when the correct Merged-In ID is used. Therefore, the Merged-In
ID listed is the Change-Id of an unrelated change that is present in
tm-dev but not aosp-master.

Bug: 220017952
Test: TH
Ignore-AOSP-First: CP to make automerger happy.
Merged-In: Iefd24d955572589c5bd3ca9a8139ea6e44979e8a
Change-Id: I7c46545a47034be409071c2ec007d9e1480c6ed0
parent 9d4ca1d6

packages/ConnectivityT/framework-t/Android.bp

+1 −1
Original line number Diff line number Diff line
@@ -131,8 +131,8 @@ filegroup { 
        "src/android/net/EthernetNetworkUpdateRequest.java",

        "src/android/net/EthernetNetworkUpdateRequest.aidl",

        "src/android/net/IEthernetManager.aidl",

        "src/android/net/IEthernetNetworkManagementListener.aidl",

        "src/android/net/IEthernetServiceListener.aidl",

        "src/android/net/INetworkInterfaceOutcomeReceiver.aidl",

        "src/android/net/ITetheredInterfaceCallback.aidl",

    ],

    path: "src",

packages/ConnectivityT/framework-t/src/android/net/EthernetManager.java

+57 −45
Original line number Diff line number Diff line
@@ -30,6 +30,7 @@ import android.compat.annotation.UnsupportedAppUsage; 
import android.content.Context;

import android.content.pm.PackageManager;

import android.os.Build;

import android.os.OutcomeReceiver;

import android.os.RemoteException;



import com.android.internal.annotations.GuardedBy;
@@ -40,7 +41,6 @@ import java.lang.annotation.RetentionPolicy; 
import java.util.ArrayList;

import java.util.Objects;

import java.util.concurrent.Executor;

import java.util.function.BiConsumer;



/**

 * A class that manages and configures Ethernet interfaces.
@@ -443,41 +443,45 @@ public class EthernetManager { 
        return new TetheredInterfaceRequest(mService, cbInternal);

    }



    private static final class InternalNetworkManagementListener

            extends IEthernetNetworkManagementListener.Stub {

    private static final class NetworkInterfaceOutcomeReceiver

            extends INetworkInterfaceOutcomeReceiver.Stub {

        @NonNull

        private final Executor mExecutor;

        @NonNull

        private final BiConsumer<Network, EthernetNetworkManagementException> mListener;

        private final OutcomeReceiver<String, EthernetNetworkManagementException> mCallback;



        InternalNetworkManagementListener(

        NetworkInterfaceOutcomeReceiver(

                @NonNull final Executor executor,

                @NonNull final BiConsumer<Network, EthernetNetworkManagementException> listener) {

                @NonNull final OutcomeReceiver<String, EthernetNetworkManagementException>

                        callback) {

            Objects.requireNonNull(executor, "Pass a non-null executor");

            Objects.requireNonNull(listener, "Pass a non-null listener");

            Objects.requireNonNull(callback, "Pass a non-null callback");

            mExecutor = executor;

            mListener = listener;

            mCallback = callback;

        }



        @Override

        public void onComplete(

                @Nullable final Network network,

                @Nullable final EthernetNetworkManagementException e) {

            mExecutor.execute(() -> mListener.accept(network, e));

        public void onResult(@NonNull String iface) {

            mExecutor.execute(() -> mCallback.onResult(iface));

        }



        @Override

        public void onError(@NonNull EthernetNetworkManagementException e) {

            mExecutor.execute(() -> mCallback.onError(e));

        }

    }



    private InternalNetworkManagementListener getInternalNetworkManagementListener(

    private NetworkInterfaceOutcomeReceiver makeNetworkInterfaceOutcomeReceiver(

            @Nullable final Executor executor,

            @Nullable final BiConsumer<Network, EthernetNetworkManagementException> listener) {

        if (null != listener) {

            Objects.requireNonNull(executor, "Pass a non-null executor, or a null listener");

            @Nullable final OutcomeReceiver<String, EthernetNetworkManagementException> callback) {

        if (null != callback) {

            Objects.requireNonNull(executor, "Pass a non-null executor, or a null callback");

        }

        final InternalNetworkManagementListener proxy;

        if (null == listener) {

        final NetworkInterfaceOutcomeReceiver proxy;

        if (null == callback) {

            proxy = null;

        } else {

            proxy = new InternalNetworkManagementListener(executor, listener);

            proxy = new NetworkInterfaceOutcomeReceiver(executor, callback);

        }

        return proxy;

    }
@@ -492,14 +496,17 @@ public class EthernetManager { 
     * Similarly, use {@link NetworkCapabilities.Builder} to build a {@code NetworkCapabilities}

     * object for this network to put inside the {@code request}.

     *

     * If non-null, the listener will be called exactly once after this is called, unless

     * a synchronous exception was thrown.

     * This function accepts an {@link OutcomeReceiver} that is called once the operation has

     * finished execution.

     *

     * @param iface the name of the interface to act upon.

     * @param request the {@link EthernetNetworkUpdateRequest} used to set an ethernet network's

     *                {@link StaticIpConfiguration} and {@link NetworkCapabilities} values.

     * @param executor an {@link Executor} to execute the listener on. Optional if listener is null.

     * @param listener an optional {@link BiConsumer} to listen for completion of the operation.

     * @param executor an {@link Executor} to execute the callback on. Optional if callback is null.

     * @param callback an optional {@link OutcomeReceiver} to listen for completion of the

     *                 operation. On success, {@link OutcomeReceiver#onResult} is called with the

     *                 interface name. On error, {@link OutcomeReceiver#onError} is called with more

     *                 information about the error.

     * @throws SecurityException if the process doesn't hold

     *                          {@link android.Manifest.permission.MANAGE_ETHERNET_NETWORKS}.

     * @throws UnsupportedOperationException if called on a non-automotive device or on an
@@ -515,11 +522,11 @@ public class EthernetManager { 
            @NonNull String iface,

            @NonNull EthernetNetworkUpdateRequest request,

            @Nullable @CallbackExecutor Executor executor,

            @Nullable BiConsumer<Network, EthernetNetworkManagementException> listener) {

            @Nullable OutcomeReceiver<String, EthernetNetworkManagementException> callback) {

        Objects.requireNonNull(iface, "iface must be non-null");

        Objects.requireNonNull(request, "request must be non-null");

        final InternalNetworkManagementListener proxy = getInternalNetworkManagementListener(

                executor, listener);

        final NetworkInterfaceOutcomeReceiver proxy = makeNetworkInterfaceOutcomeReceiver(

                executor, callback);

        try {

            mService.updateConfiguration(iface, request, proxy);

        } catch (RemoteException e) {
@@ -530,15 +537,17 @@ public class EthernetManager { 
    /**

     * Set an ethernet network's link state up.

     *

     * When the link is successfully turned up, the listener will be called with the resulting

     * network. If any error or unexpected condition happens while the system tries to turn the

     * interface up, the listener will be called with an appropriate exception.

     * The listener is guaranteed to be called exactly once for each call to this method, but this

     * may take an unbounded amount of time depending on the actual network conditions.

     * When the link is successfully turned up, the callback will be called with the network

     * interface was torn down, if any. If any error or unexpected condition happens while the

     * system tries to turn the interface down, the callback will be called with an appropriate

     * exception. The callback is guaranteed to be called exactly once for each call to this method.

     *

     * @param iface the name of the interface to act upon.

     * @param executor an {@link Executor} to execute the listener on. Optional if listener is null.

     * @param listener an optional {@link BiConsumer} to listen for completion of the operation.

     * @param executor an {@link Executor} to execute the callback on. Optional if callback is null.

     * @param callback an optional {@link OutcomeReceiver} to listen for completion of the

     *                 operation. On success, {@link OutcomeReceiver#onResult} is called with the

     *                 interface name. On error, {@link OutcomeReceiver#onError} is called with more

     *                 information about the error.

     * @throws SecurityException if the process doesn't hold

     *                          {@link android.Manifest.permission.MANAGE_ETHERNET_NETWORKS}.

     * @throws UnsupportedOperationException if called on a non-automotive device.
@@ -553,10 +562,10 @@ public class EthernetManager { 
    public void connectNetwork(

            @NonNull String iface,

            @Nullable @CallbackExecutor Executor executor,

            @Nullable BiConsumer<Network, EthernetNetworkManagementException> listener) {

            @Nullable OutcomeReceiver<String, EthernetNetworkManagementException> callback) {

        Objects.requireNonNull(iface, "iface must be non-null");

        final InternalNetworkManagementListener proxy = getInternalNetworkManagementListener(

                executor, listener);

        final NetworkInterfaceOutcomeReceiver proxy = makeNetworkInterfaceOutcomeReceiver(

                executor, callback);

        try {

            mService.connectNetwork(iface, proxy);

        } catch (RemoteException e) {
@@ -567,14 +576,17 @@ public class EthernetManager { 
    /**

     * Set an ethernet network's link state down.

     *

     * When the link is successfully turned down, the listener will be called with the network that

     * was torn down, if any. If any error or unexpected condition happens while the system tries to

     * turn the interface down, the listener will be called with an appropriate exception.

     * The listener is guaranteed to be called exactly once for each call to this method.

     * When the link is successfully turned down, the callback will be called with the network

     * interface was torn down, if any. If any error or unexpected condition happens while the

     * system tries to turn the interface down, the callback will be called with an appropriate

     * exception. The callback is guaranteed to be called exactly once for each call to this method.

     *

     * @param iface the name of the interface to act upon.

     * @param executor an {@link Executor} to execute the listener on. Optional if listener is null.

     * @param listener an optional {@link BiConsumer} to listen for completion of the operation.

     * @param executor an {@link Executor} to execute the callback on. Optional if callback is null.

     * @param callback an optional {@link OutcomeReceiver} to listen for completion of the

     *                 operation. On success, {@link OutcomeReceiver#onResult} is called with the

     *                 interface name. On error, {@link OutcomeReceiver#onError} is called with more

     *                 information about the error.

     * @throws SecurityException if the process doesn't hold

     *                          {@link android.Manifest.permission.MANAGE_ETHERNET_NETWORKS}.

     * @throws UnsupportedOperationException if called on a non-automotive device.
@@ -589,10 +601,10 @@ public class EthernetManager { 
    public void disconnectNetwork(

            @NonNull String iface,

            @Nullable @CallbackExecutor Executor executor,

            @Nullable BiConsumer<Network, EthernetNetworkManagementException> listener) {

            @Nullable OutcomeReceiver<String, EthernetNetworkManagementException> callback) {

        Objects.requireNonNull(iface, "iface must be non-null");

        final InternalNetworkManagementListener proxy = getInternalNetworkManagementListener(

                executor, listener);

        final NetworkInterfaceOutcomeReceiver proxy = makeNetworkInterfaceOutcomeReceiver(

                executor, callback);

        try {

            mService.disconnectNetwork(iface, proxy);

        } catch (RemoteException e) {

packages/ConnectivityT/framework-t/src/android/net/IEthernetManager.aidl

+5 −4
Original line number Diff line number Diff line
@@ -18,8 +18,9 @@ package android.net; 


import android.net.IpConfiguration;

import android.net.IEthernetServiceListener;

import android.net.IEthernetNetworkManagementListener;

import android.net.EthernetNetworkManagementException;

import android.net.EthernetNetworkUpdateRequest;

import android.net.INetworkInterfaceOutcomeReceiver;

import android.net.ITetheredInterfaceCallback;



/**
@@ -39,7 +40,7 @@ interface IEthernetManager 
    void requestTetheredInterface(in ITetheredInterfaceCallback callback);

    void releaseTetheredInterface(in ITetheredInterfaceCallback callback);

    void updateConfiguration(String iface, in EthernetNetworkUpdateRequest request,

        in IEthernetNetworkManagementListener listener);

    void connectNetwork(String iface, in IEthernetNetworkManagementListener listener);

    void disconnectNetwork(String iface, in IEthernetNetworkManagementListener listener);

        in INetworkInterfaceOutcomeReceiver listener);

    void connectNetwork(String iface, in INetworkInterfaceOutcomeReceiver listener);

    void disconnectNetwork(String iface, in INetworkInterfaceOutcomeReceiver listener);

}

packages/ConnectivityT/framework-t/src/android/net/IEthernetNetworkManagementListener.aidl→packages/ConnectivityT/framework-t/src/android/net/INetworkInterfaceOutcomeReceiver.aidl

+3 −3
Original line number Diff line number Diff line
@@ -17,9 +17,9 @@ 
package android.net;



import android.net.EthernetNetworkManagementException;

import android.net.Network;



/** @hide */

oneway interface IEthernetNetworkManagementListener {

    void onComplete(in Network network, in EthernetNetworkManagementException exception);

oneway interface INetworkInterfaceOutcomeReceiver {

    void onResult(in String iface);

    void onError(in EthernetNetworkManagementException e);

}
 
 No newline at end of file