/external/perfetto/test/cts/producer/src/android/perfetto/producer/ |
H A D | ProducerActivity.java | 17 package android.perfetto.producer;
|
H A D | ProducerIsolatedService.java | 17 package android.perfetto.producer;
|
H A D | ProducerService.java | 17 package android.perfetto.producer;
|
/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
H A D | 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) 96 ChooseKind( const HloInstruction* producer, const HloInstruction* consumer) argument [all...] |
/external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sem_destroy/ |
H A D | 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/ |
H A D | 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/ |
H A D | probes.cc | 71 ProbesProducer producer; local 72 producer.ConnectWithRetries(GetProducerSocket(), &task_runner);
|
/external/perfetto/test/ |
H A D | task_runner_thread_delegates.h | 78 FakeProducer* producer() { return producer_.get(); } function in class:perfetto::FakeProducerDelegate
|
H A D | end_to_end_benchmark.cc | 45 FakeProducer* producer = helper.ConnectFakeProducer(); local 80 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed));
|
/external/tensorflow/tensorflow/compiler/xla/service/ |
H A D | 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 t 81 FusionWouldDuplicate(const HloInstruction& producer, const HloInstruction& consumer) argument [all...] |
/external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
H A D | cpu_instruction_fusion.cc | 51 bool CanBeOutputFused(const HloInstruction* producer, argument 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)) { 87 if (producer->opcode() != HloOpcode::kFusion && 89 is_expensive(*producer)) { 94 // TODO(b/28644064): see if the "producer 151 ChooseKind( const HloInstruction* producer, const HloInstruction* consumer) argument [all...] |
/external/ltp/testcases/open_posix_testsuite/functional/semaphores/ |
H A D | 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/ |
H A D | multi_con_pro.c | 40 int *producer(void *ID) function 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, 201 pthread_create(&pro[i], NULL, (void *)producer,
|
/external/python/cpython2/Demo/metaclasses/ |
H A D | Synch.py | 211 def producer(buffer, wait, n=1000): function in function:_test 247 thread.start_new_thread(producer, (buffer, pwait, n))
|
/external/libmojo/mojo/public/cpp/bindings/tests/ |
H A D | sample_service_unittest.cc | 71 mojo::ScopedDataPipeProducerHandle producer; local 73 mojo::CreateDataPipe(&options, &producer, &consumer); 75 output_streams[i] = std::move(producer);
|
/external/perfetto/src/tracing/ipc/producer/ |
H A D | producer_ipc_client_impl.cc | 17 #include "src/tracing/ipc/producer/producer_ipc_client_impl.h" 27 #include "perfetto/tracing/core/producer.h" 42 Producer* producer, 46 service_sock_name, producer, producer_name, task_runner)); 50 Producer* producer, 53 : producer_(producer), 40 Connect( const char* service_sock_name, Producer* producer, const std::string& producer_name, base::TaskRunner* task_runner) argument 49 ProducerIPCClientImpl(const char* service_sock_name, Producer* producer, const std::string& producer_name, base::TaskRunner* task_runner) argument
|
/external/perfetto/src/tracing/ipc/service/ |
H A D | producer_ipc_service.cc | 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 90 if (!producer) { 120 RemoteProducer* producer = GetProducerForCurrentRequest(); local 121 if (!producer) { 136 RemoteProducer* producer = GetProducerForCurrentRequest(); local 165 RemoteProducer* producer = GetProducerForCurrentRequest(); local [all...] |
/external/tensorflow/tensorflow/core/common_runtime/ |
H A D | graph_runner.cc | 163 const int producer = graph_to_run->versions().producer(); local 164 params.create_kernel = [this, producer](const NodeDef& ndef, 166 return CreateNonCachedKernel(cpu_device_.get(), nullptr, ndef, producer,
|
/external/valgrind/drd/tests/ |
H A D | circular_buffer.c | 1 /* Test program that performs producer-consumer style communication through 159 static void producer(int* id) function 211 (void * (*)(void *)) producer, &thread_arg[i]);
|
/external/icu/icu4c/source/i18n/ |
H A D | number_rounding.cpp | 252 Rounder::chooseMultiplierAndApply(impl::DecimalQuantity &input, const impl::MultiplierProducer &producer, argument 260 int32_t multiplier = producer.getMultiplier(magnitude); 268 multiplier = producer.getMultiplier(magnitude);
|
/external/libmojo/mojo/edk/test/ |
H A D | mojo_test_base.cc | 290 void MojoTestBase::WriteData(MojoHandle producer, const std::string& data) { argument 291 CHECK_EQ(MojoWait(producer, MOJO_HANDLE_SIGNAL_WRITABLE, 295 CHECK_EQ(MojoWriteData(producer, data.data(), &num_bytes,
|
/external/mesa3d/src/compiler/glsl/ |
H A D | link_interface_blocks.cpp | 153 * an array and the producer interface is required to be a non-array. 157 interstage_match(struct gl_shader_program *prog, ir_variable *producer, argument 161 if (consumer->get_interface_type() != producer->get_interface_type()) { 172 producer->data.how_declared != ir_var_declared_implicitly) && 174 producer->get_interface_type())) 192 (producer->is_interface_instance() && 193 producer->type->is_array())) { 194 if (consumer_instance_type != producer->type) 358 const gl_linked_shader *producer, 363 const bool extra_array_level = (producer 357 validate_interstage_inout_blocks(struct gl_shader_program *prog, const gl_linked_shader *producer, const gl_linked_shader *consumer) argument [all...] |
H A D | opt_dead_builtin_varyings.cpp | 271 * If "ir" is the producer, the "external" usage should come from 535 gl_linked_shader *producer, 557 if (producer) { 558 producer_info.get(producer->ir, num_tfeedback_decls, tfeedback_decls); 563 lower_texcoord_array(producer, &producer_info); 572 if (!producer) { 585 replace_varyings_visitor(producer, 602 /* Eliminate the inputs uninitialized by the producer. */ 534 do_dead_builtin_varyings(struct gl_context *ctx, gl_linked_shader *producer, gl_linked_shader *consumer, unsigned num_tfeedback_decls, tfeedback_decl *tfeedback_decls) argument
|
/external/perfetto/src/tracing/core/ |
H A D | 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 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...] |
/external/python/cpython3/Lib/test/test_asyncio/ |
H A D | test_queues.py | 284 def producer(queue, num_items): function in function:QueueGetTests.test_why_are_getters_waiting 293 asyncio.gather(producer(q, producer_num_items),
|