/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...] |
/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...] |
ProducersTest.java | 22 import dagger.producers.Producer; 100 Producer<Integer> producer = Producers.producerFromProvider(new Provider<Integer>() { local 107 assertThat(producer.get().get()).isEqualTo(0); 108 assertThat(producer.get().get()).isEqualTo(0); 109 assertThat(producer.get().get()).isEqualTo(0);
|
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/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
|
/external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sem_init/ |
3-1.c | 34 void *producer(void *); 47 if (pthread_create(&prod, NULL, producer, (void *)cnt) != 0) { 68 void *producer(void *arg) function
|
/external/perfetto/src/traced/probes/ |
probes.cc | 71 ProbesProducer producer; local 72 producer.ConnectWithRetries(GetProducerSocket(), &task_runner);
|
/external/perfetto/test/cts/producer/src/android/perfetto/producer/ |
ProducerActivity.java | 17 package android.perfetto.producer;
|
ProducerIsolatedService.java | 17 package android.perfetto.producer;
|
ProducerService.java | 17 package android.perfetto.producer;
|
/external/perfetto/test/ |
task_runner_thread_delegates.h | 78 FakeProducer* producer() { return producer_.get(); } function in class:perfetto::FakeProducerDelegate
|
/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...] |
/frameworks/base/native/android/ |
surface_texture.cpp | 33 sp<IGraphicBufferProducer> producer; member in struct:ASurfaceTexture 42 ast->producer = SurfaceTexture_getProducer(env, surfacetexture); 47 sp<Surface> surface = new Surface(st->producer);
|
/frameworks/native/libs/gui/tests/ |
SurfaceTextureGL.h | 40 sp<IGraphicBufferProducer> producer; local 41 BufferQueue::createBufferQueue(&producer, &mConsumer); 44 mSTC = new Surface(producer);
|
Malicious.cpp | 30 ProxyBQP(const sp<IGraphicBufferProducer>& producer) : mProducer(producer) {} 105 MaliciousBQP(const sp<IGraphicBufferProducer>& producer) : ProxyBQP(producer) {} 140 sp<IGraphicBufferProducer> producer; local 142 BufferQueue::createBufferQueue(&producer, &consumer); 146 sp<MaliciousBQP> malicious = new MaliciousBQP(producer);
|
MultiTextureConsumer_test.cpp | 37 sp<IGraphicBufferProducer> producer; local 39 BufferQueue::createBufferQueue(&producer, &consumer); 42 mSurface = new Surface(producer);
|
/frameworks/native/opengl/tools/glgen/stubs/egl/ |
eglCreateWindowSurface.cpp | 89 android::sp<android::IGraphicBufferProducer> producer; local 110 producer = android::SurfaceTexture_getProducer(_env, win); 112 if (producer == NULL) 115 window = new android::Surface(producer, true);
|
/frameworks/native/libs/gui/ |
BufferQueue.cpp | 97 sp<IGraphicBufferProducer> producer(new BufferQueueProducer(core, consumerIsSurfaceFlinger)); 98 LOG_ALWAYS_FATAL_IF(producer == NULL, 105 *outProducer = producer; 115 sp<IGraphicBufferProducer> producer; local 126 producer = BufferHubProducer::Create(producerQueue); 129 LOG_ALWAYS_FATAL_IF(producer == NULL, "BufferQueue: failed to create BufferQueueProducer"); 132 *outProducer = producer;
|
/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...] |
/cts/tests/tests/uirendering/src/android/uirendering/cts/testclasses/ |
TextureViewTests.java | 97 Surface producer = new Surface(texture); local 98 Canvas canvas = producer.lockCanvas(null); 100 producer.unlockCanvasAndPost(canvas);
|
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/metaclasses/ |
Synch.py | 211 def producer(buffer, wait, n=1000):
function in function:_test 218 print "Producer: done producing", n, "items"
247 thread.start_new_thread(producer, (buffer, pwait, n))
249 print "Producer done"
|
/external/ltp/testcases/open_posix_testsuite/functional/semaphores/ |
sem_conpro.c | 9 * This is a test about producer and consumer. Producer sends data 38 int *producer(buf_t * buf) function 54 printf("producer has added %d to the buffer[%d] \n", data, in); 125 pthread_create(&pro, NULL, (void *)producer, &buf);
|
/external/ltp/testcases/open_posix_testsuite/stress/semaphores/ |
multi_con_pro.c | 40 int *producer(void *ID) function 47 printf("Enter into Producer Thread %d... \n", ThreadID); 64 printf("[%d] producer has added %d to the buffer[%d] \n", 91 printf("[%d] producer has added %d to the buffer[%d] \n", ThreadID, 102 printf("Producer %d exit... \n", ThreadID); 201 pthread_create(&pro[i], NULL, (void *)producer,
|