| /aosp12/packages/services/Car/tests/carservice_test/src/com/android/car/ |
| H A D | VmsPublisherSubscriberTest.java | 65 private VmsSubscriberManager mSubscriber; field in VmsPublisherSubscriberTest
71 mSubscriber = getSubscriberManager(); in setUpClients()
199 mSubscriber.startMonitoring(); in testStartMonitoring()
212 mSubscriber.startMonitoring(); in testStartMonitoring_AfterPublish()
218 mSubscriber.startMonitoring(); in testStartMonitoring_MultipleLayers()
230 mSubscriber.startMonitoring(); in testStartMonitoring_MultiplePublishers()
243 mSubscriber.startMonitoring(); in testStopMonitoring()
244 mSubscriber.stopMonitoring(); in testStopMonitoring()
255 mSubscriber.subscribe(SUBSCRIPTION_LAYER); in testSubscribe()
268 mSubscriber.subscribe(SUBSCRIPTION_LAYER); in testSubscribe_AfterPublish()
[all …]
|
| /aosp12/packages/services/Car/service/src/com/android/car/telemetry/databroker/ |
| H A D | DataSubscriber.java | 34 private final TelemetryProto.Subscriber mSubscriber; field in DataSubscriber
42 mSubscriber = subscriber; in DataSubscriber()
47 return mSubscriber.getHandler(); in getHandlerName()
55 return mSubscriber.getPublisher(); in getPublisherParam()
83 return mSubscriber; in getSubscriber()
88 return mSubscriber.getPriority(); in getPriority()
99 && mSubscriber.getHandler().equals(other.getSubscriber().getHandler()); in equals()
105 mSubscriber.getHandler()); in hashCode()
|
| H A D | ScriptExecutionTask.java | 33 private final DataSubscriber mSubscriber; field in ScriptExecutionTask
40 mSubscriber = subscriber; in ScriptExecutionTask()
47 return mSubscriber.getPriority(); in getPriority()
56 return mSubscriber.getMetricsConfig(); in getMetricsConfig()
60 return mSubscriber.getHandlerName(); in getHandlerName()
71 return mSubscriber.getMetricsConfig().getName().equals(key.getName()) in isAssociatedWithMetricsConfig()
72 && mSubscriber.getMetricsConfig().getVersion() == key.getVersion(); in isAssociatedWithMetricsConfig()
|
| /aosp12/frameworks/base/core/tests/coretests/src/android/service/controls/ |
| H A D | ControlProviderServiceTest.java | 80 private IControlsSubscriber.Stub mSubscriber; field in ControlProviderServiceTest
101 when(mSubscriber.asBinder()).thenCallRealMethod(); in setUp()
102 when(mSubscriber.queryLocalInterface(any())).thenReturn(mSubscriber); in setUp()
137 mControlsProvider.load(mSubscriber); in testOnLoad_allStateless()
143 verify(mSubscriber, times(2)) in testOnLoad_allStateless()
149 verify(mSubscriber).onComplete(eq(mToken)); in testOnLoad_allStateless()
169 mControlsProvider.load(mSubscriber); in testOnLoad_statefulConvertedToStateless()
175 verify(mSubscriber).onNext(eq(mToken), controlCaptor.capture()); in testOnLoad_statefulConvertedToStateless()
181 verify(mSubscriber).onComplete(eq(mToken)); in testOnLoad_statefulConvertedToStateless()
200 mControlsProvider.loadSuggested(mSubscriber); in testOnLoadSuggested_allStateless()
[all …]
|
| /aosp12/frameworks/base/core/java/android/service/controls/ |
| H A D | ControlsProviderService.java | 210 ControlsProviderService.this, false, mToken, sMsg.mSubscriber);
367 final IControlsSubscriber mSubscriber;
371 this.mSubscriber = subscriber;
|
| /aosp12/hardware/qcom/gps/msm8960/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 949 const BITSubscriber mSubscriber; member
953 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
959 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
960 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
964 (unsigned char)(mSubscriber.ID>>24), in locallog()
965 (unsigned char)(mSubscriber.ID>>16), in locallog()
966 (unsigned char)(mSubscriber.ID>>8), in locallog()
967 (unsigned char)mSubscriber.ID, in locallog()
968 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/sdm845/gps/msm8960/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 949 const BITSubscriber mSubscriber; member
953 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
959 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
960 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
964 (unsigned char)(mSubscriber.ID>>24), in locallog()
965 (unsigned char)(mSubscriber.ID>>16), in locallog()
966 (unsigned char)(mSubscriber.ID>>8), in locallog()
967 (unsigned char)mSubscriber.ID, in locallog()
968 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/packages/modules/StatsD/statsd/src/packages/ |
| H A D | UidMap.cpp | 149 broadcast = mSubscriber; in updateMap()
191 broadcast = mSubscriber; in updateApp()
252 broadcast = mSubscriber; in removeApp()
263 mSubscriber = listener; in setListener()
|
| H A D | UidMap.h | 193 wp<PackageInfoListener> mSubscriber; variable
|
| /aosp12/hardware/qcom/gps/msm8994/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1020 const BITSubscriber mSubscriber; member
1024 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1030 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1031 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1035 (unsigned char)(mSubscriber.ID>>24), in locallog()
1036 (unsigned char)(mSubscriber.ID>>16), in locallog()
1037 (unsigned char)(mSubscriber.ID>>8), in locallog()
1038 (unsigned char)mSubscriber.ID, in locallog()
1039 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/gps/msm8996/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1017 const BITSubscriber mSubscriber; member
1021 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1027 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1028 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1032 (unsigned char)(mSubscriber.ID>>24), in locallog()
1033 (unsigned char)(mSubscriber.ID>>16), in locallog()
1034 (unsigned char)(mSubscriber.ID>>8), in locallog()
1035 (unsigned char)mSubscriber.ID, in locallog()
1036 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/gps/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1019 const BITSubscriber mSubscriber; member
1023 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1029 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1030 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1034 (unsigned char)(mSubscriber.ID>>24), in locallog()
1035 (unsigned char)(mSubscriber.ID>>16), in locallog()
1036 (unsigned char)(mSubscriber.ID>>8), in locallog()
1037 (unsigned char)mSubscriber.ID, in locallog()
1038 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/gps/msm8084/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1040 const BITSubscriber mSubscriber; member
1044 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1050 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1051 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1055 (unsigned char)(mSubscriber.ID>>24), in locallog()
1056 (unsigned char)(mSubscriber.ID>>16), in locallog()
1057 (unsigned char)(mSubscriber.ID>>8), in locallog()
1058 (unsigned char)mSubscriber.ID, in locallog()
1059 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/gps/msm8909/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1018 const BITSubscriber mSubscriber; member
1022 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1028 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1029 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1033 (unsigned char)(mSubscriber.ID>>24), in locallog()
1034 (unsigned char)(mSubscriber.ID>>16), in locallog()
1035 (unsigned char)(mSubscriber.ID>>8), in locallog()
1036 (unsigned char)mSubscriber.ID, in locallog()
1037 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/sdm845/gps/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1019 const BITSubscriber mSubscriber; member
1023 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1029 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1030 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1034 (unsigned char)(mSubscriber.ID>>24), in locallog()
1035 (unsigned char)(mSubscriber.ID>>16), in locallog()
1036 (unsigned char)(mSubscriber.ID>>8), in locallog()
1037 (unsigned char)mSubscriber.ID, in locallog()
1038 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/sdm845/gps/msm8084/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1040 const BITSubscriber mSubscriber; member
1044 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1050 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1051 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1055 (unsigned char)(mSubscriber.ID>>24), in locallog()
1056 (unsigned char)(mSubscriber.ID>>16), in locallog()
1057 (unsigned char)(mSubscriber.ID>>8), in locallog()
1058 (unsigned char)mSubscriber.ID, in locallog()
1059 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/sdm845/gps/msm8909/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1018 const BITSubscriber mSubscriber; member
1022 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1028 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1029 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1033 (unsigned char)(mSubscriber.ID>>24), in locallog()
1034 (unsigned char)(mSubscriber.ID>>16), in locallog()
1035 (unsigned char)(mSubscriber.ID>>8), in locallog()
1036 (unsigned char)mSubscriber.ID, in locallog()
1037 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/sdm845/gps/msm8994/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1020 const BITSubscriber mSubscriber; member
1024 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1030 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1031 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1035 (unsigned char)(mSubscriber.ID>>24), in locallog()
1036 (unsigned char)(mSubscriber.ID>>16), in locallog()
1037 (unsigned char)(mSubscriber.ID>>8), in locallog()
1038 (unsigned char)mSubscriber.ID, in locallog()
1039 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|
| /aosp12/hardware/qcom/sdm845/gps/msm8996/loc_api/libloc_api_50001/ |
| H A D | loc_eng.cpp | 1017 const BITSubscriber mSubscriber; member
1021 mSubscriber(stateMachine, ipv4, ipv6) in LocEngReleaseBIT()
1027 AgpsStateMachine* sm = (AgpsStateMachine*)mSubscriber.mStateMachine; in proc()
1028 sm->unsubscribeRsrc((Subscriber*)&mSubscriber); in proc()
1032 (unsigned char)(mSubscriber.ID>>24), in locallog()
1033 (unsigned char)(mSubscriber.ID>>16), in locallog()
1034 (unsigned char)(mSubscriber.ID>>8), in locallog()
1035 (unsigned char)mSubscriber.ID, in locallog()
1036 NULL != mSubscriber.mIPv6Addr ? mSubscriber.mIPv6Addr : ""); in locallog()
|