| /external/cronet/net/third_party/quiche/src/quiche/http2/hpack/decoder/ |
| D | hpack_entry_collector_test.cc | 19 HpackEntryCollector collector; in TEST() local
20 QUICHE_VLOG(1) << collector; in TEST()
21 EXPECT_THAT(collector.ToString(), HasSubstr("!started")); in TEST()
22 EXPECT_TRUE(collector.IsClear()); in TEST()
23 collector.set_header_type(HpackEntryType::kIndexedLiteralHeader); in TEST()
24 EXPECT_FALSE(collector.IsClear()); in TEST()
25 QUICHE_VLOG(1) << collector; in TEST()
26 collector.Clear(); in TEST()
27 EXPECT_TRUE(collector.IsClear()); in TEST()
28 collector.set_index(123); in TEST()
[all …]
|
| D | hpack_block_collector_test.cc | 19 HpackBlockCollector collector; in TEST() local
20 EXPECT_TRUE(collector.IsClear()); in TEST()
21 EXPECT_TRUE(collector.IsNotPending()); in TEST()
23 collector.OnIndexedHeader(234); in TEST()
24 EXPECT_FALSE(collector.IsClear()); in TEST()
25 EXPECT_TRUE(collector.IsNotPending()); in TEST()
27 collector.Clear(); in TEST()
28 EXPECT_TRUE(collector.IsClear()); in TEST()
29 EXPECT_TRUE(collector.IsNotPending()); in TEST()
31 collector.OnDynamicTableSizeUpdate(0); in TEST()
[all …]
|
| /external/robolectric/utils/src/test/java/org/robolectric/util/ |
| D | PerfStatsCollectorTest.kt | 15 private lateinit var collector: PerfStatsCollector variable in org.robolectric.util.PerfStatsCollectorTest
21 collector = PerfStatsCollector(fakeClock) in setUp()
27 val firstEvent = collector.startEvent("first event") in shouldMeasureElapsedTimeForEvents()
30 val metrics = collector.metrics in shouldMeasureElapsedTimeForEvents()
37 val firstEvent = collector.startEvent("repeatable event") in shouldMeasureElapsedTimeForRepeatedEvents()
40 val secondEvent = collector.startEvent("repeatable event") in shouldMeasureElapsedTimeForRepeatedEvents()
43 val thirdEvent = collector.startEvent("repeatable event") in shouldMeasureElapsedTimeForRepeatedEvents()
46 val metrics = collector.metrics in shouldMeasureElapsedTimeForRepeatedEvents()
54 collector.measure<String, RuntimeException>("event") { in shouldRunAndMeasureSuccessfulCallable()
60 val metrics = collector.metrics in shouldRunAndMeasureSuccessfulCallable()
[all …]
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| D | CollectorTester.java | 54 public static <T, A, R> CollectorTester<T, A, R> of(Collector<T, A, R> collector) { in of() argument
55 return of(collector, Objects::equals); in of()
63 Collector<T, A, R> collector, BiPredicate<? super R, ? super R> equivalence) { in of() argument
64 return new CollectorTester<>(collector, equivalence); in of()
67 private final Collector<T, A, R> collector; field in CollectorTester
71 Collector<T, A, R> collector, BiPredicate<? super R, ? super R> equivalence) { in CollectorTester() argument
72 this.collector = checkNotNull(collector); in CollectorTester()
84 final <T, A, R> A result(Collector<T, A, R> collector, Iterable<T> inputs) { in result() argument
85 A accum = collector.supplier().get(); in result()
87 collector.accumulator().accept(accum, input); in result()
[all …]
|
| /external/robolectric-shadows/utils/src/test/java/org/robolectric/util/ |
| D | PerfStatsCollectorTest.java | 19 private PerfStatsCollector collector; field in PerfStatsCollectorTest
24 collector = new PerfStatsCollector(fakeClock); in setUp()
29 Event firstEvent = collector.startEvent("first event"); in shouldMeasureElapsedTimeForEvents()
33 Collection<Metric> metrics = collector.getMetrics(); in shouldMeasureElapsedTimeForEvents()
41 Event firstEvent = collector.startEvent("repeatable event"); in shouldMeasureElapsedTimeForRepeatedEvents()
45 Event secondEvent = collector.startEvent("repeatable event"); in shouldMeasureElapsedTimeForRepeatedEvents()
49 Event thirdEvent = collector.startEvent("repeatable event"); in shouldMeasureElapsedTimeForRepeatedEvents()
53 Collection<Metric> metrics = collector.getMetrics(); in shouldMeasureElapsedTimeForRepeatedEvents()
61 assertThat(collector.measure("event", () -> { in shouldRunAndMeasureSuccessfulCallable()
66 Collection<Metric> metrics = collector.getMetrics(); in shouldRunAndMeasureSuccessfulCallable()
[all …]
|
| /external/desugar/test/java/com/google/devtools/build/android/desugar/dependencies/ |
| D | MetadataCollectorTest.java | 39 MetadataCollector collector = new MetadataCollector(false); in testAssumeCompanionClass() local
40 collector.assumeCompanionClass("a", "b$$CC"); in testAssumeCompanionClass()
41 collector.assumeCompanionClass("b", "b$$CC"); in testAssumeCompanionClass()
42 collector.assumeCompanionClass("a", "a$$CC"); in testAssumeCompanionClass()
44 DesugarDepsInfo info = extractProto(collector); in testAssumeCompanionClass()
54 MetadataCollector collector = new MetadataCollector(true); in testMissingImplementedInterface() local
55 collector.missingImplementedInterface("a", "b"); in testMissingImplementedInterface()
56 collector.missingImplementedInterface("a", "c"); in testMissingImplementedInterface()
57 collector.missingImplementedInterface("c", "b"); in testMissingImplementedInterface()
59 DesugarDepsInfo info = extractProto(collector); in testMissingImplementedInterface()
[all …]
|
| /external/mockito/src/test/java/org/mockitousage/junitrule/ |
| D | VerificationCollectorImplTest.java | 24 VerificationCollector collector = MockitoJUnit.collector().assertLazily(); in should_not_throw_any_exceptions_when_verifications_are_successful() local
30 collector.collectAndReport(); in should_not_throw_any_exceptions_when_verifications_are_successful()
35 VerificationCollector collector = MockitoJUnit.collector().assertLazily(); in should_collect_verification_failures() local
40 collector.collectAndReport(); in should_collect_verification_failures()
45 VerificationCollector collector = MockitoJUnit.collector().assertLazily(); in should_collect_multiple_verification_failures() local
52 collector.collectAndReport(); in should_collect_multiple_verification_failures()
62 VerificationCollector collector = MockitoJUnit.collector().assertLazily(); in should_only_collect_failures_ignore_successful_verifications() local
69 this.assertAtLeastOneFailure(collector); in should_only_collect_failures_ignore_successful_verifications()
74 VerificationCollector collector = MockitoJUnit.collector().assertLazily(); in should_continue_collecting_after_failing_verification() local
82 this.assertAtLeastOneFailure(collector); in should_continue_collecting_after_failing_verification()
[all …]
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | collector.rs | 92 pub fn collector(&self) -> &Collector { in collector() method
93 unsafe { (*self.local).collector() } in collector()
125 let collector = Collector::new(); in pin_reentrant() localVariable
126 let handle = collector.register(); in pin_reentrant()
127 drop(collector); in pin_reentrant()
144 let collector = Collector::new(); in flush_local_bag() localVariable
145 let handle = collector.register(); in flush_local_bag()
146 drop(collector); in flush_local_bag()
165 let collector = Collector::new(); in garbage_buffering() localVariable
166 let handle = collector.register(); in garbage_buffering()
[all …]
|
| D | default.rs | 7 use crate::collector::{Collector, LocalHandle};
13 fn collector() -> &'static Collector { in collector() function
34 static HANDLE: LocalHandle = collector().register();
51 collector() in default_collector()
61 .unwrap_or_else(|_| f(&collector().register())) in with_handle()
|
| /external/openscreen/cast/streaming/ |
| D | frame_collector_unittest.cc | 28 #define EXPECT_HAS_NACKS(expected_nacks, collector) \ argument
31 (collector).GetMissingPackets(&nacks); \
36 FrameCollector collector; in TEST() local
41 collector.set_frame_id(frame_id); in TEST()
42 EXPECT_FALSE(collector.is_complete()); in TEST()
47 collector); in TEST()
68 EXPECT_TRUE(collector.CollectRtpPacket(part, &buffer)); in TEST()
71 EXPECT_TRUE(collector.is_complete()); in TEST()
72 EXPECT_HAS_NACKS(std::vector<PacketNack>(), collector); in TEST()
76 const auto& frame = collector.PeekAtAssembledFrame(); in TEST()
[all …]
|
| D | receiver.cc | 104 if (entry.collector.is_complete()) { in AdvanceToNextFrame()
106 entry.collector.PeekAtAssembledFrame(); in AdvanceToNextFrame()
152 OSP_DCHECK(entry.collector.is_complete()); in ConsumeNextFrame()
155 crypto_.Decrypt(entry.collector.PeekAtAssembledFrame(), &frame); in ConsumeNextFrame()
208 .collector.set_frame_id(latest_frame_expected_); in OnReceivedRtpPacket()
227 FrameCollector& collector = pending_frame.collector; in OnReceivedRtpPacket() local
228 if (collector.is_complete()) { in OnReceivedRtpPacket()
234 if (!collector.CollectRtpPacket(*part, &packet)) { in OnReceivedRtpPacket()
265 if (!collector.is_complete()) { in OnReceivedRtpPacket()
268 const EncryptedFrame& encrypted_frame = collector.PeekAtAssembledFrame(); in OnReceivedRtpPacket()
[all …]
|
| /external/tensorflow/tensorflow/core/util/proto/ |
| D | proto_utils_test.cc | 65 StringErrorCollector collector(&err); in TEST() local
66 collector.AddError(1, 2, "foo"); in TEST()
72 StringErrorCollector collector(&err); in TEST() local
73 collector.AddWarning(1, 2, "foo"); in TEST()
79 StringErrorCollector collector(&err); in TEST() local
80 collector.AddError(1, 2, "foo"); in TEST()
81 collector.AddError(3, 4, "bar"); in TEST()
87 StringErrorCollector collector(&err); in TEST() local
88 collector.AddWarning(1, 2, "foo"); in TEST()
89 collector.AddWarning(3, 4, "bar"); in TEST()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | TableCollectorsTest.java | 36 Collector<Cell<String, String, Integer>, ?, ImmutableTable<String, String, Integer>> collector = in testToImmutableTable() local
40 CollectorTester.of(collector, equivalence) in testToImmutableTable()
53 Collector<Cell<String, String, Integer>, ?, ImmutableTable<String, String, Integer>> collector = in testToImmutableTableConflict() local
56 Stream.of(immutableCell("one", "uno", 1), immutableCell("one", "uno", 2)).collect(collector); in testToImmutableTableConflict()
63 Collector<Cell<String, String, Integer>, ?, ImmutableTable<String, String, Integer>> collector = in testToImmutableTableNullRowKey() local
66 Stream.of(immutableCell("one", "uno", 1)).collect(collector); in testToImmutableTableNullRowKey()
73 Collector<Cell<String, String, Integer>, ?, ImmutableTable<String, String, Integer>> collector = in testToImmutableTableNullColumnKey() local
76 Stream.of(immutableCell("one", "uno", 1)).collect(collector); in testToImmutableTableNullColumnKey()
83 Collector<Cell<String, String, Integer>, ?, ImmutableTable<String, String, Integer>> collector = in testToImmutableTableNullValue() local
86 Stream.of(immutableCell("one", "uno", 1)).collect(collector); in testToImmutableTableNullValue()
[all …]
|
| /external/cronet/base/sampling_heap_profiler/ |
| D | sampling_heap_profiler_unittest.cc | 103 SamplesCollector collector(10000); in TEST_F() local
106 sampler->AddSamplesObserver(&collector); in TEST_F()
109 sampler->RemoveSamplesObserver(&collector); in TEST_F()
110 EXPECT_TRUE(collector.sample_added); in TEST_F()
111 EXPECT_TRUE(collector.sample_removed); in TEST_F()
116 SamplesCollector collector(10000); in TEST_F() local
119 sampler->AddSamplesObserver(&collector); in TEST_F()
125 sampler->RemoveSamplesObserver(&collector); in TEST_F()
126 EXPECT_FALSE(collector.sample_added); in TEST_F()
127 EXPECT_FALSE(collector.sample_removed); in TEST_F()
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/ |
| D | FlowPlaysScrabbleOpt.kt | 128 val collector = object : FlowCollector<Int> { in asFlow() constant
135 collect(collector) in asFlow()
136 return collector.sum in asFlow()
140 val collector = object : FlowCollector<Int> { in max() constant
147 collect(collector) in max()
148 return collector.max in max()
153 val collector = object : FlowCollector<Long> { in sum() constant
160 collect(collector) in sum()
161 return collector.sum in sum()
165 override suspend fun collect(collector: FlowCollector<Char>) { in collect()
[all …]
|
| /external/yapf/yapftests/ |
| D | pytree_visitor_test.py | 65 collector = _NodeNameCollector()
66 collector.Visit(tree)
73 self.assertEqual(expected_names, collector.all_node_names)
76 self.assertEqual(expected_name_node_values, collector.name_node_values)
80 collector = _NodeNameCollector()
81 collector.Visit(tree)
90 self.assertEqual(expected_names, collector.all_node_names)
93 self.assertEqual(expected_name_node_values, collector.name_node_values)
|
| /external/python/cpython3/Lib/test/ |
| D | test_htmlparser.py | 86 def _run_check(self, source, expected_events, collector=None): argument
87 if collector is None:
88 collector = self.get_collector()
89 parser = collector
316 collector=Collector(convert_charrefs=False))
346 collector = lambda: EventCollectorCharrefs() function
347 self.assertTrue(collector().convert_charrefs)
354 expected, collector=collector())
362 expected, collector=collector())
373 expected, collector=collector())
[all …]
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_unittest.cc | 123 explicit TestDelegate(NotificationCollector* collector) in TestDelegate() argument
124 : collector_(collector) { in TestDelegate()
205 NotificationCollector* collector() { return collector_.get(); } in collector() function in base::__anon89a21af20111::FilePathWatcherTest
231 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
243 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
257 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
269 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
318 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
326 std::unique_ptr<TestDelegate> delegate1(new TestDelegate(collector())); in TEST_F()
327 std::unique_ptr<TestDelegate> delegate2(new TestDelegate(collector())); in TEST_F()
[all …]
|
| /external/cronet/build/android/ |
| D | method_count.py | 89 collector = DexStatsCollector()
92 collector.CollectFromZip(path, path)
94 collector.CollectFromDex(path, path)
96 counts_by_label = collector.GetCountsByLabel()
105 for metric, count in sorted(collector.GetTotalCounts().items()):
109 print('Unique Methods:', collector.GetUniqueMethodCount())
110 print('DexCache (Pre-Oreo):', collector.GetDexCacheSize(pre_oreo=True),
112 print('DexCache (Oreo+):', collector.GetDexCacheSize(pre_oreo=False),
|
| /external/angle/build/android/ |
| D | method_count.py | 89 collector = DexStatsCollector()
92 collector.CollectFromZip(path, path)
94 collector.CollectFromDex(path, path)
96 counts_by_label = collector.GetCountsByLabel()
105 for metric, count in sorted(collector.GetTotalCounts().items()):
109 print('Unique Methods:', collector.GetUniqueMethodCount())
110 print('DexCache (Pre-Oreo):', collector.GetDexCacheSize(pre_oreo=True),
112 print('DexCache (Oreo+):', collector.GetDexCacheSize(pre_oreo=False),
|
| /external/opencensus-java/exporters/stats/prometheus/src/test/java/io/opencensus/exporter/stats/prometheus/ |
| D | PrometheusStatsCollectorTest.java | 102 PrometheusStatsCollector collector = new PrometheusStatsCollector(mockViewManager); in testCollect() local
104 assertThat(collector.collect()) in testCollect()
144 PrometheusStatsCollector collector = new PrometheusStatsCollector(mockViewManager); in testCollect_SkipDistributionViewWithLeTagKey() local
145 assertThat(collector.collect()).isEmpty(); in testCollect_SkipDistributionViewWithLeTagKey()
150 PrometheusStatsCollector collector = new PrometheusStatsCollector(mockViewManager); in testDescribe() local
151 assertThat(collector.describe()) in testDescribe()
159 PrometheusStatsCollector collector = new PrometheusStatsCollector(Stats.getViewManager()); in testCollect_WithNoopViewManager() local
160 assertThat(collector.collect()).isEmpty(); in testCollect_WithNoopViewManager()
165 PrometheusStatsCollector collector = new PrometheusStatsCollector(Stats.getViewManager()); in testDescribe_WithNoopViewManager() local
166 assertThat(collector.describe()).isEmpty(); in testDescribe_WithNoopViewManager()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | ChannelFlow.kt | 121 override suspend fun collect(collector: FlowCollector<T>): Unit = in create()
123 collector.emitAll(produceImpl(this)) in create()
146 protected abstract suspend fun flowCollect(collector: FlowCollector<T>) in flowCollect()
149 …private suspend fun collectWithContextUndispatched(collector: FlowCollector<T>, newContext: Corout… in flowCollect()
150 val originalContextCollector = collector.withUndispatchedContextCollector(coroutineContext) in flowCollect()
160 override suspend fun collect(collector: FlowCollector<T>) { in collectTo()
167 return flowCollect(collector) in collectTo()
170 return collectWithContextUndispatched(collector, newContext) in collectTo()
173 super.collect(collector) in collectTo()
194 override suspend fun flowCollect(collector: FlowCollector<T>) = in toString()
[all …]
|
| D | Merge.kt | 23 override suspend fun flowCollect(collector: FlowCollector<R>) { in <lambda>()
24 …assert { collector is SendingCollector } // So cancellation behaviour is not leaking into the down… in <lambda>()
34 collector.transform(value) in <lambda>()
57 val collector = SendingCollector(scope) in collectTo() constant
69 inner.collect(collector) in collectTo()
94 val collector = SendingCollector(scope) in additionalToStringProps() constant
96 scope.launch { flow.collect(collector) } in additionalToStringProps()
|
| /external/cronet/base/files/ |
| D | file_path_watcher_unittest.cc | 131 explicit TestDelegate(NotificationCollector* collector) in TestDelegate() argument
132 : collector_(collector) { in TestDelegate()
227 NotificationCollector* collector() { return collector_.get(); } in collector() function in base::__anon91391b880111::FilePathWatcherTest
258 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
271 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
286 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
299 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
349 std::unique_ptr<TestDelegate> delegate(new TestDelegate(collector())); in TEST_F()
358 std::unique_ptr<TestDelegate> delegate1(new TestDelegate(collector())); in TEST_F()
359 std::unique_ptr<TestDelegate> delegate2(new TestDelegate(collector())); in TEST_F()
[all …]
|
| /external/jackson-databind/src/test/java/com/fasterxml/jackson/databind/introspect/ |
| D | POJOPropertiesCollectorTest.java | 244 POJOPropertiesCollector coll = collector(MAPPER, in testSimple()
258 POJOPropertiesCollector coll = collector(MAPPER, in testSimpleFieldVisibility()
271 POJOPropertiesCollector coll = collector(MAPPER, in testSimpleGetterVisibility()
286 POJOPropertiesCollector coll = collector(MAPPER, in testEmpty()
297 POJOPropertiesCollector coll = collector(MAPPER, in testPartialIgnore()
310 POJOPropertiesCollector coll = collector(MAPPER, in testSimpleRenamed()
323 POJOPropertiesCollector coll = collector(MAPPER, in testSimpleRenamed2()
336 POJOPropertiesCollector coll = collector(MAPPER, in testMergeWithRename()
349 POJOPropertiesCollector coll = collector(MAPPER, in testSimpleIgnoreAndRename()
365 POJOPropertiesCollector coll = collector(m, SimpleGetterVisibility.class, true); in testGlobalVisibilityForGetters()
[all …]
|