Home
last modified time | relevance | path

Searched refs:VmsLayer (Results 1 – 25 of 32) sorted by relevance

12

/packages/services/Car/tests/carservice_test/src/com/android/car/
DVmsHalServiceSubscriptionEventTest.java21 import android.car.vms.VmsLayer;
43 List<VmsLayer> layers = new ArrayList<>(); in testEmptySubscriptions()
49 List<VmsLayer> layers = in testOneSubscription()
50 Collections.singletonList(new VmsLayer(8, 0, 3)); in testOneSubscription()
56 List<VmsLayer> layers = Arrays.asList( in testManySubscriptions()
57 new VmsLayer(8, 1, 3), in testManySubscriptions()
58 new VmsLayer(5, 2, 1), in testManySubscriptions()
59 new VmsLayer(3, 3, 9), in testManySubscriptions()
60 new VmsLayer(2, 4, 7), in testManySubscriptions()
61 new VmsLayer(9, 5, 3)); in testManySubscriptions()
[all …]
DVmsSubscriberManagerTest.java25 import android.car.vms.VmsLayer;
52 private static final VmsLayer SUBSCRIPTION_LAYER = new VmsLayer(SUBSCRIPTION_LAYER_ID,
60 private static final VmsLayer SUBSCRIPTION_DEPENDANT_LAYER_1 =
61 new VmsLayer(SUBSCRIPTION_DEPENDANT_LAYER_ID_1,
70 private static final VmsLayer SUBSCRIPTION_DEPENDANT_LAYER_2 =
71 new VmsLayer(SUBSCRIPTION_DEPENDANT_LAYER_ID_2,
98 Pair<VmsLayer, byte[]> message = getMockSubscriberClient().receiveMessage(); in testSubscribe()
136 Pair<VmsLayer, byte[]> message = getMockSubscriberClient().receiveMessage(); in testSubscribeFromPublisher()
212 Pair<VmsLayer, byte[]> message = getMockSubscriberClient().receiveMessage(); in testSubscribeAll()
DVmsOperationRecorderTest.java21 import android.car.vms.VmsLayer;
66 private static final VmsLayer layer1 = new VmsLayer(1, 3, 2);
67 private static final VmsLayer layer2 = new VmsLayer(2, 4, 3);
68 private static final VmsLayer layer3 = new VmsLayer(3, 5, 4);
72 new HashSet<VmsLayer>(Arrays.asList(layer2, layer3)));
DVmsPublisherSubscriberTest.java27 import android.car.vms.VmsLayer;
53 private static final VmsLayer SUBSCRIPTION_LAYER = new VmsLayer(1, 1, 1);
54 private static final VmsLayer SUBSCRIPTION_LAYER_OTHER = new VmsLayer(2, 1, 1);
569 private void assertSubscriptionState(int sequenceNumber, VmsLayer... layers) { in assertSubscriptionState()
580 private void assertSubscriptionState(int sequenceNumber, Set<VmsLayer> layers, in assertSubscriptionState()
601 private void assertDataMessage(VmsLayer layer, byte[] payload) { in assertDataMessage()
602 Pair<VmsLayer, byte[]> message = mSubscriberClient.receiveMessage(); in assertDataMessage()
DMockedVmsTestBase.java24 import android.car.vms.VmsLayer;
153 private BlockingQueue<Pair<VmsLayer, byte[]>> mMessages = new LinkedBlockingQueue<>();
157 public void onVmsMessageReceived(VmsLayer layer, byte[] payload) { in onVmsMessageReceived()
168 Pair<VmsLayer, byte[]> receiveMessage() { in receiveMessage()
/packages/services/Car/car-lib/src/android/car/vms/
DVmsLayerDependency.java45 private final @NonNull VmsLayer mLayer;
50 private @NonNull Set<VmsLayer> mDependencies;
61 private Set<VmsLayer> unparcelDependencies(Parcel in) { in unparcelDependencies()
62 return (Set<VmsLayer>) in.readArraySet(VmsLayer.class.getClassLoader()); in unparcelDependencies()
71 public VmsLayerDependency(@NonNull VmsLayer layer) { in VmsLayerDependency()
100 @NonNull VmsLayer layer, in VmsLayerDependency()
101 @NonNull Set<VmsLayer> dependencies) { in VmsLayerDependency()
116 public @NonNull VmsLayer getLayer() { in getLayer()
124 public @NonNull Set<VmsLayer> getDependencies() { in getDependencies()
190 VmsLayer layer = (VmsLayer) in.readTypedObject(VmsLayer.CREATOR); in VmsLayerDependency()
[all …]
DVmsLayer.java44 public final class VmsLayer implements Parcelable { class
96 public VmsLayer( in VmsLayer() method in VmsLayer
154 VmsLayer that = (VmsLayer) o; in equals()
193 /* package-private */ VmsLayer(@android.annotation.NonNull Parcel in) { in VmsLayer() method in VmsLayer
209 public static final @android.annotation.NonNull Parcelable.Creator<VmsLayer> CREATOR
210 = new Parcelable.Creator<VmsLayer>() {
212 public VmsLayer[] newArray(int size) {
213 return new VmsLayer[size];
217 public VmsLayer createFromParcel(@android.annotation.NonNull Parcel in) {
218 return new VmsLayer(in);
DVmsOperationRecorder.java67 public void subscribe(VmsLayer layer) { in subscribe()
74 public void unsubscribe(VmsLayer layer) { in unsubscribe()
82 public void subscribe(VmsLayer layer, int publisherId) { in subscribe()
90 public void unsubscribe(VmsLayer layer, int publisherId) { in unsubscribe()
129 public void addSubscription(int sequenceNumber, VmsLayer layer) { in addSubscription()
137 public void removeSubscription(int sequenceNumber, VmsLayer layer) { in removeSubscription()
161 public void addHalSubscription(int sequenceNumber, VmsLayer layer) { in addHalSubscription()
169 public void removeHalSubscription(int sequenceNumber, VmsLayer layer) { in removeHalSubscription()
199 private void recordOp(String operation, VmsLayer layer) { in recordOp()
235 private void recordOp(String operation, String intArgName, int arg, VmsLayer layer) { in recordOp()
[all …]
DVmsSubscriptionHelper.java45 private final Set<VmsLayer> mLayerSubscriptions = new ArraySet<>();
48 private final Map<VmsLayer, SparseBooleanArray> mPublisherSubscriptions = new ArrayMap<>();
65 public void subscribe(@NonNull VmsLayer layer) { in subscribe()
78 public void subscribe(@NonNull VmsLayer layer, int providerId) { in subscribe()
94 public void unsubscribe(@NonNull VmsLayer layer) { in unsubscribe()
107 public void unsubscribe(@NonNull VmsLayer layer, int providerId) { in unsubscribe()
146 Map.Entry<VmsLayer, SparseBooleanArray> entry) { in toAssociatedLayer() argument
DVmsSubscriptionState.java54 private @NonNull Set<VmsLayer> mLayers;
71 private Set<VmsLayer> unparcelLayers(Parcel in) { in unparcelLayers()
72 return (Set<VmsLayer>) in.readArraySet(VmsLayer.class.getClassLoader()); in unparcelLayers()
112 @NonNull Set<VmsLayer> layers, in VmsSubscriptionState()
137 public @NonNull Set<VmsLayer> getLayers() { in getLayers()
216 Set<VmsLayer> layers = unparcelLayers(in); in VmsSubscriptionState()
DVmsAssociatedLayer.java42 private final @NonNull VmsLayer mVmsLayer;
98 @NonNull VmsLayer vmsLayer, in VmsAssociatedLayer()
114 public @NonNull VmsLayer getVmsLayer() { in getVmsLayer()
188 VmsLayer vmsLayer = (VmsLayer) in.readTypedObject(VmsLayer.CREATOR); in VmsAssociatedLayer()
DVmsSubscriberManager.java62 void onVmsMessageReceived(@NonNull VmsLayer layer, byte[] payload); in onVmsMessageReceived()
177 public void subscribe(@NonNull VmsLayer layer) { in subscribe()
189 public void subscribe(@NonNull VmsLayer layer, int publisherId) { in subscribe()
207 public void unsubscribe(@NonNull VmsLayer layer) { in unsubscribe()
219 public void unsubscribe(@NonNull VmsLayer layer, int publisherId) { in unsubscribe()
278 public void onPacketReceived(int providerId, VmsLayer layer, byte[] packet) { in onPacketReceived()
DIVmsClientCallback.aidl20 import android.car.vms.VmsLayer;
38 in VmsLayer layer, in onPacketReceived()
43 in VmsLayer layer, in onLargePacketReceived()
DIVmsBrokerService.aidl21 import android.car.vms.VmsLayer;
70 in VmsLayer layer, in publishPacket()
76 in VmsLayer layer, in publishLargePacket()
DVmsPublisherClientService.java138 public final void publish(@NonNull VmsLayer layer, int publisherId, byte[] payload) { in publish()
205 public void onPacketReceived(int providerId, VmsLayer layer, byte[] packet) { in onPacketReceived()
/packages/services/Car/service/src/com/android/car/vms/
DVmsLayerAvailability.java21 import android.car.vms.VmsLayer;
51 private final Map<VmsLayer, Set<Set<VmsLayer>>> mPotentialLayersAndDependencies =
56 private Map<VmsLayer, Set<Integer>> mPotentialLayersAndPublishers = new HashMap<>();
69 VmsLayer layer = dependency.getLayer(); in setPublishersOffering()
104 Set<VmsLayer> availableLayersSet = new HashSet<>(); in calculateLayers()
105 Set<VmsLayer> cyclicAvoidanceAuxiliarySet = new HashSet<>(); in calculateLayers()
107 for (VmsLayer layer : mPotentialLayersAndDependencies.keySet()) { in calculateLayers()
123 private void addLayerToAvailabilityCalculationLocked(VmsLayer layer, in addLayerToAvailabilityCalculationLocked()
124 Set<VmsLayer> currentAvailableLayers, in addLayerToAvailabilityCalculationLocked()
125 Set<VmsLayer> cyclicAvoidanceSet) { in addLayerToAvailabilityCalculationLocked()
[all …]
DVmsClientInfo.java21 import android.car.vms.VmsLayer;
56 private final SparseArray<Set<VmsLayer>> mPotentialOfferings = new SparseArray<>();
58 private Set<VmsLayer> mLayerSubscriptions = Collections.emptySet();
60 private Map<VmsLayer, Set<Integer>> mLayerAndProviderSubscriptions = Collections.emptyMap();
137 boolean hasOffering(int providerId, VmsLayer layer) { in hasOffering()
157 Set<VmsLayer> getLayerSubscriptions() { in getLayerSubscriptions()
163 Map<VmsLayer, Set<Integer>> getLayerAndProviderSubscriptions() { in getLayerAndProviderSubscriptions()
175 boolean isSubscribed(int providerId, VmsLayer layer) { in isSubscribed()
219 for (VmsLayer layer : mLayerSubscriptions) { in dump()
222 for (Map.Entry<VmsLayer, Set<Integer>> layerEntry : in dump()
DVmsBrokerService.java27 import android.car.vms.VmsLayer;
211 public void publishPacket(IBinder clientToken, int providerId, VmsLayer layer, byte[] packet) { in publishPacket()
218 public void publishLargePacket(IBinder clientToken, int providerId, VmsLayer layer, in publishLargePacket()
227 private void deliverToSubscribers(IBinder clientToken, int providerId, VmsLayer layer, in deliverToSubscribers()
332 Set<VmsLayer> layerSubscriptions = new ArraySet<>(); in updateSubscriptionState()
333 Map<VmsLayer, Set<Integer>> layerAndProviderSubscriptions = new ArrayMap<>(); in updateSubscriptionState()
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/hal/
DVmsHalServiceTest.java33 import android.car.vms.VmsLayer;
74 private static final VmsLayer LAYER = new VmsLayer(LAYER_TYPE, LAYER_SUBTYPE, LAYER_VERSION);
436 new VmsLayer(4, 5, 6))))); in testHandleOfferingEvent_LayerAndDependency()
464 new VmsLayer(4, 5, 6), in testHandleOfferingEvent_MultipleLayersAndDependencies()
465 new VmsLayer(7, 8, 9) in testHandleOfferingEvent_MultipleLayersAndDependencies()
467 new VmsLayerDependency(new VmsLayer(3, 2, 1), Collections.emptySet()), in testHandleOfferingEvent_MultipleLayersAndDependencies()
468 new VmsLayerDependency(new VmsLayer(6, 5, 4), Collections.singleton( in testHandleOfferingEvent_MultipleLayersAndDependencies()
469 new VmsLayer(7, 8, 9) in testHandleOfferingEvent_MultipleLayersAndDependencies()
547 new VmsAssociatedLayer(new VmsLayer(3, 2, 1), in testHandleAvailabilityRequestEvent_MultipleLayers()
549 new VmsAssociatedLayer(new VmsLayer(6, 5, 4), in testHandleAvailabilityRequestEvent_MultipleLayers()
[all …]
/packages/services/Car/service/src/com/android/car/hal/
DVmsHalService.java26 import android.car.vms.VmsLayer;
126 public void onPacketReceived(int providerId, VmsLayer layer, byte[] packet) {
409 VmsLayer vmsLayer = parseVmsLayerFromMessage(message); in handleDataEvent()
428 VmsLayer vmsLayer = parseVmsLayerFromMessage(message); in handleSubscribeEvent()
444 VmsLayer vmsLayer = parseVmsLayerFromMessage(message); in handleSubscribeToPublisherEvent()
463 VmsLayer vmsLayer = parseVmsLayerFromMessage(message); in handleUnsubscribeEvent()
479 VmsLayer vmsLayer = parseVmsLayerFromMessage(message); in handleUnsubscribeFromPublisherEvent()
580 VmsLayer offeredLayer = parseVmsLayerAtIndex(message, idx); in handleOfferingEvent()
587 Set<VmsLayer> dependencies = new HashSet<>(); in handleOfferingEvent()
590 VmsLayer dependantLayer = parseVmsLayerAtIndex(message, idx); in handleOfferingEvent()
[all …]
/packages/services/Car/service/src/com/android/car/stats/
DVmsClientLogger.java20 import android.car.vms.VmsLayer;
65 private final Map<VmsLayer, VmsClientStats> mLayerStats = new ArrayMap<>();
111 public void logPacketSent(VmsLayer layer, long size) { in logPacketSent()
121 public void logPacketReceived(VmsLayer layer, long size) { in logPacketReceived()
131 public void logPacketDropped(VmsLayer layer, long size) { in logPacketDropped()
143 private VmsClientStats getLayerEntry(VmsLayer layer) { in getLayerEntry()
DVmsClientStats.java19 import android.car.vms.VmsLayer;
58 VmsClientStats(int uid, VmsLayer layer) { in VmsClientStats()
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/vms/
DVmsLayerAvailabilityTest.java20 import android.car.vms.VmsLayer;
34 private static final VmsLayer LAYER_X = new VmsLayer(1, 1, 2);
35 private static final VmsLayer LAYER_Y = new VmsLayer(3, 2, 4);
36 private static final VmsLayer LAYER_Z = new VmsLayer(5, 3, 6);
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/stats/
DCarStatsServiceTest.java22 import android.car.vms.VmsLayer;
50 private static final VmsLayer LAYER = new VmsLayer(1, 2, 3);
51 private static final VmsLayer LAYER2 = new VmsLayer(2, 3, 4);
52 private static final VmsLayer LAYER3 = new VmsLayer(3, 4, 5);
/packages/services/Car/tests/carservice_unit_test/src/android/car/vms/
DVmsSubscriptionHelperTest.java38 private static final VmsLayer LAYER1 = new VmsLayer(1, 1, 1);
39 private static final VmsLayer LAYER2 = new VmsLayer(2, 1, 1);
40 private static final VmsLayer LAYER3 = new VmsLayer(3, 1, 1);

12