| /external/perfetto/src/tracing/core/ |
| D | tracing_service_impl_unittest.cc | 249 std::unique_ptr<MockProducer> producer = CreateMockProducer(); in TEST_F() local
250 producer->Connect(svc.get(), "mock_producer"); in TEST_F()
251 producer->RegisterDataSource("data_source"); in TEST_F()
259 producer->WaitForTracingSetup(); in TEST_F()
260 producer->WaitForDataSourceSetup("data_source"); in TEST_F()
261 producer->WaitForDataSourceStart("data_source"); in TEST_F()
268 producer->WaitForDataSourceStop("data_source"); in TEST_F()
278 std::unique_ptr<MockProducer> producer = CreateMockProducer(); in TEST_F() local
279 producer->Connect(svc.get(), "mock_producer"); in TEST_F()
282 producer->RegisterDataSource("ds_1"); in TEST_F()
[all …]
|
| D | tracing_service_impl.cc | 143 TracingServiceImpl::ConnectProducer(Producer* producer, in ConnectProducer() argument
177 id, uid, this, task_runner_, producer, producer_name, in_process, in ConnectProducer()
193 if (auto* producer = GetProducer(id)) { in DisconnectProducer() local
195 ScrapeSharedMemoryBuffers(&session_id_and_session.second, producer); in DisconnectProducer()
608 ProducerEndpointImpl* producer = GetProducer(it->second.producer_id); in ChangeTraceConfig() local
609 PERFETTO_DCHECK(producer); in ChangeTraceConfig()
617 producer->name_) == new_producer_name_filter.end()) { in ChangeTraceConfig()
640 if (producer->name_ == config.producer_name()) { in ChangeTraceConfig()
650 StartDataSourceInstance(producer, tracing_session, ds_inst); in ChangeTraceConfig()
728 ProducerEndpointImpl* producer = GetProducer(producer_id); in StartTracing() local
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | multi_output_fusion.cc | 147 HloInstruction* producer = consumer_operands[i]; in DoProducerConsumerMultiOutputFusion() local
148 if (!producer->IsFusible()) { in DoProducerConsumerMultiOutputFusion()
149 VLOG(3) << producer->name() << " is not fusible."; in DoProducerConsumerMultiOutputFusion()
154 if (producer->opcode() == HloOpcode::kConstant) { in DoProducerConsumerMultiOutputFusion()
155 VLOG(3) << producer->name() << " is a constant."; in DoProducerConsumerMultiOutputFusion()
159 producer->opcode() == HloOpcode::kFusion && in DoProducerConsumerMultiOutputFusion()
160 producer->fusion_kind() == HloInstruction::FusionKind::kLoop; in DoProducerConsumerMultiOutputFusion()
161 if (!producer->IsElementwise() && !is_loop_fusion) { in DoProducerConsumerMultiOutputFusion()
162 VLOG(3) << producer->name() << " is not a loop fusion."; in DoProducerConsumerMultiOutputFusion()
165 if (!ShapesCompatibleForMultiOutputFusion(*producer, *consumer)) { in DoProducerConsumerMultiOutputFusion()
[all …]
|
| D | instruction_fusion.cc | 119 HloInstruction* producer = consumer->mutable_operand(operand_index); in ShouldFuseInexpensiveChecks() local
122 if (producer->opcode() == HloOpcode::kDot || in ShouldFuseInexpensiveChecks()
123 (producer->opcode() == HloOpcode::kFusion && in ShouldFuseInexpensiveChecks()
124 producer->fused_expression_root()->opcode() == HloOpcode::kDot)) { in ShouldFuseInexpensiveChecks()
161 consumer->operand(other_operand_index) != producer) { in ShouldFuseInexpensiveChecks()
172 auto producer_operand_index = consumer->operand_index(producer); in ShouldFuseInexpensiveChecks()
179 if (producer->opcode() == HloOpcode::kTranspose) { in ShouldFuseInexpensiveChecks()
183 if (producer->opcode() == HloOpcode::kBroadcast) { in ShouldFuseInexpensiveChecks()
186 return producer->dimensions().empty() && in ShouldFuseInexpensiveChecks()
187 IsIEEEFloatingPointScalarConstant(producer->operand(0)) && in ShouldFuseInexpensiveChecks()
[all …]
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | producer_ipc_service.cc | 66 std::unique_ptr<RemoteProducer> producer(new RemoteProducer()); in InitializeConnection() local
82 producer->service_endpoint = core_service_->ConnectProducer( in InitializeConnection()
83 producer.get(), client_info.uid(), req.producer_name(), in InitializeConnection()
88 if (!producer->service_endpoint) in InitializeConnection()
91 producers_.emplace(ipc_client_id, std::move(producer)); in InitializeConnection()
103 RemoteProducer* producer = GetProducerForCurrentRequest(); in RegisterDataSource() local
104 if (!producer) { in RegisterDataSource()
138 RemoteProducer* producer = GetProducerForCurrentRequest(); in UnregisterDataSource() local
139 if (!producer) { in UnregisterDataSource()
147 producer->service_endpoint->UnregisterDataSource(req.data_source_name()); in UnregisterDataSource()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | instruction_fusion.cc | 196 HloInstruction* producer, HloInstruction* consumer, in CanFuseOnAllPaths() argument
200 if (consumer == producer) { in CanFuseOnAllPaths()
206 auto cache_it = result_cache->find(std::make_pair(producer, consumer)); in CanFuseOnAllPaths()
215 if (!reachability_->IsReachable(producer, consumer_operand)) { in CanFuseOnAllPaths()
227 if (!CanFuseOnAllPaths(producer, consumer_operand, do_not_fuse, in CanFuseOnAllPaths()
233 result_cache->emplace(std::make_pair(producer, consumer), result); in CanFuseOnAllPaths()
253 for (HloInstruction* producer : consumer->operands()) { in ComputeGloballyUnfusible()
254 if (do_not_duplicate.count(producer) > 0) { in ComputeGloballyUnfusible()
263 if (EffectivelyAtMostUnary(producer)) { in ComputeGloballyUnfusible()
283 for (const HloInstruction* op : producer->operands()) { in ComputeGloballyUnfusible()
[all …]
|
| D | instruction_fusion.h | 83 virtual HloInstruction::FusionKind ChooseKind(const HloInstruction* producer,
87 virtual HloInstruction* Fuse(HloInstruction* producer,
94 virtual HloInstruction* FuseIntoMultiOutput(HloInstruction* producer,
105 bool FusionWouldDuplicate(const HloInstruction& producer, in FusionWouldDuplicate() argument
107 return !(producer.users().size() == 1 && consumer.IsUserOf(&producer)); in FusionWouldDuplicate()
115 bool MultiOutputFusionCreatesCycle(HloInstruction* producer,
128 HloInstruction* AddFusionInstruction(HloInstruction* producer,
138 HloInstruction* producer, HloInstruction* consumer,
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
| D | cpu_instruction_fusion.cc | 58 bool CanBeOutputFused(const HloInstruction* producer, in CanBeOutputFused() argument
61 IsNonComplexMatrixVectorDot(producer) && in CanBeOutputFused()
62 HasExactlyOneUse(*producer) == 1; in CanBeOutputFused()
74 HloInstruction* producer = consumer->mutable_operand(operand_index); in ShouldFuse() local
80 if (CanBeOutputFused(producer, consumer)) { in ShouldFuse()
84 if (CanBeOutputFusedIntoSomeOperand(producer)) { in ShouldFuse()
88 if (!CanBeLoopFused(*producer)) { in ShouldFuse()
95 if (producer->opcode() != HloOpcode::kFusion && in ShouldFuse()
97 is_expensive(*producer)) { in ShouldFuse()
109 if (producer->opcode() == HloOpcode::kConstant && in ShouldFuse()
[all …]
|
| /external/swiftshader/third_party/llvm-7.0/llvm/test/DebugInfo/Generic/ |
| D | debug-names-many-cu.ll | 74 !12 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
80 !22 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
86 !32 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
92 !42 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
98 !52 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
104 !62 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
110 !72 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
116 !82 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
122 !92 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (trun…
128 !102 = distinct !DICompileUnit(language: DW_LANG_C99, file: !3, producer: "clang version 7.0.0 (tru…
[all …]
|
| /external/toolchain-utils/debug_info_test/ |
| D | check_cus.py | 12 def check_compile_unit(dso_path, producer, comp_path): argument
25 if not c(dso_path, producer, comp_path):
40 producer = ''
49 if producer:
50 failed = failed.union(check_compile_unit(dso_path, producer,
52 producer = ''
55 producer = l
60 if producer:
61 failed = failed.union(check_compile_unit(dso_path, producer, comp_path))
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| D | ProducerFactoryTest.java | 65 Producer<String> producer = in noArgMethod() local
68 assertThat(producer.get().get()).isEqualTo("str"); in noArgMethod()
80 Producer<String> producer = in singleArgMethod() local
83 assertThat(producer.get().isDone()).isFalse(); in singleArgMethod()
85 assertThat(producer.get().get()).isEqualTo("str with arg"); in singleArgMethod()
95 Producer<String> producer = in successMonitor() local
98 assertThat(producer.get().isDone()).isFalse(); in successMonitor()
106 assertThat(producer.get().isDone()).isFalse(); in successMonitor()
109 assertThat(producer.get().get()).isEqualTo("monkey"); in successMonitor()
122 Producer<String> producer = in failureMonitor() local
[all …]
|
| /external/dagger2/producers/src/test/java/dagger/producers/internal/ |
| D | SetOfProducedProducerTest.java | 40 Producer<Set<Produced<Integer>>> producer = in success() local
44 assertThat(producer.get().get()) in success()
55 Producer<Set<Produced<Integer>>> producer = in failure() local
59 assertThat(producer.get().get()) in failure()
66 Producer<Set<Produced<Integer>>> producer = in delegateSetNpe() local
68 Results<Integer> results = Results.create(producer.get().get()); in delegateSetNpe()
77 Producer<Set<Produced<Integer>>> producer = in oneOfDelegateSetNpe() local
81 Results<Integer> results = Results.create(producer.get().get()); in oneOfDelegateSetNpe()
90 Producer<Set<Produced<Integer>>> producer = in delegateElementNpe() local
93 Results<Integer> results = Results.create(producer.get().get()); in delegateElementNpe()
[all …]
|
| D | AbstractProducerTest.java | 67 Producer<Object> producer = new DelegateProducer<>(componentMonitorProvider, null); in get_nullPointerException() local
69 producer.get(); in get_nullPointerException()
76 Producer<Integer> producer = in get() local
85 assertThat(producer.get().get()).isEqualTo(0); in get()
86 assertThat(producer.get().get()).isEqualTo(0); in get()
87 assertThat(producer.get().get()).isEqualTo(0); in get()
93 Producer<Integer> producer = new DelegateProducer<>(componentMonitorProvider, delegateFuture); in monitor_success() local
95 ListenableFuture<Integer> future = producer.get(); in monitor_success()
107 Producer<Integer> producer = new DelegateProducer<>(componentMonitorProvider, delegateFuture); in monitor_failure() local
109 ListenableFuture<Integer> future = producer.get(); in monitor_failure()
|
| D | SetProducerTest.java | 37 Producer<Set<Integer>> producer = in success() local
41 assertThat(producer.get().get()).containsExactly(1, 2, 5, 7); in success()
45 Producer<Set<Integer>> producer = in delegateSetNpe() local
49 ListenableFuture<Set<Integer>> future = producer.get(); in delegateSetNpe()
59 Producer<Set<Integer>> producer = in delegateElementNpe() local
63 ListenableFuture<Set<Integer>> future = producer.get(); in delegateElementNpe()
|
| /external/mesa3d/src/compiler/nir/ |
| D | nir_linking_helpers.c | 132 nir_remove_unused_varyings(nir_shader *producer, nir_shader *consumer) in nir_remove_unused_varyings() argument
134 assert(producer->info.stage != MESA_SHADER_FRAGMENT); in nir_remove_unused_varyings()
140 nir_foreach_variable(var, &producer->outputs) { in nir_remove_unused_varyings()
143 get_variable_io_mask(var, producer->info.stage); in nir_remove_unused_varyings()
146 get_variable_io_mask(var, producer->info.stage); in nir_remove_unused_varyings()
164 if (producer->info.stage == MESA_SHADER_TESS_CTRL) in nir_remove_unused_varyings()
165 tcs_add_output_reads(producer, read, patches_read); in nir_remove_unused_varyings()
168 progress = remove_unused_io_vars(producer, &producer->outputs, read, in nir_remove_unused_varyings()
350 compact_components(nir_shader *producer, nir_shader *consumer, uint8_t *comps, in compact_components() argument
355 struct exec_list *output_list = &producer->outputs; in compact_components()
[all …]
|
| /external/skqp/src/gpu/ |
| D | SkGpuDevice_drawTexture.cpp | 73 static bool can_ignore_bilerp_constraint(const GrTextureProducer& producer, in can_ignore_bilerp_constraint() argument
160 void SkGpuDevice::drawTextureProducer(GrTextureProducer* producer, in drawTextureProducer() argument
171 auto proxy = producer->refTextureProxyForParams(GrSamplerState::ClampNearest(), nullptr); in drawTextureProducer()
176 producer->alphaType(), producer->colorSpace(), this->clip(), in drawTextureProducer()
189 const SkRect srcBounds = SkRect::MakeIWH(producer->width(), producer->height()); in drawTextureProducer()
227 this->drawTextureProducerImpl(producer, clippedSrcRect, clippedDstRect, constraint, viewMatrix, in drawTextureProducer()
231 void SkGpuDevice::drawTextureProducerImpl(GrTextureProducer* producer, in drawTextureProducerImpl() argument
249 bool canUseTextureCoordsAsLocalCoords = !use_shader(producer->isAlphaOnly(), paint) && !mf; in drawTextureProducerImpl()
274 if (can_ignore_bilerp_constraint(*producer, clippedSrcRect, combinedMatrix, in drawTextureProducerImpl()
290 auto fp = producer->createFragmentProcessor(*textureMatrix, clippedSrcRect, constraintMode, in drawTextureProducerImpl()
[all …]
|
| /external/perfetto/src/profiling/memory/ |
| D | main.cc | 130 HeapprofdProducer producer(HeapprofdMode::kChild, &task_runner); in StartChildHeapprofd() local
131 producer.SetTargetProcess(target_pid, target_cmdline, in StartChildHeapprofd()
133 producer.ConnectWithRetries(GetProducerSocket()); in StartChildHeapprofd()
134 producer.ScheduleActiveDataSourceWatchdog(); in StartChildHeapprofd()
146 HeapprofdProducer producer(HeapprofdMode::kCentral, &task_runner); in StartCentralHeapprofd() local
153 task_runner.AddFileDescriptorWatch(g_dump_evt->fd(), [&producer] { in StartCentralHeapprofd()
155 producer.DumpAll(); in StartCentralHeapprofd()
157 producer.ConnectWithRetries(GetProducerSocket()); in StartCentralHeapprofd()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | MessageDeframerTest.java | 99 private ArgumentCaptor<StreamListener.MessageProducer> producer = field in MessageDeframerTest.WithAndWithoutFullStreamCompressionTests
127 verify(listener).messagesAvailable(producer.capture()); in simplePayload()
128 assertEquals(Bytes.asList(new byte[]{3, 14}), bytes(producer.getValue().next())); in simplePayload()
138 verify(listener, times(2)).messagesAvailable(producer.capture()); in smallCombinedPayloads()
139 List<StreamListener.MessageProducer> streams = producer.getAllValues(); in smallCombinedPayloads()
153 verify(listener).messagesAvailable(producer.capture()); in endOfStreamWithPayloadShouldNotifyEndOfStream()
154 assertEquals(Bytes.asList(new byte[]{3}), bytes(producer.getValue().next())); in endOfStreamWithPayloadShouldNotifyEndOfStream()
209 verify(listener).messagesAvailable(producer.capture()); in payloadSplitBetweenBuffers()
211 Bytes.asList(new byte[]{3, 14, 1, 5, 9, 2, 6}), bytes(producer.getValue().next())); in payloadSplitBetweenBuffers()
234 verify(listener).messagesAvailable(producer.capture()); in frameHeaderSplitBetweenBuffers()
[all …]
|
| /external/webrtc/webrtc/test/fuzzers/ |
| D | producer_fec_fuzzer.cc | 19 ProducerFec producer(&fec); in FuzzOneInput() local
26 producer.SetFecParameters(¶ms, 0); in FuzzOneInput()
41 rtc::scoped_ptr<RedPacket> red_packet(producer.BuildRedPacket( in FuzzOneInput()
45 producer.AddRtpPacketAndGenerateFec(packet.get(), payload_size, in FuzzOneInput()
48 uint16_t num_fec_packets = producer.NumAvailableFecPackets(); in FuzzOneInput()
52 producer.GetFecPackets(kRedPayloadType, 99, 100, rtp_header_length); in FuzzOneInput()
|
| /external/mesa3d/src/compiler/glsl/ |
| D | link_interface_blocks.cpp | 157 interstage_match(struct gl_shader_program *prog, ir_variable *producer, in interstage_match() argument
161 if (consumer->get_interface_type() != producer->get_interface_type()) { in interstage_match()
172 producer->data.how_declared != ir_var_declared_implicitly) && in interstage_match()
174 producer->get_interface_type())) in interstage_match()
192 (producer->is_interface_instance() && in interstage_match()
193 producer->type->is_array())) { in interstage_match()
194 if (consumer_instance_type != producer->type) in interstage_match()
358 const gl_linked_shader *producer, in validate_interstage_inout_blocks() argument
363 const bool extra_array_level = (producer->Stage == MESA_SHADER_VERTEX && in validate_interstage_inout_blocks()
386 producer->symbols->get_interface("gl_PerVertex", in validate_interstage_inout_blocks()
[all …]
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | string_data_pipe_producer_unittest.cc | 85 std::unique_ptr<StringDataPipeProducer> producer, in WriteStringThenCloseProducer() argument
88 StringDataPipeProducer* raw_producer = producer.get(); in WriteStringThenCloseProducer()
91 base::BindOnce([](std::unique_ptr<StringDataPipeProducer> producer, in WriteStringThenCloseProducer()
93 std::move(producer))); in WriteStringThenCloseProducer()
97 std::unique_ptr<StringDataPipeProducer> producer, in WriteStringsThenCloseProducer() argument
100 StringDataPipeProducer* raw_producer = producer.get(); in WriteStringsThenCloseProducer()
105 [](std::unique_ptr<StringDataPipeProducer> producer, in WriteStringsThenCloseProducer()
111 std::move(producer), std::move(strings), in WriteStringsThenCloseProducer()
114 std::move(producer), std::move(strings), mode)); in WriteStringsThenCloseProducer()
|
| D | file_data_pipe_producer_unittest.cc | 103 std::unique_ptr<FileDataPipeProducer> producer, in WriteFromFileThenCloseWriter() argument
105 FileDataPipeProducer* raw_producer = producer.get(); in WriteFromFileThenCloseWriter()
108 base::BindOnce([](std::unique_ptr<FileDataPipeProducer> producer, in WriteFromFileThenCloseWriter()
110 std::move(producer))); in WriteFromFileThenCloseWriter()
114 std::unique_ptr<FileDataPipeProducer> producer, in WriteFromFileThenCloseWriter() argument
117 FileDataPipeProducer* raw_producer = producer.get(); in WriteFromFileThenCloseWriter()
120 base::BindOnce([](std::unique_ptr<FileDataPipeProducer> producer, in WriteFromFileThenCloseWriter()
122 std::move(producer))); in WriteFromFileThenCloseWriter()
126 std::unique_ptr<FileDataPipeProducer> producer, in WriteFromPathThenCloseWriter() argument
128 FileDataPipeProducer* raw_producer = producer.get(); in WriteFromPathThenCloseWriter()
[all …]
|
| /external/swiftshader/third_party/llvm-7.0/llvm/test/Assembler/ |
| D | dicompileunit.ll | 19 ; CHECK: !8 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang", isOptimiz…
20 !8 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang",
28 !9 = distinct !DICompileUnit(language: 12, file: !1, producer: "",
32 ; CHECK: !10 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang", isOptimi…
33 !10 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang",
|
| /external/llvm/test/Assembler/ |
| D | dicompileunit.ll | 19 ; CHECK: !8 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang", isOptimiz…
20 !8 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang",
28 !9 = distinct !DICompileUnit(language: 12, file: !1, producer: "",
32 ; CHECK: !10 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang", isOptimi…
33 !10 = distinct !DICompileUnit(language: DW_LANG_C99, file: !1, producer: "clang",
|
| /external/perfetto/docs/ |
| D | architecture.md | 5  from
27 consumer(s). A producer knows nothing about:
30 - How many other producer(s) are registered or active.
31 - Trace data written by other producer(s).
34 In rare circumstances a process can host more than one producer and hence more
70 for in-process heap profiling. In such case more than one producer, linking
[all …]
|