| /frameworks/base/packages/SystemUI/src/com/android/systemui/controls/controller/ |
| D | ControlsProviderLifecycleManager.kt | 181 fun maybeBindAndLoad(subscriber: IControlsSubscriber.Stub) { in maybeBindAndLoad()
185 subscriber.onError(token, "Timeout waiting onLoad") in maybeBindAndLoad()
189 invokeOrQueue(Load(subscriber)) in maybeBindAndLoad()
200 fun maybeBindAndLoadSuggested(subscriber: IControlsSubscriber.Stub) { in maybeBindAndLoadSuggested()
204 subscriber.onError(token, "Timeout waiting onLoadSuggested") in maybeBindAndLoadSuggested()
208 invokeOrQueue(Suggest(subscriber)) in maybeBindAndLoadSuggested()
223 fun maybeBindAndSubscribe(controlIds: List<String>, subscriber: IControlsSubscriber) = in maybeBindAndSubscribe()
224 invokeOrQueue(Subscribe(controlIds, subscriber)) in maybeBindAndSubscribe()
304 inner class Load(val subscriber: IControlsSubscriber.Stub) : ServiceMethod() { in callWrapper() constant in com.android.systemui.controls.controller.ControlsProviderLifecycleManager.Load
309 return wrapper?.load(subscriber) ?: false in callWrapper()
[all …]
|
| D | ServiceWrapper.kt | 47 fun load(subscriber: IControlsSubscriber): Boolean { in load()
49 service.load(subscriber) in load()
53 fun loadSuggested(subscriber: IControlsSubscriber): Boolean { in loadSuggested()
55 service.loadSuggested(subscriber) in loadSuggested()
59 fun subscribe(controlIds: List<String>, subscriber: IControlsSubscriber): Boolean { in subscribe()
61 service.subscribe(controlIds, subscriber) in subscribe()
|
| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/controls/controller/ |
| D | ServiceWrapperTest.kt | 55 private lateinit var subscriber: IControlsSubscriber variable in com.android.systemui.controls.controller.ServiceWrapperTest
80 val result = wrapper.load(subscriber) in testLoad_happyPath()
83 verify(service).load(subscriber) in testLoad_happyPath()
89 val result = wrapper.load(subscriber) in testLoad_error()
96 val result = wrapper.loadSuggested(subscriber) in testLoadSuggested_happyPath()
99 verify(service).loadSuggested(subscriber) in testLoadSuggested_happyPath()
105 val result = wrapper.loadSuggested(subscriber) in testLoadSuggested_error()
113 val result = wrapper.subscribe(list, subscriber) in testSubscribe_happyPath()
116 verify(service).subscribe(list, subscriber) in testSubscribe_happyPath()
124 val result = wrapper.subscribe(list, subscriber) in testSubscribe_error()
|
| /frameworks/base/core/java/android/service/controls/ |
| D | IControlsProvider.aidl | 27 void load(IControlsSubscriber subscriber); in load() argument
29 void loadSuggested(IControlsSubscriber subscriber); in loadSuggested() argument
32 IControlsSubscriber subscriber); in subscribe() argument
|
| D | ControlsProviderService.java | 143 public void load(IControlsSubscriber subscriber) { in onBind()
144 mHandler.obtainMessage(RequestHandler.MSG_LOAD, subscriber).sendToTarget(); in onBind()
147 public void loadSuggested(IControlsSubscriber subscriber) { in onBind() argument
148 mHandler.obtainMessage(RequestHandler.MSG_LOAD_SUGGESTED, subscriber) in onBind()
153 IControlsSubscriber subscriber) { in onBind() argument
154 SubscribeMessage msg = new SubscribeMessage(controlIds, subscriber); in onBind()
369 SubscribeMessage(List<String> controlIds, IControlsSubscriber subscriber) {
371 this.mSubscriber = subscriber;
|
| /frameworks/base/packages/EasterEgg/src/com/android/egg/neko/ |
| D | NekoControlsService.kt | 273 var subscriber: Flow.Subscriber<in Control>? variable in com.android.egg.neko.NekoControlsService.UglyPublisher.UglySubscription
276 Log.v(TAG, "cancel subscription: $this for subscriber: $subscriber " + in cancel()
278 subscriber = null in cancel()
287 if (!indefinite) subscriber?.onComplete() in request()
293 Log.v(TAG, "sending update: " + Control_toString(c) + " => " + subscriber) in send()
294 subscriber?.onNext(c) in send()
298 override fun subscribe(subscriber: Flow.Subscriber<in Control>) { in subscribe()
299 Log.v(TAG, "subscribe to publisher: $this by subscriber: $subscriber") in subscribe()
301 subscriber) in subscribe()
303 subscriber.onSubscribe(sub) in subscribe()
|
| /frameworks/av/services/mediaresourcemanager/ |
| D | ResourceObserverService.cpp | 299 for (auto &subscriber : observableIt->second) { in notifyObservers() local
300 auto calleeIt = calleeList.find(subscriber.first); in notifyObservers()
302 calleeList.emplace(subscriber.first, CalleeInfo{ in notifyObservers()
303 subscriber.second, {{observableType, res.second.value}}}); in notifyObservers()
|
| /frameworks/base/core/java/android/net/ |
| D | INetworkPolicyManager.aidl | 77 void factoryReset(String subscriber); in factoryReset() argument
|
| D | NetworkPolicyManager.java | 542 public void factoryReset(String subscriber) { in factoryReset() argument
544 mService.factoryReset(subscriber); in factoryReset()
|
| /frameworks/base/core/proto/android/service/ |
| D | netstats.proto | 70 // Full subscriber ID on eng builds. The IMSI is scrubbed on user & userdebug
72 // that uniquely identifies the subscriber is removed).
|
| /frameworks/base/services/core/java/com/android/server/net/ |
| D | NetworkPolicyManagerService.java | 5616 public void factoryReset(String subscriber) {
5625 NetworkTemplate templateCarrier = subscriber != null
5626 ? buildTemplateCarrierMetered(subscriber) : null;
5627 NetworkTemplate templateMobile = buildTemplateMobileAll(subscriber);
|
| /frameworks/proto_logging/stats/ |
| D | atoms.proto | 11732 * This event is intended to be consumed by a Perfetto subscriber for
|