| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| instruction_fusion.cc | 47 HloInstruction* producer = consumer->mutable_operand(operand_index); local
50 if (producer->opcode() == HloOpcode::kFusion) {
55 if (producer->opcode() == HloOpcode::kRng) {
61 if (IsReductionToVector(*producer)) {
68 if (producer->CouldBeBitcast() &&
69 ImplementedAsLibraryCall(*producer->operand(0))) {
80 !producer->IsElementwise()) {
86 if (producer->opcode() != HloOpcode::kFusion &&
88 is_expensive(*producer)) {
92 return IsFusile(*producer) && IsFusile(*consumer) &
[all...] |
| instruction_fusion.h | 33 const HloInstruction* producer, const HloInstruction* consumer) override;
|
| /frameworks/native/services/vr/bufferhubd/ |
| consumer_channel.cpp | 23 const std::shared_ptr<Channel> producer)
26 producer_(producer) {
35 if (auto producer = GetProducer()) {
36 producer->RemoveConsumer(this);
42 if (auto producer = GetProducer()) {
43 // If producer has not hung up, copy most buffer info from the producer.
44 info = producer->GetBufferInfo();
70 auto producer = GetProducer(); local
71 if (!producer)
118 auto producer = GetProducer(); local
142 auto producer = GetProducer(); local
167 auto producer = GetProducer(); local
[all...] |
| consumer_queue_channel.cpp | 18 const std::shared_ptr<Channel>& producer, bool silent)
20 producer_(producer),
30 if (auto producer = GetProducer()) {
31 producer->RemoveConsumer(this);
37 auto producer = GetProducer(); local
38 if (!producer) {
46 *producer, &ProducerQueueChannel::OnCreateConsumerQueue, message);
51 *producer, &ProducerQueueChannel::OnGetQueueInfo, message);
75 if (auto producer = GetProducer()) {
76 // If producer has not hung up, copy most buffer info from the producer
[all...] |
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
| cpu_instruction_fusion.cc | 51 bool CanBeOutputFused(const HloInstruction* producer,
53 return consumer->opcode() == HloOpcode::kAdd && IsMatrixVectorDot(producer) &&
54 producer->user_count() == 1;
66 HloInstruction* producer = consumer->mutable_operand(operand_index); local
72 if (CanBeOutputFused(producer, consumer)) {
76 if (CanBeOutputFusedIntoSomeOperand(producer)) {
80 if (!CanBeLoopFused(*producer)) {
81 VLOG(2) << "Producer is not fusile.";
87 if (producer->opcode() != HloOpcode::kFusion &&
89 is_expensive(*producer)) {
[all...] |
| cpu_instruction_fusion.h | 34 const HloInstruction* producer, const HloInstruction* consumer) override;
|
| /external/perfetto/src/tracing/core/ |
| service_impl_unittest.cc | 29 #include "perfetto/tracing/core/producer.h"
131 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
132 producer->Connect(svc.get(), "mock_producer");
133 producer->RegisterDataSource("data_source");
141 producer->WaitForTracingSetup();
142 producer->WaitForDataSourceStart("data_source");
145 producer->WaitForDataSourceStop("data_source");
153 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
154 producer->Connect(svc.get(), "mock_producer_sameuid", geteuid());
155 producer->RegisterDataSource("data_source")
197 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
220 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
274 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
360 std::unique_ptr<MockProducer> producer[kNumProducers]; local
399 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
436 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
475 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/filtershow/pipeline/ |
| SharedBuffer.java | 32 public synchronized void setProducer(Bitmap producer) {
34 && !mProducer.isSameSize(producer)) {
39 mProducer = new Buffer(producer);
41 mProducer.useBitmap(producer);
|
| /external/perfetto/test/cts/producer/jni/ |
| fake_producer_jni.cc | 30 FakeProducer producer(name);
31 producer.Connect(GetProducerSocket(), &task_runner, [] {});
|
| /hardware/google/av/codec2/include/ |
| C2BufferBase.h | 81 /** Create a usage from separate consumer and producer usage mask. \deprecated */
82 inline C2MemoryUsage(uint64_t consumer, uint64_t producer)
83 : expected(consumer | producer) { }
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| instruction_fusion.h | 51 // Returns whether the given producer instruction should be fused into the
52 // given consumer instruction. producer is necessarily an operand of consumer.
55 // producer is.
59 // the operand is 'producer' and the instruction is 'consumer')
64 // Chooses a fusion kind for `producer` and `consumer`.
66 virtual HloInstruction::FusionKind ChooseKind(const HloInstruction* producer,
69 // Fuses producer into consumer.
70 virtual HloInstruction* Fuse(HloInstruction* producer,
79 // Returns true if fusing producer into consumer would cause producer to b
[all...] |
| instruction_fusion.cc | 158 const HloReachabilityMap& reachability_map, HloInstruction* producer,
161 // First check to see if we have already marked this producer as infeasible
163 if (do_not_fuse->count(producer) > 0) {
166 // Make sure it is possible for producer and consumer to exist in a fusion
168 if (!producer->IsFusable() || !consumer->IsFusable()) {
172 // lead to producer to find any unfusable paths.
175 if (consumer_operand == producer) {
181 } else if (reachability_map.IsReachable(producer, consumer_operand)) {
183 // path to producer. We need to further investigate from
186 // First check if we have already ruled out fusing producer int
[all...] |
| /external/webrtc/webrtc/test/fuzzers/ |
| producer_fec_fuzzer.cc | 19 ProducerFec producer(&fec);
26 producer.SetFecParameters(¶ms, 0);
41 rtc::scoped_ptr<RedPacket> red_packet(producer.BuildRedPacket(
45 producer.AddRtpPacketAndGenerateFec(packet.get(), payload_size,
48 uint16_t num_fec_packets = producer.NumAvailableFecPackets();
52 producer.GetFecPackets(kRedPayloadType, 99, 100, rtp_header_length);
|
| /frameworks/native/libs/gui/tests/ |
| SurfaceTextureGL.h | 40 sp<IGraphicBufferProducer> producer; local
41 BufferQueue::createBufferQueue(&producer, &mConsumer);
44 mSTC = new Surface(producer);
|
| /external/dagger2/producers/src/test/java/dagger/producers/internal/ |
| SetProducerTest.java | 20 import dagger.producers.Producer;
37 Producer<Set<Integer>> producer = local
41 assertThat(producer.get().get()).containsExactly(1, 2, 5, 7);
45 Producer<Set<Integer>> producer = local
49 ListenableFuture<Set<Integer>> future = producer.get();
59 Producer<Set<Integer>> producer = local
63 ListenableFuture<Set<Integer>> future = producer.get()
[all...] |
| AbstractProducerTest.java | 21 import dagger.producers.Producer;
67 Producer<Object> producer = new DelegateProducer<>(componentMonitorProvider, null); local
69 producer.get();
76 Producer<Integer> producer = local
85 assertThat(producer.get().get()).isEqualTo(0);
86 assertThat(producer.get().get()).isEqualTo(0);
87 assertThat(producer.get().get()).isEqualTo(0);
93 Producer<Integer> producer = new DelegateProducer<>(componentMonitorProvider, delegateFuture) local
107 Producer<Integer> producer = new DelegateProducer<>(componentMonitorProvider, delegateFuture); local
[all...] |
| SetOfProducedProducerTest.java | 22 import dagger.producers.Producer;
40 Producer<Set<Produced<Integer>>> producer = local
44 assertThat(producer.get().get())
55 Producer<Set<Produced<Integer>>> producer = local
59 assertThat(producer.get().get())
66 Producer<Set<Produced<Integer>>> producer = local
68 Results<Integer> results = Results.create(producer.get().get())
77 Producer<Set<Produced<Integer>>> producer = local
90 Producer<Set<Produced<Integer>>> producer = local
102 Producer<Set<Produced<Integer>>> producer = local
[all...] |
| /external/tensorflow/tensorflow/core/framework/ |
| versions.cc | 32 if (versions.producer() < min_producer) {
34 upper_name, " producer version ", versions.producer(),
35 " below min producer ", min_producer, " supported by TensorFlow ",
|
| /external/tensorflow/tensorflow/core/graph/ |
| graph_def_builder_test.cc | 39 ASSERT_EQ(graph.versions().producer(), TF_GRAPH_DEF_VERSION);
45 ASSERT_EQ(graph_def.versions().producer(), TF_GRAPH_DEF_VERSION);
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| ProducerFactoryTest.java | 21 import dagger.producers.Producer;
65 Producer<String> producer = local
68 assertThat(producer.get().get()).isEqualTo("str");
79 Producer<Integer> intProducer = producerOfFuture(intFuture);
80 Producer<String> producer = local
83 assertThat(producer.get().isDone()).isFalse();
85 assertThat(producer.get().get()).isEqualTo("str with arg");
94 Producer<SettableFuture<String>> strFutureProducer = producerOfFuture(strFutureFuture)
95 Producer<String> producer = local
122 Producer<String> producer = local
152 Producer<String> producer = local
[all...] |
| /external/perfetto/src/tracing/ipc/service/ |
| producer_ipc_service.cc | 30 // The remote Producer(s) are not trusted. All the methods from the ProducerPort
31 // IPC layer (e.g. RegisterDataSource()) must assume that the remote Producer is
51 // Called by the remote Producer through the IPC channel soon after connecting.
61 "The remote Producer is trying to re-initialize the connection");
66 std::unique_ptr<RemoteProducer> producer(new RemoteProducer());
69 producer->service_endpoint = core_service_->ConnectProducer(
70 producer.get(), client_info.uid(), req.producer_name(),
74 if (!producer->service_endpoint)
77 producers_.emplace(ipc_client_id, std::move(producer));
78 // Because of the std::move() |producer| is invalid after this point
89 RemoteProducer* producer = GetProducerForCurrentRequest(); local
120 RemoteProducer* producer = GetProducerForCurrentRequest(); local
136 RemoteProducer* producer = GetProducerForCurrentRequest(); local
165 RemoteProducer* producer = GetProducerForCurrentRequest(); local
[all...] |
| /frameworks/base/libs/hwui/tests/common/ |
| TestContext.cpp | 89 sp<IGraphicBufferProducer> producer; local
91 BufferQueue::createBufferQueue(&producer, &consumer);
92 producer->setMaxDequeuedBufferCount(3);
93 producer->setAsyncMode(true);
96 mSurface = new Surface(producer);
108 // We assume the producer is internally ordered enough such that
|
| /external/perfetto/src/traced/probes/ |
| probes.cc | 71 ProbesProducer producer; local
72 producer.ConnectWithRetries(GetProducerSocket(), &task_runner);
|
| /hardware/google/av/codec2/vndk/include/ |
| C2BqBufferPriv.h | 46 typedef std::function<void(uint64_t producer, int32_t slot, int64_t nsecs)> OnRenderCallback;
60 * Since zero is not used for Unique Id of IGBP, if IGBP is not configured or producer
63 * \param producer the IGBP, which will be used to fetch blocks
65 virtual void configureProducer(const android::sp<android::HGraphicBufferProducer> &producer);
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sem_destroy/ |
| 3-1.c | 34 void *producer(void *);
47 if (pthread_create(&prod, NULL, producer, (void *)cnt) != 0) {
68 void *producer(void *arg) function
|
