Home
last modified time | relevance | path

Searched refs:mBrokerService (Results 1 – 6 of 6) sorted by relevance

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/
DVmsSubscriberServiceTest.java61 private VmsBrokerService mBrokerService; field in VmsSubscriberServiceTest
76 mSubscriberService = new VmsSubscriberService(mContext, mBrokerService, mClientManager, in setUp()
78 verify(mBrokerService).addSubscriberListener(eq(mSubscriberService)); in setUp()
84 verifyNoMoreInteractions(mBrokerService, mClientManager); in tearDown()
103 verify(mBrokerService).addSubscription(mSubscriberClient, LAYER); in testAddVmsSubscriber()
109 verify(mBrokerService).removeSubscription(mSubscriberClient, LAYER); in testRemoveVmsSubscriber()
117 verify(mBrokerService).addSubscription(mSubscriberClient, LAYER, PUBLISHER_ID); in testAddVmsSubscriberToPublisher()
125 verify(mBrokerService).removeSubscription(mSubscriberClient, LAYER, PUBLISHER_ID); in testRemoveVmsSubscriberToPublisher()
132 verify(mBrokerService).addSubscription(mSubscriberClient); in testAddVmsSubscriberPassive()
138 verify(mBrokerService).removeSubscription(mSubscriberClient); in testRemoveVmsSubscriberPassive()
[all …]
DVmsPublisherServiceTest.java88 private VmsBrokerService mBrokerService; field in VmsPublisherServiceTest
114 mPublisherService = new VmsPublisherService(mContext, mStatsService, mBrokerService, in setUp()
128 when(mBrokerService.getSubscribersForLayerFromPublisher(LAYER, PUBLISHER_ID)) in setUp()
146 verify(mBrokerService, times(2)).addPublisherListener(mProxyCaptor.capture()); in testOnClientConnected()
160 verify(mBrokerService, times(2)).addPublisherListener(mProxyCaptor.capture()); in testOnClientDisconnected()
162 reset(mClientManager, mBrokerService); in testOnClientDisconnected()
165 verify(mBrokerService).removeDeadPublisher(mPublisherClient.mToken); in testOnClientDisconnected()
166 verify(mBrokerService).removePublisherListener(mProxyCaptor.getAllValues().get(0)); in testOnClientDisconnected()
167 verifyNoMoreInteractions(mBrokerService); in testOnClientDisconnected()
175 verify(mBrokerService).setPublisherLayersOffering(mPublisherClient.mToken, OFFERING); in testSetLayersOffering()
[all …]
/packages/services/Car/service/src/com/android/car/
DVmsSubscriberService.java41 private final VmsBrokerService mBrokerService; field in VmsSubscriberService
55 mBrokerService = brokerService; in VmsSubscriberService()
57 mBrokerService.addSubscriberListener(this); in VmsSubscriberService()
87 mBrokerService.addSubscription(subscriber, layer); in addVmsSubscriber()
93 mBrokerService.removeSubscription(subscriber, layer); in removeVmsSubscriber()
102 mBrokerService.addSubscription(subscriber, layer, publisherId); in addVmsSubscriberToPublisher()
110 mBrokerService.removeSubscription(subscriber, layer, publisherId); in removeVmsSubscriberToPublisher()
117 mBrokerService.addSubscription(subscriber); in addVmsSubscriberPassive()
123 mBrokerService.removeSubscription(subscriber); in removeVmsSubscriberPassive()
129 return mBrokerService.getPublisherInfo(publisherId); in getPublisherInfo()
[all …]
DVmsPublisherService.java55 private final VmsBrokerService mBrokerService; field in VmsPublisherService
78 mBrokerService = brokerService; in VmsPublisherService()
156 mBrokerService.addPublisherListener(this); in register()
162 mBrokerService.removePublisherListener(this); in unregister()
163 mBrokerService.removeDeadPublisher(mToken); in unregister()
169 mBrokerService.setPublisherLayersOffering(token, offering); in setLayersOffering()
189 mBrokerService.getSubscribersForLayerFromPublisher(layer, publisherId); in publish()
217 return mBrokerService.getSubscriptionState(); in getSubscriptions()
223 return mBrokerService.getPublisherId(publisherInfo); in getPublisherId()
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/vms/
DVmsClientManagerTest.java123 private VmsBrokerService mBrokerService; field in VmsClientManagerTest
205 mBrokerService, mHal, mHandler, () -> mCallingAppUid); in setUp()
223 verifyNoMoreInteractions(mContext, mBrokerService, mHal, mPublisherService, mHandler); in tearDown()
894 verify(mBrokerService).removeDeadSubscriber(mSubscriberClient1); in testRemoveSubscriber()
913 verify(mBrokerService).removeDeadSubscriber(mSubscriberClient1); in testRemoveSubscriber_OnDeath()
923 verify(mBrokerService).removeDeadSubscriber(mSubscriberClient1); in testOnUserSwitch_RemoveSubscriber()
934 verify(mBrokerService).removeDeadSubscriber(mSubscriberClient1); in testOnUserSwitch_RemoveSubscriber_AddNewSubscriber()
959 verify(mBrokerService).removeDeadSubscriber(mSubscriberClient1); in testOnUserSwitch_RemoveSubscriber_RetainSystemClient()
960 verify(mBrokerService, never()).removeDeadSubscriber(mSubscriberClient2); in testOnUserSwitch_RemoveSubscriber_RetainSystemClient()
975 verify(mBrokerService, never()).removeDeadSubscriber(subscriberClient); in testOnUserSwitch_RemoveSubscriber_RetainHalClient()
[all …]
/packages/services/Car/service/src/com/android/car/vms/
DVmsClientManager.java82 private final VmsBrokerService mBrokerService; field in VmsClientManager
161 mBrokerService = brokerService; in VmsClientManager()
603 mBrokerService.removeDeadSubscriber(mClient); in terminate()