| /* |
| * Copyright (C) 2020 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 android.car.vms; |
| |
| import android.annotation.CallbackExecutor; |
| import android.annotation.NonNull; |
| import android.annotation.RequiresPermission; |
| import android.car.Car; |
| import android.car.CarManagerBase; |
| import android.car.annotation.RequiredFeature; |
| import android.os.IBinder; |
| import android.os.RemoteException; |
| import android.util.ArrayMap; |
| import android.util.Log; |
| |
| import com.android.internal.annotations.GuardedBy; |
| |
| import java.util.Map; |
| import java.util.concurrent.Executor; |
| |
| /** |
| * Car Service manager for connecting clients to the Vehicle Map Service. |
| * |
| * @hide |
| */ |
| @RequiredFeature(Car.VEHICLE_MAP_SERVICE) |
| public class VmsClientManager extends CarManagerBase { |
| private static final boolean DBG = false; |
| private static final String TAG = VmsClientManager.class.getSimpleName(); |
| |
| /** |
| * Callback interface for Vehicle Map Service clients. |
| * |
| * @hide |
| */ |
| public interface VmsClientCallback { |
| /** |
| * Invoked when a Vehicle Map Service connection has been established for the callback. |
| * |
| * @param client API client |
| */ |
| void onClientConnected(VmsClient client); |
| |
| /** |
| * Invoked when the availability of data layers has changed. |
| * |
| * @param availableLayers Current layer availability |
| */ |
| void onLayerAvailabilityChanged(VmsAvailableLayers availableLayers); |
| |
| /** |
| * Invoked when any subscriptions to data layers have changed. |
| * |
| * @param subscriptionState Current subscription state |
| */ |
| void onSubscriptionStateChanged(VmsSubscriptionState subscriptionState); |
| |
| /** |
| * Invoked whenever a message is received for this client's subscriptions. |
| * |
| * @param providerId Message provider |
| * @param layer Message layer |
| * @param message Message payload |
| */ |
| void onMessageReceived(int providerId, VmsLayer layer, byte[] message); |
| } |
| |
| private final IVmsBrokerService mBrokerService; |
| |
| private final Object mLock = new Object(); |
| @GuardedBy("mLock") |
| private final Map<VmsClientCallback, VmsClient> mClients = new ArrayMap<>(); |
| |
| public VmsClientManager(Car car, IBinder service) { |
| super(car); |
| mBrokerService = IVmsBrokerService.Stub.asInterface(service); |
| } |
| |
| /** |
| * Registers new Vehicle Map Service client for the given callback. |
| * |
| * If the callback is already registered, no action is taken. |
| * |
| * @param executor Executor to run callback operations |
| * @param callback Callback to register for new client |
| */ |
| @RequiresPermission(anyOf = {Car.PERMISSION_VMS_PUBLISHER, Car.PERMISSION_VMS_SUBSCRIBER}) |
| public void registerVmsClientCallback( |
| @NonNull @CallbackExecutor Executor executor, |
| @NonNull VmsClientCallback callback) { |
| VmsClient client; |
| synchronized (mLock) { |
| if (mClients.containsKey(callback)) { |
| Log.w(TAG, "VmsClient already registered"); |
| return; |
| } |
| |
| client = new VmsClient(mBrokerService, executor, callback, |
| this::handleRemoteExceptionFromCarService); |
| mClients.put(callback, client); |
| if (DBG) Log.d(TAG, "Client count: " + mClients.size()); |
| } |
| |
| try { |
| if (DBG) Log.d(TAG, "Registering VmsClient"); |
| client.register(); |
| } catch (RemoteException e) { |
| Log.e(TAG, "Error while registering", e); |
| synchronized (mLock) { |
| mClients.remove(callback); |
| } |
| handleRemoteExceptionFromCarService(e); |
| return; |
| } |
| |
| if (DBG) Log.d(TAG, "Triggering callbacks for new VmsClient"); |
| executor.execute(() -> { |
| callback.onClientConnected(client); |
| callback.onLayerAvailabilityChanged(client.getAvailableLayers()); |
| callback.onSubscriptionStateChanged(client.getSubscriptionState()); |
| }); |
| } |
| |
| /** |
| * Unregisters the Vehicle Map Service client associated with the given callback. |
| * |
| * If the callback is not registered, no action is taken. |
| * |
| * @param callback |
| */ |
| @RequiresPermission(anyOf = {Car.PERMISSION_VMS_PUBLISHER, Car.PERMISSION_VMS_SUBSCRIBER}) |
| public void unregisterVmsClientCallback(@NonNull VmsClientCallback callback) { |
| VmsClient client; |
| synchronized (mLock) { |
| client = mClients.remove(callback); |
| } |
| if (client == null) { |
| Log.w(TAG, "Unregister called for unknown callback"); |
| return; |
| } |
| |
| if (DBG) Log.d(TAG, "Unregistering VmsClient"); |
| try { |
| client.unregister(); |
| } catch (RemoteException e) { |
| handleRemoteExceptionFromCarService(e); |
| } |
| } |
| |
| @Override |
| protected void onCarDisconnected() { |
| synchronized (mLock) { |
| Log.w(TAG, "Car disconnected with " + mClients.size() + " active clients"); |
| mClients.clear(); |
| } |
| } |
| } |