Home
last modified time | relevance | path

Searched refs:subscription (Results 1 – 25 of 105) sorted by relevance

12345

/frameworks/native/libs/bufferstreams/rust/src/subscribers/
Dtesting.rs35 subscription: Option<Box<dyn BufferSubscription>>, field
42 Self { config, subscription: None, events: Vec::new() } in new()
47 self.subscription.is_some() in has_subscription()
54 let subscription = self in request() localVariable
55 .subscription in request()
58 subscription.request(n); in request()
67 let subscription = self in cancel() localVariable
68 .subscription in cancel()
71 subscription.cancel(); in cancel()
88 fn on_subscribe(&mut self, subscription: Box<dyn BufferSubscription>) { in on_subscribe()
[all …]
Dshared.rs69 fn on_subscribe(&mut self, subscription: Box<dyn BufferSubscription>) { in on_subscribe()
77 inner.subscriber.on_subscribe(subscription); in on_subscribe()
/frameworks/native/libs/bufferstreams/rust/src/publishers/
Dtesting.rs25 subscription: SharedBufferSubscription, field
31 Self { config, subscriber: None, subscription: SharedBufferSubscription::new() } in new()
44 if self.subscription.take_request() { in send_frame()
81 self.subscription.pending_requests() in pending_requests()
86 self.subscription.is_cancelled() in is_cancelled()
100 subscriber.on_subscribe(self.subscription.clone_for_subscriber()); in subscribe()
Dbuffer_pool_publisher.rs24 subscription: SharedBufferSubscription, field
35 subscription: SharedBufferSubscription::new(), in new()
44 if self.subscription.take_request() { in send_next_frame()
66 self.subscriber.as_mut().unwrap().on_subscribe(self.subscription.clone_for_subscriber()); in subscribe()
106 assert_eq!(buffer_pool_publisher.subscription.pending_requests(), 0); in test_send_next_frame()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/controls/controller/
DStatefulControlSubscriberTest.kt46 private lateinit var subscription: IControlsSubscription variable in com.android.systemui.controls.controller.StatefulControlSubscriberTest
75 scs.onSubscribe(token, subscription) in testOnSubscribe()
78 verify(provider).startSubscription(subscription, REQUEST_LIMIT) in testOnSubscribe()
83 scs.onSubscribe(badToken, subscription) in testOnSubscribe_badToken()
86 verify(provider, never()).startSubscription(subscription, REQUEST_LIMIT) in testOnSubscribe_badToken()
91 scs.onSubscribe(token, subscription) in testOnNext()
100 scs.onSubscribe(token, subscription) in testOnNext_multiple()
119 scs.onSubscribe(token, subscription) in testOnNext_noRefreshAfterCancel()
131 scs.onSubscribe(token, subscription) in testOnNext_noRefreshAfterError()
141 scs.onSubscribe(token, subscription) in testOnNext_noRefreshAfterComplete()
DControlsBindingControllerImplTest.kt120 val subscription = mock(IControlsSubscription::class.java) in testBindAndLoad_cancel() constant
125 loadSubscriberCaptor.value.onSubscribe(Binder(), subscription) in testBindAndLoad_cancel()
128 verify(providers[0]).cancelSubscription(subscription) in testBindAndLoad_cancel()
139 val subscription = mock(IControlsSubscription::class.java) in testBindAndLoad_noCancelAfterOnComplete() constant
145 loadSubscriberCaptor.value.onSubscribe(b, subscription) in testBindAndLoad_noCancelAfterOnComplete()
149 verify(providers[0], never()).cancelSubscription(subscription) in testBindAndLoad_noCancelAfterOnComplete()
159 val subscription = mock(IControlsSubscription::class.java) in testLoad_onCompleteRemovesTimeout() constant
165 subscriberCaptor.value.onSubscribe(b, subscription) in testLoad_onCompleteRemovesTimeout()
178 val subscription = mock(IControlsSubscription::class.java) in testLoad_onErrorRemovesTimeout() constant
184 subscriberCaptor.value.onSubscribe(b, subscription) in testLoad_onErrorRemovesTimeout()
[all …]
DServiceWrapperTest.kt52 private lateinit var subscription: IControlsSubscription variable in com.android.systemui.controls.controller.ServiceWrapperTest
131 val result = wrapper.cancel(subscription) in testCancel_happyPath()
134 verify(subscription).cancel() in testCancel_happyPath()
139 `when`(subscription.cancel()).thenThrow(exception) in testCancel_error()
140 val result = wrapper.cancel(subscription) in testCancel_error()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/util/condition/
DConditionalCoreStartableTest.java117 final Monitor.Subscription subscription = subscriptionCaptor.getValue(); in testOnStartCallback() local
119 assertThat(subscription.getConditions()).containsExactly(mCondition); in testOnStartCallback()
123 subscription.getCallback().onConditionsChanged(true); in testOnStartCallback()
142 final Monitor.Subscription subscription = subscriptionCaptor.getValue(); in testOnStartCallbackWithNoConditions() local
144 assertThat(subscription.getConditions()).isEmpty(); in testOnStartCallbackWithNoConditions()
148 subscription.getCallback().onConditionsChanged(true); in testOnStartCallbackWithNoConditions()
173 final Monitor.Subscription subscription = subscriptionCaptor.getValue(); in testBootCompleted() local
175 assertThat(subscription.getConditions()).containsExactly(mCondition); in testBootCompleted()
179 subscription.getCallback().onConditionsChanged(true); in testBootCompleted()
/frameworks/base/packages/SystemUI/src/com/android/systemui/controls/controller/
DServiceWrapper.kt65 fun request(subscription: IControlsSubscription, num: Long): Boolean { in request()
67 subscription.request(num) in request()
71 fun cancel(subscription: IControlsSubscription): Boolean { in cancel()
73 subscription.cancel() in cancel()
DStatefulControlSubscriber.kt38 private var subscription: IControlsSubscription? = null variable in com.android.systemui.controls.controller.StatefulControlSubscriber
53 subscription = subs in onSubscribe()
90 subscription?.let { in cancel()
93 subscription = null in cancel()
DControlsBindingControllerImpl.kt251 val subscription: IControlsSubscription, constant
256 provider?.cancelSubscription(subscription) in doRun()
263 val subscription: IControlsSubscription, constant
268 provider?.startSubscription(subscription, requestLimit) in doRun()
304 private lateinit var subscription: IControlsSubscription variable in LoadSubscriber
319 subscription = subs in onSubscribe()
320 _loadCancelInternal = { currentProvider?.cancelSubscription(subscription) } in onSubscribe()
335 OnCancelAndLoadRunnable(token, loadedControls, subscription, callback) in onNext()
DControlsProviderLifecycleManager.kt299 fun startSubscription(subscription: IControlsSubscription, requestLimit: Long) { in maybeBindAndSubscribe()
301 Log.d(TAG, "startSubscription: $subscription") in maybeBindAndSubscribe()
304 wrapper?.request(subscription, requestLimit) in maybeBindAndSubscribe()
313 fun cancelSubscription(subscription: IControlsSubscription) { in cancelSubscription()
315 Log.d(TAG, "cancelSubscription: $subscription") in cancelSubscription()
318 wrapper?.cancel(subscription) in cancelSubscription()
/frameworks/opt/telephony/src/java/com/android/internal/telephony/euicc/
DEuiccOperation.java117 DownloadableSubscription subscription, String callingPackage) { in forGetMetadataDeactivateSim() argument
119 subscription, 0 /* subscriptionId */, false /* switchAfterDownload */, in forGetMetadataDeactivateSim()
129 DownloadableSubscription subscription, boolean switchAfterDownload, in forDownloadDeactivateSim() argument
132 subscription, 0 /* subscriptionId */, switchAfterDownload, callingPackage); in forDownloadDeactivateSim()
140 DownloadableSubscription subscription, boolean switchAfterDownload, in forDownloadNoPrivileges() argument
143 subscription, 0 /* subscriptionId */, switchAfterDownload, callingPackage); in forDownloadNoPrivileges()
151 DownloadableSubscription subscription, boolean switchAfterDownload, in forDownloadNoPrivilegesOrDeactivateSimCheckMetadata() argument
154 callingToken, subscription, 0 /* subscriptionId */, in forDownloadNoPrivilegesOrDeactivateSimCheckMetadata()
168 DownloadableSubscription subscription, boolean switchAfterDownload, in forDownloadConfirmationCode() argument
171 subscription, 0 /* subscriptionId */, switchAfterDownload, callingPackage); in forDownloadConfirmationCode()
[all …]
DEuiccController.java74 import com.android.internal.telephony.subscription.SubscriptionManagerService;
348 DownloadableSubscription subscription, String callingPackage, in getDownloadableSubscriptionMetadata() argument
351 subscription, false /* forceDeactivateSim */, callingPackage, callbackIntent); in getDownloadableSubscriptionMetadata()
449 void getDownloadableSubscriptionMetadata(int cardId, DownloadableSubscription subscription, in getDownloadableSubscriptionMetadata() argument
459 TelephonyManager.DEFAULT_PORT_INDEX, subscription, in getDownloadableSubscriptionMetadata()
462 token, subscription, callingPackage, callbackIntent)); in getDownloadableSubscriptionMetadata()
476 DownloadableSubscription subscription, in GetMetadataCommandCallback() argument
480 mSubscription = subscription; in GetMetadataCommandCallback()
529 public void downloadSubscription(int cardId, DownloadableSubscription subscription, in downloadSubscription() argument
536 downloadSubscription(cardId, portIndex, subscription, in downloadSubscription()
[all …]
/frameworks/base/telephony/java/android/service/euicc/
DEuiccService.java507 int slotId, DownloadableSubscription subscription, boolean forceDeactivateSim); in onGetDownloadableSubscriptionMetadata() argument
524 int slotId, int portIndex, @NonNull DownloadableSubscription subscription, in onGetDownloadableSubscriptionMetadata() argument
570 @NonNull DownloadableSubscription subscription, boolean switchAfterDownload, in onDownloadSubscription() argument
600 @NonNull DownloadableSubscription subscription, boolean switchAfterDownload, in onDownloadSubscription() argument
625 @NonNull DownloadableSubscription subscription, boolean switchAfterDownload, in onDownloadSubscription() argument
810 DownloadableSubscription subscription, in downloadSubscription() argument
819 slotId, portIndex, subscription, switchAfterDownload, in downloadSubscription()
826 slotId, subscription, switchAfterDownload, in downloadSubscription()
918 DownloadableSubscription subscription, in getDownloadableSubscriptionMetadata() argument
928 slotId, portIndex, subscription, forceDeactivateSim); in getDownloadableSubscriptionMetadata()
[all …]
DGetDownloadableSubscriptionMetadataResult.java87 @Nullable DownloadableSubscription subscription) { in GetDownloadableSubscriptionMetadataResult() argument
90 this.mSubscription = subscription; in GetDownloadableSubscriptionMetadataResult()
92 if (subscription != null) { in GetDownloadableSubscriptionMetadataResult()
DIEuiccService.aidl39 void downloadSubscription(int slotId, int portIndex, in DownloadableSubscription subscription, in downloadSubscription() argument
43 int slotId, int portIndex, in DownloadableSubscription subscription, in getDownloadableSubscriptionMetadata() argument
/frameworks/base/packages/SystemUI/shared/src/com/android/systemui/shared/condition/
DMonitor.java59 SubscriptionState(Subscription subscription) { in SubscriptionState() argument
60 mSubscription = subscription; in SubscriptionState()
199 public Subscription.Token addSubscription(@NonNull Subscription subscription) { in addSubscription() argument
200 return addSubscription(subscription, mPreconditions); in addSubscription()
203 private Subscription.Token addSubscription(@NonNull Subscription subscription, in addSubscription() argument
207 ? new Subscription.Builder(subscription).addConditions(preconditions).build() in addSubscription()
208 : subscription; in addSubscription()
/frameworks/base/packages/SystemUI/tests/utils/src/com/android/systemui/condition/
DSelfExecutingMonitor.java41 public Subscription.Token addSubscription(@NonNull Subscription subscription) { in addSubscription() argument
42 final Subscription.Token result = super.addSubscription(subscription); in addSubscription()
/frameworks/opt/telephony/proto/src/
DcarrierId.proto63 // [Optional] The Service Provider Name. Read from subscription EF_SPN.
67 // [Optional] PLMN network name. Read from subscription EF_PNN.
71 // [Optional] Group Identifier Level1 for a GSM phone. Read from subscription EF_GID1.
75 // [Optional] Group Identifier Level2 for a GSM phone. Read from subscription EF_GID2.
84 // [Optional] Prefix of Integrated Circuit Card Identifier. Read from subscription EF_ICCID.
/frameworks/base/telephony/java/com/android/internal/telephony/euicc/
DIEuiccController.aidl32 in DownloadableSubscription subscription, in getDownloadableSubscriptionMetadata() argument
38 oneway void downloadSubscription(int cardId, in DownloadableSubscription subscription, in downloadSubscription() argument
/frameworks/opt/telephony/flags/
Dsubscription.aconfig27 description: "Supports customized cellular service capabilities per subscription."
53 description: "Supports querying if a subscription is associated with the caller"
/frameworks/native/libs/bufferstreams/aidl/android/graphics/bufferstreams/
DIBufferSubscriber.aidl28 oneway void onSubscribe(in IBufferSubscription subscription); in onSubscribe() argument
/frameworks/base/services/foldables/devicestateprovider/src/com/android/server/policy/
DBookStyleClosedStatePredicate.java422 final SensorSubscription subscription = mSensorSubscriptions.get(i); in updateListeningState() local
423 final Sensor sensor = subscription.mSensor; in updateListeningState()
425 final boolean shouldBeListening = subscription.mAllowedToListenSupplier.get(); in updateListeningState()
437 subscription.mOnUnsubscribe.run(); in updateListeningState()
/frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/subscription/
DSubscriptionManagerServiceTest.java17 package com.android.internal.telephony.subscription;
19 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_CARR…
20 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_CARR…
21 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_CARR…
22 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_CARR…
23 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_CONT…
24 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_CONT…
25 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_COUN…
26 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_DEFA…
27 import static com.android.internal.telephony.subscription.SubscriptionDatabaseManagerTest.FAKE_EHPL…
[all …]

12345