| /aosp_15_r20/external/tensorflow/tensorflow/python/framework/ |
| H A D | subscribe_test.py | 87 subscribed = subscribe.subscribe(
89 self.assertIsInstance(subscribed, tuple)
90 self._ExpectSubscribedIdentities(subscribed)
93 subscribed = subscribe.subscribe(
95 self.assertIsInstance(subscribed, list)
96 self._ExpectSubscribedIdentities(subscribed)
99 subscribed = subscribe.subscribe({
103 self.assertIsInstance(subscribed, dict)
104 self._ExpectSubscribedIdentities(subscribed.values())
111 subscribed = subscribe.subscribe(
[all …]
|
| /aosp_15_r20/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| H A D | SelfPubSubTest.java | 66 …CompletableFuture<Integer> subscribed = connection.subscribe(TEST_TOPIC, QualityOfService.AT_LEAST… in testPubSub() local
68 subscribed.thenApply(unused -> subsAcked++); in testPubSub()
69 int packetId = subscribed.get(); in testPubSub()
144 …CompletableFuture<Integer> subscribed = connection.subscribe(TEST_TOPIC, QualityOfService.AT_LEAST… in testPubSubOnMessage() local
145 subscribed.thenApply(unused -> subsAcked++); in testPubSubOnMessage()
146 int packetId = subscribed.get(); in testPubSubOnMessage()
|
| H A D | SubscribeTest.java | 56 …CompletableFuture<Integer> subscribed = connection.subscribe(TEST_TOPIC, QualityOfService.AT_LEAST… in testSubscribeUnsubscribe() local
58 subscribed.thenAccept(packetId -> subsAcked++); in testSubscribeUnsubscribe()
59 subscribed.get(); in testSubscribeUnsubscribe()
|
| H A D | IotServiceTest.java | 52 …CompletableFuture<Integer> subscribed = connection.subscribe(TEST_TOPIC, QualityOfService.AT_LEAST… in testIotService() local
53 subscribed.thenApply(packetId -> subsAcked++); in testIotService()
54 subscribed.get(); in testIotService()
|
| H A D | Mqtt5to3AdapterConnectionTest.java | 703 …CompletableFuture<Integer> subscribed = connection.subscribe(testTopic, QualityOfService.AT_LEAST_… in TestOperationSubUnsub() local
705 subscribed.thenApply(unused -> subsAcked++); in TestOperationSubUnsub()
706 int packetId = subscribed.get(); in TestOperationSubUnsub()
800 …CompletableFuture<Integer> subscribed = connection.subscribe(testTopic, QualityOfService.AT_LEAST_… in TestAnauthorizedSub() local
802 subscribed.thenApply(unused -> subsAcked++); in TestAnauthorizedSub()
805 int packetId = subscribed.get(); in TestAnauthorizedSub()
998 CompletableFuture<Integer> subscribed = connection1.subscribe(testTopic1, in TestMultipleAdapter() local
1001 int packetId = subscribed.get(); in TestMultipleAdapter()
1004 subscribed = connection2.subscribe(testTopic2, QualityOfService.AT_LEAST_ONCE, in TestMultipleAdapter()
1006 packetId = subscribed.get(); in TestMultipleAdapter()
|
| H A D | PublishTest.java | 54 …CompletableFuture<Integer> subscribed = connection.subscribe(TEST_TOPIC, QualityOfService.AT_LEAST… in subscribe() local
57 subscribed.get(); in subscribe()
|
| /aosp_15_r20/cts/tests/tests/media/bettertogether/src/android/media/bettertogether/cts/ |
| H A D | MediaBrowserServiceTestService.java | 57 CountDownLatch subscribed = new CountDownLatch(1); in testSeriesOfNotifyChildrenChanged_setUp() local
64 if (subscribed.getCount() > 0) { in testSeriesOfNotifyChildrenChanged_setUp()
65 subscribed.countDown(); in testSeriesOfNotifyChildrenChanged_setUp()
80 assertThat(subscribed.await(TIMEOUT_MS, MILLISECONDS)).isTrue(); in testSeriesOfNotifyChildrenChanged_setUp()
|
| /aosp_15_r20/external/libcups/cups/ |
| H A D | notify.c | 39 *subscribed; /* notify-subscribed-event */ in cupsNotifySubject() local
59 subscribed = ippFindAttribute(event, "notify-subscribed-event", in cupsNotifySubject()
136 else if (subscribed) in cupsNotifySubject()
137 strlcpy(buffer, subscribed->values[0].string.text, sizeof(buffer)); in cupsNotifySubject()
|
| /aosp_15_r20/frameworks/base/services/core/java/com/android/server/notification/ |
| H A D | ConditionProviders.java | 370 if (r.subscribed) return true; in subscribeIfNecessary()
372 return r.subscribed; in subscribeIfNecessary()
383 if (!r.subscribed) return; in unsubscribeIfNecessary()
396 r.subscribed = true; in subscribeLocked()
430 r.subscribed = false; in unsubscribeLocked()
500 public boolean subscribed; field in ConditionProviders.ConditionRecord
511 .append(",subscribed=").append(subscribed); in toString()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| H A D | StateFlowCancellabilityTest.kt | 14 var subscribed = true in <lambda>() variable
19 subscribed = true in <lambda>()
38 assertTrue(subscribed) // should have subscribed in the first barrier in <lambda>()
|
| /aosp_15_r20/cts/tests/tests/notificationlegacy/notificationlegacy27/src/android/app/notification/legacy/cts/ |
| H A D | PollableConditionProviderService.java | 27 boolean subscribed; field in PollableConditionProviderService
46 subscribed = true; in onSubscribe()
54 subscribed = false; in onUnsubscribe()
|
| H A D | ConditionProviderServiceTest.java | 335 while (tries-- > 0 && !service.subscribed) { in pollForSubscribe()
343 if (!service.subscribed) { in pollForSubscribe()
|
| /aosp_15_r20/external/tinyalsa_new/src/ |
| H A D | mixer_plugin.c | 173 *subscribe = plugin->subscribed; in mixer_plug_subscribe_events()
177 if (*subscribe && !plugin->subscribed) { in mixer_plug_subscribe_events()
179 } else if (plugin->subscribed && !*subscribe) { in mixer_plug_subscribe_events()
188 plugin->subscribed = *subscribe; in mixer_plug_subscribe_events()
|
| /aosp_15_r20/external/tinyalsa/ |
| H A D | mixer_plugin.c | 178 *subscribe = plugin->subscribed; in mixer_plug_subscribe_events()
182 if (*subscribe && !plugin->subscribed) { in mixer_plug_subscribe_events()
184 } else if (plugin->subscribed && !*subscribe) { in mixer_plug_subscribe_events()
196 plugin->subscribed = *subscribe; in mixer_plug_subscribe_events()
|
| /aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/ |
| H A D | SubmissionPublisher.java | 243 boolean subscribed; field in SubmissionPublisher
353 if (!subscribed) { in subscribe()
354 subscribed = true; in subscribe()
808 boolean subscribed = false; in isSubscribed()
823 else if (subscribed = subscriber.equals(b.subscriber)) in isSubscribed()
832 return subscribed; in isSubscribed()
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SubmissionPublisher.java | 243 boolean subscribed; field in SubmissionPublisher
353 if (!subscribed) { in subscribe()
354 subscribed = true; in subscribe()
808 boolean subscribed = false; in isSubscribed()
823 else if (subscribed = subscriber.equals(b.subscriber)) in isSubscribed()
832 return subscribed; in isSubscribed()
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/20/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SubmissionPublisher.java | 243 boolean subscribed; field in SubmissionPublisher
353 if (!subscribed) { in subscribe()
354 subscribed = true; in subscribe()
808 boolean subscribed = false; in isSubscribed()
823 else if (subscribed = subscriber.equals(b.subscriber)) in isSubscribed()
832 return subscribed; in isSubscribed()
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/ |
| H A D | S3CrtRequestBodyStreamAdapter.java | 34 private final AtomicBoolean subscribed = new AtomicBoolean(false); field in S3CrtRequestBodyStreamAdapter
43 if (subscribed.compareAndSet(false, true)) { in sendRequestBody()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/http-auth-aws/src/main/java/software/amazon/awssdk/http/auth/aws/internal/signer/io/ |
| H A D | InMemoryPublisher.java | 35 private final AtomicBoolean subscribed = new AtomicBoolean(false); field in InMemoryPublisher
44 if (!subscribed.compareAndSet(false, true)) { in subscribe()
|
| /aosp_15_r20/hardware/interfaces/automotive/vehicle/2.0/ |
| H A D | IVehicleCallback.hal | 23 * subscribed to needs to be reported. This may be based purely on
35 * This method gets called if the client was subscribed to a property using
|
| /aosp_15_r20/external/googleapis/google/cloud/essentialcontacts/v1/ |
| H A D | enums.proto | 27 // The notification categories that an essential contact can be subscribed to.
29 // categories. All contacts that are subscribed to that category will receive
|
| H A D | service.proto | 106 // Lists all contacts for the resource that are subscribed to the
284 // in this list, contacts subscribed to any notification category will be
303 // All contacts for the resource that are subscribed to the specified
341 // contacts must be subscribed to this category.
|
| /aosp_15_r20/external/google-cloud-java/java-essential-contacts/proto-google-cloud-essential-contacts-v1/src/main/proto/google/cloud/essentialcontacts/v1/ |
| H A D | enums.proto | 27 // The notification categories that an essential contact can be subscribed to.
29 // categories. All contacts that are subscribed to that category will receive
|
| H A D | service.proto | 106 // Lists all contacts for the resource that are subscribed to the
283 // in this list, contacts subscribed to any notification category will be
302 // All contacts for the resource that are subscribed to the specified
340 // contacts must be subscribed to this category.
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| H A D | SharedFlowTest.kt | 777 var subscribed = true in <lambda>() variable
779 .onSubscription { subscribed = true } in <lambda>()
793 assertTrue(subscribed) // yielding in enough in <lambda>()
|