Home
last modified time | relevance | path

Searched refs:producer (Results 1 – 25 of 1985) sorted by relevance

12345678910>>...80

/external/perfetto/src/tracing/core/
Dtracing_service_impl_unittest.cc296 std::unique_ptr<MockProducer> producer = CreateMockProducer(); in TEST_F() local
297 producer->Connect(svc.get(), "mock_producer"); in TEST_F()
298 producer->RegisterDataSource("data_source"); in TEST_F()
308 producer->WaitForTracingSetup(); in TEST_F()
309 producer->WaitForDataSourceSetup("data_source"); in TEST_F()
310 producer->WaitForDataSourceStart("data_source"); in TEST_F()
317 producer->WaitForDataSourceStop("data_source"); in TEST_F()
327 std::unique_ptr<MockProducer> producer = CreateMockProducer(); in TEST_F() local
328 producer->Connect(svc.get(), "mock_producer"); in TEST_F()
331 producer->RegisterDataSource("ds_1"); in TEST_F()
[all …]
Dtracing_service_impl.cc274 TracingServiceImpl::ConnectProducer(Producer* producer, in ConnectProducer() argument
310 id, uid, this, task_runner_, producer, producer_name, in_process, in ConnectProducer()
358 if (auto* producer = GetProducer(id)) { in DisconnectProducer() local
360 ScrapeSharedMemoryBuffers(&session_id_and_session.second, producer); in DisconnectProducer()
843 ProducerEndpointImpl* producer = GetProducer(it->second.producer_id); in ChangeTraceConfig() local
844 PERFETTO_DCHECK(producer); in ChangeTraceConfig()
849 if (!NameMatchesFilter(producer->name_, new_producer_name_filter, in ChangeTraceConfig()
873 if (producer->name_ == config.producer_name()) { in ChangeTraceConfig()
883 StartDataSourceInstance(producer, tracing_session, ds_inst); in ChangeTraceConfig()
968 ProducerEndpointImpl* producer = GetProducer(producer_id); in StartTracing() local
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dmulti_output_fusion.cc121 const HloInstruction* producer, const HloReachabilityMap& reachability) { in GetProducerConsumerMultiOutputFusionCandidates() argument
123 for (HloInstruction* consumer : producer->users()) { in GetProducerConsumerMultiOutputFusionCandidates()
124 VLOG(3) << "Looking at producer " << producer->name() in GetProducerConsumerMultiOutputFusionCandidates()
131 if (!IsProducerConsumerMultiOutputFusible(*producer, *consumer)) { in GetProducerConsumerMultiOutputFusionCandidates()
132 VLOG(3) << producer->name() << " and " << consumer->name() in GetProducerConsumerMultiOutputFusionCandidates()
146 CHECK(reachability.IsPresent(operand) && reachability.IsPresent(producer)) in GetProducerConsumerMultiOutputFusionCandidates()
149 return producer != operand && reachability.IsReachable(producer, operand); in GetProducerConsumerMultiOutputFusionCandidates()
152 VLOG(3) << producer->name() << " would introduce a cycle when fused."; in GetProducerConsumerMultiOutputFusionCandidates()
155 if (FusionWouldBeTooLarge(*producer, *consumer)) { in GetProducerConsumerMultiOutputFusionCandidates()
156 VLOG(3) << producer->name() << " and " << consumer->name() in GetProducerConsumerMultiOutputFusionCandidates()
[all …]
Dinstruction_fusion.cc44 HloInstruction* producer = consumer->mutable_operand(operand_index); in ShouldFuseInexpensiveChecks() local
47 if (producer->opcode() == HloOpcode::kFusion) { in ShouldFuseInexpensiveChecks()
52 if (producer->opcode() != HloOpcode::kFusion && in ShouldFuseInexpensiveChecks()
54 is_expensive(*producer)) { in ShouldFuseInexpensiveChecks()
58 if (!IsProducerConsumerFusible(*producer, *consumer) || in ShouldFuseInexpensiveChecks()
70 auto producer = consumer->operand(operand_index); in ShouldFuse() local
73 if (FusionWouldBeTooLarge(*consumer, *producer)) { in ShouldFuse()
92 producer); in ShouldFuse()
101 const HloInstruction* producer, const HloInstruction* consumer) { in ChooseKind() argument
102 return ChooseFusionKind(*producer, *consumer); in ChooseKind()
[all …]
Dgpu_fusible.cc65 bool LayoutsAreReduceInputFusionFriendly(const HloInstruction& producer, in LayoutsAreReduceInputFusionFriendly() argument
68 AppendParams(producer, &params); in LayoutsAreReduceInputFusionFriendly()
218 bool IsProducerConsumerFusible(const HloInstruction& producer, in IsProducerConsumerFusible() argument
220 if (!IsLoopFusible(producer) || !IsFusible(consumer)) { in IsProducerConsumerFusible()
224 if (producer.IsMultiOutputFusion()) { in IsProducerConsumerFusible()
227 if (CreatesNestedLoop(producer, consumer)) { in IsProducerConsumerFusible()
233 !LayoutsAreReduceInputFusionFriendly(producer, consumer)) { in IsProducerConsumerFusible()
239 if (producer.CouldBeBitcast() && in IsProducerConsumerFusible()
240 ImplementedAsLibraryCall(*producer.operand(0))) { in IsProducerConsumerFusible()
251 if (producer.opcode() == HloOpcode::kConstant) { in IsProducerConsumerFusible()
[all …]
Dgpu_fusible_test.cc744 const HloInstruction* producer = root->operand(1); in TEST_F() local
745 EXPECT_TRUE(IsProducerConsumerMultiOutputFusible(*producer, *consumer)); in TEST_F()
768 const HloInstruction* producer = root->operand(1); in TEST_F() local
769 EXPECT_TRUE(IsProducerConsumerMultiOutputFusible(*producer, *consumer)); in TEST_F()
807 const HloInstruction* producer = root->operand(1); in TEST_F() local
808 EXPECT_TRUE(IsProducerConsumerMultiOutputFusible(*producer, *consumer)); in TEST_F()
839 const HloInstruction* producer = root->operand(1); in TEST_F() local
841 EXPECT_FALSE(IsProducerConsumerMultiOutputFusible(*producer, *consumer)); in TEST_F()
871 const HloInstruction* producer = root->operand(1); in TEST_F() local
872 EXPECT_FALSE(IsProducerConsumerMultiOutputFusible(*producer, *consumer)); in TEST_F()
[all …]
Dgpu_fusible.h44 bool LayoutsAreReduceInputFusionFriendly(const HloInstruction& producer,
72 bool CreatesNestedLoop(const HloInstruction& producer,
88 bool IsProducerConsumerFusible(const HloInstruction& producer,
94 bool IsProducerConsumerMultiOutputFusible(const HloInstruction& producer,
101 HloInstruction::FusionKind ChooseFusionKind(const HloInstruction& producer,
/external/perfetto/src/tracing/ipc/service/
Dproducer_ipc_service.cc67 std::unique_ptr<RemoteProducer> producer(new RemoteProducer()); in InitializeConnection() local
118 producer->service_endpoint = core_service_->ConnectProducer( in InitializeConnection()
119 producer.get(), client_info.uid(), req.producer_name(), in InitializeConnection()
125 if (!producer->service_endpoint) { in InitializeConnection()
131 producer->service_endpoint->IsShmemProvidedByProducer(); in InitializeConnection()
133 producers_.emplace(ipc_client_id, std::move(producer)); in InitializeConnection()
146 RemoteProducer* producer = GetProducerForCurrentRequest(); in RegisterDataSource() local
147 if (!producer) { in RegisterDataSource()
180 RemoteProducer* producer = GetProducerForCurrentRequest(); in UnregisterDataSource() local
181 if (!producer) { in UnregisterDataSource()
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/cpu/
Dcpu_instruction_fusion.cc57 bool CanBeOutputFused(const HloInstruction* producer, in CanBeOutputFused() argument
60 IsNonComplexNonBatchedMatrixVectorDot(producer) && in CanBeOutputFused()
61 HasExactlyOneUse(*producer) == 1; in CanBeOutputFused()
73 HloInstruction* producer = consumer->mutable_operand(operand_index); in ShouldFuse() local
79 if (CanBeOutputFused(producer, consumer)) { in ShouldFuse()
84 if (CanBeOutputFusedIntoSomeOperand(producer)) { in ShouldFuse()
90 if (!CanBeLoopFused(*producer)) { in ShouldFuse()
97 if (producer->opcode() != HloOpcode::kFusion && in ShouldFuse()
99 is_expensive(*producer)) { in ShouldFuse()
111 if (producer->opcode() == HloOpcode::kConstant && in ShouldFuse()
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/
Dinstruction_fusion.cc217 HloInstruction* producer, HloInstruction* consumer, in CanFuseOnAllPaths() argument
221 if (consumer == producer) { in CanFuseOnAllPaths()
227 auto cache_it = result_cache->find(std::make_pair(producer, consumer)); in CanFuseOnAllPaths()
236 if (!reachability_->IsReachable(producer, consumer_operand)) { in CanFuseOnAllPaths()
248 if (!CanFuseOnAllPaths(producer, consumer_operand, do_not_fuse, in CanFuseOnAllPaths()
254 result_cache->emplace(std::make_pair(producer, consumer), result); in CanFuseOnAllPaths()
274 HloInstruction* producer = *it; in ComputeGloballyUnfusible() local
280 if (EffectivelyAtMostUnary(producer)) { in ComputeGloballyUnfusible()
299 for (const HloInstruction* op : producer->unique_operands()) { in ComputeGloballyUnfusible()
302 if (operands_size <= total_size(producer->shape())) { in ComputeGloballyUnfusible()
[all …]
Dinstruction_fusion.h90 virtual HloInstruction::FusionKind ChooseKind(const HloInstruction* producer,
97 HloInstruction* producer);
100 virtual HloInstruction* Fuse(HloInstruction* producer,
107 virtual HloInstruction* FuseIntoMultiOutput(HloInstruction* producer,
118 bool FusionWouldDuplicate(const HloInstruction& producer, in FusionWouldDuplicate() argument
120 return !(producer.users().size() == 1 && consumer.IsUserOf(&producer)); in FusionWouldDuplicate()
128 bool MultiOutputFusionCreatesCycle(HloInstruction* producer,
145 HloInstruction* AddFusionInstruction(HloInstruction* producer,
155 HloInstruction* producer, HloInstruction* consumer,
Dfusion_node_indexing_evaluation.cc38 const HloInstruction* producer) const { in AverageCodeDuplicationTooHigh()
49 return EvaluateTotalEmittedInstructions(producer) / in AverageCodeDuplicationTooHigh()
55 const HloInstruction* producer) const { in EvaluateTotalEmittedInstructions()
57 for (const auto* user : indexing_users_.at(producer)) { in EvaluateTotalEmittedInstructions()
64 const HloInstruction* producer, in UpdateEvaluationCache() argument
66 CHECK(!indexing_users_.contains(producer)); in UpdateEvaluationCache()
67 indexing_users_[producer] = std::move(indexing_users_of_producer); in UpdateEvaluationCache()
68 UpdateIndexUsageCount(producer); in UpdateEvaluationCache()
69 UpdateIndexingUsersOfOperands(producer); in UpdateEvaluationCache()
/external/toolchain-utils/debug_info_test/
Dcheck_cus.py18 def check_compile_unit(dso_path, producer, comp_path): argument
31 if not c(dso_path, producer, comp_path):
48 producer = ''
58 if producer:
59 failed = failed.union(check_compile_unit(dso_path, producer, comp_path))
60 producer = ''
63 producer = l
68 if producer:
69 failed = failed.union(check_compile_unit(dso_path, producer, comp_path))
/external/swiftshader/third_party/llvm-7.0/llvm/test/DebugInfo/Generic/
Ddebug-names-many-cu.ll74 !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/dagger2/javatests/dagger/functional/producers/
DProducerFactoryTest.java78 Producer<String> producer = in noArgMethod() local
80 assertThat(producer.get().get()).isEqualTo("str"); in noArgMethod()
93 Producer<String> producer = in singleArgMethod() local
96 assertThat(producer.get().isDone()).isFalse(); in singleArgMethod()
98 assertThat(producer.get().get()).isEqualTo("str with arg"); in singleArgMethod()
110 Producer<String> producer = in successMonitor() local
113 assertThat(producer.get().isDone()).isFalse(); in successMonitor()
121 assertThat(producer.get().isDone()).isFalse(); in successMonitor()
124 assertThat(producer.get().get()).isEqualTo("monkey"); in successMonitor()
139 Producer<String> producer = in failureMonitor() local
[all …]
/external/dagger2/java/dagger/producers/internal/
DProducers.java166 public static <T> Producer<T> nonCancellationPropagatingViewOf(Producer<T> producer) {
169 if (producer instanceof CancellableProducer) {
170 return ((CancellableProducer<T>) producer).newDependencyView();
173 "nonCancellationPropagatingViewOf called with non-CancellableProducer: " + producer);
184 Producer<T> producer, CancellationListener cancellationListener) {
187 if (producer instanceof CancellableProducer) {
188 return ((CancellableProducer<T>) producer).newEntryPointView(cancellationListener);
191 "entryPointViewOf called with non-CancellableProducer: " + producer);
199 public static void cancel(Producer<?> producer, boolean mayInterruptIfRunning) {
202 if (producer instanceof CancellableProducer) {
[all …]
/external/dagger2/javatests/dagger/producers/internal/
DSetOfProducedProducerTest.java42 Producer<Set<Produced<Integer>>> producer = in success() local
47 assertThat(producer.get().get()) in success()
57 Producer<Set<Produced<Integer>>> producer = in failure() local
62 assertThat(producer.get().get()) in failure()
69 Producer<Set<Produced<Integer>>> producer = in delegateNpe() local
73 Results<Integer> results = Results.create(producer.get().get()); in delegateNpe()
83 Producer<Set<Produced<Integer>>> producer = in delegateSetNpe() local
87 Results<Integer> results = Results.create(producer.get().get()); in delegateSetNpe()
97 Producer<Set<Produced<Integer>>> producer = in delegateElementNpe() local
102 Results<Integer> results = Results.create(producer.get().get()); in delegateElementNpe()
[all …]
DSetProducerTest.java40 Producer<Set<Integer>> producer = in success() local
45 assertThat(producer.get().get()).containsExactly(1, 5, 7); in success()
50 Producer<Set<Integer>> producer = in delegateNpe() local
54 ListenableFuture<Set<Integer>> future = producer.get(); in delegateNpe()
65 Producer<Set<Integer>> producer = in delegateSetNpe() local
69 ListenableFuture<Set<Integer>> future = producer.get(); in delegateSetNpe()
80 Producer<Set<Integer>> producer = in delegateElementNpe() local
86 ListenableFuture<Set<Integer>> future = producer.get(); in delegateElementNpe()
DAbstractProducerTest.java37 Producer<Object> producer = new DelegateProducer<>(null); in get_nullPointerException() local
39 producer.get(); in get_nullPointerException()
46 Producer<Integer> producer = in get() local
55 assertThat(producer.get().get()).isEqualTo(0); in get()
56 assertThat(producer.get().get()).isEqualTo(0); in get()
57 assertThat(producer.get().get()).isEqualTo(0); in get()
/external/perfetto/src/profiling/memory/
Dmain.cc143 HeapprofdProducer producer(HeapprofdMode::kChild, &task_runner); in StartChildHeapprofd() local
144 producer.SetTargetProcess(target_pid, target_cmdline, in StartChildHeapprofd()
146 producer.ConnectWithRetries(GetProducerSocket()); in StartChildHeapprofd()
147 producer.ScheduleActiveDataSourceWatchdog(); in StartChildHeapprofd()
159 HeapprofdProducer producer(HeapprofdMode::kCentral, &task_runner); in StartCentralHeapprofd() local
163 base::ScopedFile(listening_raw_socket), &producer.socket_delegate(), in StartCentralHeapprofd()
171 task_runner.AddFileDescriptorWatch(g_dump_evt->fd(), [&producer] { in StartCentralHeapprofd()
173 producer.DumpAll(); in StartCentralHeapprofd()
175 producer.ConnectWithRetries(GetProducerSocket()); in StartCentralHeapprofd()
/external/skqp/src/gpu/
DSkGpuDevice_drawTexture.cpp73 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/tensorflow/tensorflow/lite/delegates/gpu/common/
Dmodel.h129 virtual Status SetProducer(NodeId producer, ValueId value) = 0;
180 [](const ValueDef& v) { return v.producer == nullptr; }); in inputs()
191 return values_[id].producer == nullptr; in IsGraphInput()
251 return values_[id].producer; in FindProducer()
261 Status SetProducer(NodeId producer, ValueId value) final { in SetProducer() argument
266 RETURN_IF_ERROR(LookupNode(producer, &n)); in SetProducer()
270 if (node_ptr == v->producer) { in SetProducer()
275 if (IsInput(producer, value)) { in SetProducer()
280 if (v->producer != nullptr) { in SetProducer()
282 Erase(&nodes_[v->producer->id].outputs, value_ptr); in SetProducer()
[all …]
/external/webrtc/webrtc/test/fuzzers/
Dproducer_fec_fuzzer.cc19 ProducerFec producer(&fec); in FuzzOneInput() local
26 producer.SetFecParameters(&params, 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/dagger2/javatests/dagger/functional/producers/provisions/
DProvisions.java35 final Producer<T> producer; field in Provisions.WrappedProducer
37 WrappedProducer(Producer<T> producer) { in WrappedProducer() argument
38 this.producer = producer; in WrappedProducer()
70 return new Output(producer1.producer, producer2.producer); in output()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DMessageDeframerTest.java99 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 …]

12345678910>>...80