Searched defs:producer (Results 1 - 25 of 43) sorted by relevance

12

/external/perfetto/test/cts/producer/src/android/perfetto/producer/
H A DProducerActivity.java17 package android.perfetto.producer;
H A DProducerIsolatedService.java17 package android.perfetto.producer;
H A DProducerService.java17 package android.perfetto.producer;
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
H A Dinstruction_fusion.cc47 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 D3-1.c34 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 D3-1.c34 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 Dprobes.cc71 ProbesProducer producer; local
72 producer.ConnectWithRetries(GetProducerSocket(), &task_runner);
/external/perfetto/test/
H A Dtask_runner_thread_delegates.h78 FakeProducer* producer() { return producer_.get(); } function in class:perfetto::FakeProducerDelegate
H A Dend_to_end_benchmark.cc45 FakeProducer* producer = helper.ConnectFakeProducer(); local
80 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed));
/external/tensorflow/tensorflow/compiler/xla/service/
H A Dinstruction_fusion.h51 // 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 Dcpu_instruction_fusion.cc51 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 Dsem_conpro.c9 * 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 Dmulti_con_pro.c40 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 DSynch.py211 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 Dsample_service_unittest.cc71 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 Dproducer_ipc_client_impl.cc17 #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 Dproducer_ipc_service.cc66 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 Dgraph_runner.cc163 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 Dcircular_buffer.c1 /* 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 Dnumber_rounding.cpp252 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 Dmojo_test_base.cc290 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 Dlink_interface_blocks.cpp153 * 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 Dopt_dead_builtin_varyings.cpp271 * 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 Dservice_impl_unittest.cc29 #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 Dtest_queues.py284 def producer(queue, num_items): function in function:QueueGetTests.test_why_are_getters_waiting
293 asyncio.gather(producer(q, producer_num_items),

Completed in 1014 milliseconds

12