| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/tests/ |
| D | option.rs | 25 let subscriber = tracing_subscriber::registry().with(LevelFilter::INFO); in just_layer() localVariable
31 let subscriber = tracing_subscriber::registry() in subscriber_and_option_some_layer() localVariable
40 let subscriber = tracing_subscriber::registry() in subscriber_and_option_none_layer() localVariable
49 let subscriber = tracing_subscriber::registry().with(None::<LevelFilter>); in just_option_some_layer() localVariable
56 let subscriber = tracing_subscriber::registry().with(Some(LevelFilter::ERROR)); in just_option_none_layer() localVariable
64 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
75 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
86 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
99 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
110 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
[all …]
|
| D | hinted_layer_filters_dont_break_other_layers.rs | 15 let subscriber = tracing_subscriber::registry() in layer_filters() localVariable
39 let subscriber = tracing_subscriber::registry() in layered_layer_filters() localVariable
61 let subscriber = tracing_subscriber::registry() in out_of_order() localVariable
87 let subscriber = tracing_subscriber::registry().with(layered1).with(layered2); in mixed_layered() localVariable
|
| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| H A D | ByteBufferStoringSubscriberTest.java | 63 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(3); in doesNotRequestMoreThanMaxBytes() local
81 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(3); in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax() local
106 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(1); in blockingTransfer_waitsForFullOutputBuffer() local
147 … ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_stopsOnComplete() local
176 … ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_stopsOnError() local
200 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_stopsOnInterrupt() local
231 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_returnsEndOfStreamWithRepeatedCalls() local
246 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(2); in noDataTransferredIfNoDataBuffered() local
257 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(2); in noDataTransferredIfComplete() local
271 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(2); in noDataTransferredIfError() local
[all …]
|
| H A D | SimplePublisherTest.java | 54 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in immediateSuccessWorks() local
67 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in immediateFailureWorks() local
130 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in oneDemandWorks() local
154 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in highDemandWorks() local
185 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in writeFuturesDoNotCompleteUntilAfterOnNext() local
203 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in completeFuturesDoNotCompleteUntilAfterOnComplete() local
224 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in errorFuturesDoNotCompleteUntilAfterOnError() local
244 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(Integer.MAX_VALUE); in completeBeforeSubscribeIsDeliveredOnSubscribe() local
254 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(Integer.MAX_VALUE); in errorBeforeSubscribeIsDeliveredOnSubscribe() local
266 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(Integer.MAX_VALUE); in writeBeforeSubscribeIsDeliveredOnSubscribe() local
[all …]
|
| H A D | StoringSubscriberTest.java | 52 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in doesNotStoreMoreThanMaxElements() local
73 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsEmptyEventWithOutstandingDemand() local
80 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsCompleteOnComplete() local
89 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsErrorOnError() local
99 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in errorWrapsCheckedExceptions() local
108 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in deliversMessagesInTheCorrectOrder() local
136 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(10); in stochastic_subscriberSeemsThreadSafe() local
|
| H A D | AddingTrailingDataSubscriberTest.java | 50 Subscriber<Integer> subscriber = new AddingTrailingDataSubscriber<>(downstreamSubscriber, in trailingDataHasItems_shouldSendAdditionalData() local
67 …Subscriber<Integer> subscriber = new AddingTrailingDataSubscriber<>(downstreamSubscriber, () -> ne… in trailingDataEmpty_shouldNotSendAdditionalData() local
82 …Subscriber<Integer> subscriber = new AddingTrailingDataSubscriber<>(downstreamSubscriber, () -> nu… in trailingDataNull_shouldCompleteNormally() local
91 private void publishData(Subscriber<Integer> subscriber) { in publishData()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/layer/ |
| D | tests.rs | 93 let subscriber = in downcasts_to_subscriber() localVariable
166 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
174 let subscriber = crate::registry().with(NopLayer).with( in mixed_with_unfiltered_layered() localVariable
184 let subscriber = crate::registry() in mixed_interleaved() localVariable
194 let subscriber = crate::registry() in mixed_layered() localVariable
202 let subscriber = crate::registry() in plf_only_unhinted() localVariable
212 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
233 let subscriber = dbg!(crate::registry().with( in plf_only_unhinted_nested_inner() localVariable
244 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
257 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/fmt/format/ |
| D | json.rs | 560 fn subscriber() -> SubscriberBuilder<JsonFields, Format<Json>> { in subscriber() function
568 let subscriber = subscriber() in json() localVariable
595 let subscriber = subscriber() in json_filename() localVariable
611 let subscriber = subscriber() in json_line_number() localVariable
628 let subscriber = subscriber() in json_flattened_event() localVariable
643 let subscriber = subscriber() in json_disabled_current_span_event() localVariable
658 let subscriber = subscriber() in json_disabled_span_list_event() localVariable
673 let subscriber = subscriber() in json_nested_span() localVariable
695 let subscriber = subscriber() in json_no_span() localVariable
710 let subscriber = crate::fmt() in record_works() localVariable
[all …]
|
| D | mod.rs | 1760 let subscriber = crate::fmt::Subscriber::builder() in disable_everything() localVariable
1768 let subscriber = subscriber.with_ansi(false); in disable_everything() localVariable
1781 let subscriber = builder in test_ansi() localVariable
1797 let subscriber = builder.with_writer(make_writer).with_timer(MockTime); in test_without_ansi() localVariable
1809 let subscriber = builder in test_without_level() localVariable
1820 let subscriber = crate::fmt::Subscriber::builder() in with_line_number_and_file_name() localVariable
1845 let subscriber = crate::fmt::Subscriber::builder() localVariable
1864 let subscriber = crate::fmt::Subscriber::builder() localVariable
1880 let subscriber = crate::fmt::Subscriber::builder() localVariable
1894 let subscriber = crate::fmt::Subscriber::builder() localVariable
[all …]
|
| /aosp_15_r20/out/soong/.intermediates/frameworks/base/packages/SystemUI/SystemUI-core/android_common/kapt/gen/stubs/com/android/systemui/controls/controller/ |
| D | ControlsProviderLifecycleManager.java | 137 public final void maybeBindAndLoad(@org.jetbrains.annotations.NotNull() in maybeBindAndLoad()
149 public final void maybeBindAndLoadSuggested(@org.jetbrains.annotations.NotNull() in maybeBindAndLoadSuggested()
165 android.service.controls.IControlsSubscriber subscriber) { in maybeBindAndSubscribe()
262 private final android.service.controls.IControlsSubscriber.Stub subscriber = null; field in ControlsProviderLifecycleManager.Load
264 public Load(@org.jetbrains.annotations.NotNull() in Load()
301 private final android.service.controls.IControlsSubscriber subscriber = null; field in ControlsProviderLifecycleManager.Subscribe
305 android.service.controls.IControlsSubscriber subscriber) { in Subscribe()
328 private final android.service.controls.IControlsSubscriber.Stub subscriber = null; field in ControlsProviderLifecycleManager.Suggest
330 public Suggest(@org.jetbrains.annotations.NotNull() in Suggest()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/ |
| H A D | AsyncRequestBodyTest.java | 77 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(buffer -> { in hasCorrectContent() local
119 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in fromBytesCopiesTheProvidedByteArray() local
138 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in fromBytesUnsafeDoesNotCopyTheProvidedByteArray() local
159 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in safeByteBufferBuildersCopyTheProvidedBuffer() local
187 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in unsafeByteBufferBuildersDoNotCopyTheProvidedBuffer() local
215 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in nonRewindingByteBufferBuildersReadFromTheInputBufferPosition() local
247 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in safeNonRewindingByteBufferBuildersCopyFromTheInputBufferPosition() local
274 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(buffer -> { in rewindingByteBufferBuildersDoNotRewindTheInputBuffer() local
293 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in rewindingByteBufferBuildersReadTheInputBufferFromTheBeginning() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| H A D | ByteBuffersAsyncRequestBodyTest.java | 76 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsMarkedAsCompleted() local
88 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsMarkedAsCompletedWhenARequestIsMadeForMoreBuffersThanAreAvailable() local
103 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsThreadSafeAndMarkedAsCompletedExactlyOnce() local
131 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsNotMarkedAsCompletedWhenThereAreRemainingBuffersToPublish() local
148 TestSubscriber subscriber = new TestSubscriber(); in subscriberReceivesAllBuffers() local
163 TestSubscriber subscriber = new TestSubscriber(); in multipleSubscribersReceiveTheSameResults() local
180 TestSubscriber subscriber = new TestSubscriber(); in canceledSubscriberDoesNotReturnNewResults() local
|
| H A D | FileAsyncRequestBodyTest.java | 121 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsShorterThanAlreadyRead_failsBecauseTooShort() local
144 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsShorterThanExistingLength_failsBecauseTooShort() local
170 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsLongerThanExistingLength_failsBecauseTooLong() local
196 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsTouched_failsBecauseUpdatedModificationTime() local
220 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsDeleted_failsBecauseDeleted() local
|
| /aosp_15_r20/packages/services/Car/service/src/com/android/car/telemetry/publisher/ |
| D | StatsPublisher.java | 218 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber()
243 DataSubscriber subscriber = mConfigKeyToSubscribers.get(configKey); in processReport() local
408 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber()
460 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber()
483 private static String buildBundleConfigKey(@NonNull DataSubscriber subscriber) { in buildBundleConfigKey()
501 private void addStatsConfig(long configKey, @NonNull DataSubscriber subscriber) { in addStatsConfig()
530 private long removeStatsConfig(@NonNull DataSubscriber subscriber) { in removeStatsConfig()
559 private static long buildConfigKey(@NonNull DataSubscriber subscriber) { in buildConfigKey()
569 static StatsdConfig buildStatsdConfig(@NonNull DataSubscriber subscriber, long configId) { in buildStatsdConfig()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/tests/env_filter/ |
| D | main.rs | 22 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
55 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
75 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
112 let subscriber = Registry::default().with(filter).with(layer); in level_filter_event_with_target_and_span_global() localVariable
144 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
175 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
205 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/pagination/async/ |
| H A D | PaginationSubscription.java | 28 protected final Subscriber subscriber; field in PaginationSubscription
108 BuilderT subscriber(Subscriber subscriber); in subscriber() method
117 private Subscriber subscriber; field in PaginationSubscription.BuilderImpl
121 public BuilderT subscriber(Subscriber subscriber) { in subscriber() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/fmt/ |
| D | fmt_layer.rs | 1238 let subscriber = fmt.with_subscriber(Registry::default()); in impls() localVariable
1243 let subscriber = fmt.with_subscriber(Registry::default()); in impls() localVariable
1248 let subscriber = fmt.with_subscriber(Registry::default()); in impls() localVariable
1256 let subscriber = fmt.with_subscriber(Registry::default()); in fmt_layer_downcasts() localVariable
1266 let subscriber = fmt.with_subscriber(Registry::default()); in fmt_layer_downcasts_to_parts() localVariable
1276 let subscriber = fmt.with_subscriber(Registry::default()); in is_lookup_span() localVariable
1296 let subscriber = crate::fmt::Subscriber::builder() in format_error_print_to_stderr() localVariable
1333 let subscriber = crate::fmt::Subscriber::builder() in format_error_ignore_if_log_internal_errors_is_false() localVariable
1351 let subscriber = crate::fmt::Subscriber::builder() in synthesize_span_none() localVariable
1370 let subscriber = crate::fmt::Subscriber::builder() in synthesize_span_active() localVariable
[all …]
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/auth/src/test/java/software/amazon/awssdk/auth/signer/internal/ |
| H A D | DigestComputingSubscriberTest.java | 40 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(); in test_computesCorrectSha256() local
55 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(); in test_futureCancelledBeforeSubscribe_cancelsSubscription() local
68 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(); in test_publisherCallsOnError_errorPropagatedToFuture() local
84 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(sdkChecksum); in test_computesCorrectSdkChecksum() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| H A D | HandlerSubscriberBlackboxVerificationTest.java | 48 HandlerSubscriber<Long> subscriber = new HandlerSubscriber<>(channel.eventLoop(), 2, 4); in createSubscriber() local
60 public void triggerRequest(Subscriber<? super Long> subscriber) { in triggerRequest()
75 final HandlerSubscriber<T> subscriber; field in HandlerSubscriberBlackboxVerificationTest.SubscriberWithChannel
77 public SubscriberWithChannel(EmbeddedChannel channel, HandlerSubscriber<T> subscriber) { in SubscriberWithChannel()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/http-auth-aws/src/test/java/software/amazon/awssdk/http/auth/aws/internal/signer/io/ |
| H A D | ChecksumSubscriberTest.java | 46 ChecksumSubscriber subscriber = new ChecksumSubscriber(Collections.singleton(checksum)); in checksum_computesCorrectSha256() local
64 …ChecksumSubscriber subscriber = new ChecksumSubscriber(Arrays.asList(sha256Checksum, crc32Checksum… in checksum_withMultipleChecksums_shouldComputeCorrectChecksums() local
80 ChecksumSubscriber subscriber = new ChecksumSubscriber(Collections.emptyList()); in checksum_futureCancelledBeforeSubscribe_cancelsSubscription() local
94 ChecksumSubscriber subscriber = new ChecksumSubscriber(Collections.emptyList()); in checksum_publisherCallsOnError_errorPropagatedToFuture() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/eventstream/ |
| H A D | DefaultEventStreamResponseHandlerBuilder.java | 41 private Supplier<Subscriber<EventT>> subscriber; field in DefaultEventStreamResponseHandlerBuilder
79 public SubBuilderT subscriber(Supplier<Subscriber<EventT>> eventSubscriber) { in subscriber() method in DefaultEventStreamResponseHandlerBuilder
85 public SubBuilderT subscriber(Consumer<EventT> eventConsumer) { in subscriber() method in DefaultEventStreamResponseHandlerBuilder
90 Supplier<Subscriber<EventT>> subscriber() { in subscriber() method in DefaultEventStreamResponseHandlerBuilder
|
| /aosp_15_r20/frameworks/native/libs/bufferstreams/rust/src/publishers/ |
| H A D | testing.rs | 24 subscriber: Option<Box<dyn BufferSubscriber>>, field
41 let subscriber = in send_frame() localVariable
58 let subscriber = in send_complete() localVariable
69 let subscriber = in send_error() localVariable
|
| /aosp_15_r20/external/openscreen/platform/impl/ |
| H A D | socket_handle_waiter.cc | 18 void SocketHandleWaiter::Subscribe(Subscriber* subscriber, in Subscribe()
26 void SocketHandleWaiter::Unsubscribe(Subscriber* subscriber, in Unsubscribe()
35 void SocketHandleWaiter::UnsubscribeAll(Subscriber* subscriber) { in UnsubscribeAll()
46 void SocketHandleWaiter::OnHandleDeletion(Subscriber* subscriber, in OnHandleDeletion()
|
| /aosp_15_r20/external/ims/rcs/rcsservice/src/com/android/service/ims/presence/ |
| H A D | PresenceSubscriber.java | 63 public PresenceSubscriber(SubscribePublisher subscriber, Context context, in PresenceSubscriber()
75 public void updatePresenceSubscriber(SubscribePublisher subscriber) { in updatePresenceSubscriber()
127 SubscribePublisher subscriber = null; in requestCapability() local
247 SubscribePublisher subscriber = null; in requestAvailability() local
383 SubscribePublisher subscriber = null; in onSipResponse() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/ |
| H A D | PublisherAdapterTest.java | 130 TestSubscriber subscriber = new TestSubscriber(); in successfulStreaming_shouldNotInvokeChannelRead() local
158 TestSubscriber subscriber = new TestSubscriber(); in errorOccurred_shouldInvokeResponseHandler() local
200 Subscriber<ByteBuffer> subscriber = new Subscriber<ByteBuffer>() { in subscriptionCancelled_upstreamPublisherCallsOnNext_httpContentReleased() local
257 Subscriber<ByteBuffer> subscriber = new Subscriber<ByteBuffer>() { in contentLengthValidationFails_closesAndReleasesConnection() local
|