Home
last modified time | relevance | path

Searched refs:producers (Results 1 – 25 of 125) sorted by relevance

12345

/external/grpc-grpc/test/core/surface/
Dcompletion_queue_threading_test.cc208 static void test_threading(size_t producers, size_t consumers) { in test_threading() argument
210 gpr_malloc((producers + consumers) * sizeof(test_thread_options))); in test_threading()
219 "test_threading", producers, consumers); in test_threading()
223 gpr_malloc(sizeof(*threads) * (producers + consumers))); in test_threading()
224 for (i = 0; i < producers + consumers; i++) { in test_threading()
236 i < producers ? "grpc_producer" : "grpc_consumer", in test_threading()
237 i < producers ? producer_thread : consumer_thread, options + i, &ok); in test_threading()
249 for (i = 0; i < producers + consumers; i++) { in test_threading()
264 for (i = 0; i < producers + consumers; i++) { in test_threading()
272 for (i = 0; i < producers + consumers; i++) { in test_threading()
[all …]
/external/dagger2/producers/src/main/java/dagger/producers/internal/
DAbstractProducer.java16 package dagger.producers.internal;
19 import dagger.producers.Producer;
20 import dagger.producers.monitoring.ProducerMonitor;
21 import dagger.producers.monitoring.ProducerToken;
22 import dagger.producers.monitoring.ProductionComponentMonitor;
23 import dagger.producers.monitoring.internal.Monitors;
DSetOfProducedProducer.java16 package dagger.producers.internal;
22 import dagger.producers.Produced;
23 import dagger.producers.Producer;
24 import dagger.producers.monitoring.ProducerMonitor;
44 public static <T> Producer<Set<Produced<T>>> create(Producer<Set<T>>... producers) { in create() argument
45 return new SetOfProducedProducer<T>(ImmutableSet.copyOf(producers)); in create()
DSetProducer.java16 package dagger.producers.internal;
22 import dagger.producers.Producer;
23 import dagger.producers.monitoring.ProducerMonitor;
42 public static <T> Producer<Set<T>> create(Producer<Set<T>>... producers) { in create() argument
43 return new SetProducer<T>(ImmutableSet.copyOf(producers)); in create()
DProducers.java16 package dagger.producers.internal;
23 import dagger.producers.Produced;
24 import dagger.producers.Producer;
25 import dagger.producers.monitoring.ProducerMonitor;
/external/deqp/framework/delibs/decpp/
DdeThreadSafeRingBuffer.cpp134 vector<Producer*> producers; in ThreadSafeRingBuffer_selfTest() local
138 producers.push_back(new Producer(buffer, (deUint16)i, dataSize)); in ThreadSafeRingBuffer_selfTest()
148 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++) in ThreadSafeRingBuffer_selfTest()
152 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++) in ThreadSafeRingBuffer_selfTest()
177 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++) in ThreadSafeRingBuffer_selfTest()
DdeBlockBuffer.cpp171 vector<Producer*> producers; in runTest() local
175 producers.push_back(new Producer(buffer, (deUint16)i, dataSize)); in runTest()
185 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++) in runTest()
189 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++) in runTest()
216 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++) in runTest()
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/
DMultibindingProducerModule.java21 import dagger.producers.ProducerModule;
22 import dagger.producers.Produces;
26 import static dagger.producers.Produces.Type.SET;
27 import static dagger.producers.Produces.Type.SET_VALUES;
DSimpleProducerModule.java22 import dagger.producers.Produced;
23 import dagger.producers.Producer;
24 import dagger.producers.ProducerModule;
25 import dagger.producers.Produces;
31 import static dagger.producers.Produces.Type.SET;
32 import static dagger.producers.Produces.Type.SET_VALUES;
DDependedProducerModule.java22 import dagger.producers.ProducerModule;
23 import dagger.producers.Produces;
DMultibindingComponent.java19 import dagger.producers.Produced;
20 import dagger.producers.ProductionComponent;
DResponseProducerModule.java20 import dagger.producers.ProducerModule;
21 import dagger.producers.Produces;
DDependentProducerModule.java22 import dagger.producers.ProducerModule;
23 import dagger.producers.Produces;
/external/dagger2/producers/src/main/java/dagger/producers/monitoring/
DProductionComponentMonitor.java16 package dagger.producers.monitoring;
18 import dagger.producers.Produces;
19 import dagger.producers.ProductionComponent;
DProducerToken.java16 package dagger.producers.monitoring;
18 import dagger.producers.Produces;
DProducerMonitor.java16 package dagger.producers.monitoring;
21 import dagger.producers.Produces;
/external/dagger2/producers/src/test/java/dagger/producers/internal/
DAbstractProducerTest.java16 package dagger.producers.internal;
21 import dagger.producers.Producer;
22 import dagger.producers.monitoring.ProducerMonitor;
23 import dagger.producers.monitoring.ProducerToken;
24 import dagger.producers.monitoring.ProductionComponentMonitor;
/external/dagger2/compiler/src/test/java/dagger/internal/codegen/
DDependencyRequestMapperTest.java24 import dagger.producers.Produced;
25 import dagger.producers.Producer;
26 import dagger.producers.ProducerModule;
27 import dagger.producers.Produces;
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/
DStringModule.java18 import dagger.producers.ProducerModule;
19 import dagger.producers.Produces;
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/badexecutor/
DSimpleProducerModule.java18 import dagger.producers.ProducerModule;
19 import dagger.producers.Produces;
/external/dagger2/
DAndroid.bp85 // build dagger2 producers plugin
89 name: "dagger2-producers",
91 srcs: ["producers/src/main/java/**/*.java"],
127 "dagger2-producers",
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/monitoring/
DServingModule.java19 import dagger.producers.ProducerModule;
20 import dagger.producers.Produces;
/external/eigen/unsupported/test/
Dcxx11_eventcount.cpp90 std::vector<std::unique_ptr<std::thread>> producers; in test_stress_eventcount() local
92 producers.emplace_back(new std::thread([&ec, &queues]() { in test_stress_eventcount()
133 producers[i]->join(); in test_stress_eventcount()
/external/dagger2/producers/src/main/java/dagger/producers/monitoring/internal/
DMonitorCache.java16 package dagger.producers.monitoring.internal;
18 import dagger.producers.monitoring.ProductionComponentMonitor;
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/
DProducerFactoryTest.java21 import dagger.producers.Producer;
22 import dagger.producers.monitoring.ProducerMonitor;
23 import dagger.producers.monitoring.ProducerToken;
24 import dagger.producers.monitoring.ProductionComponentMonitor;

12345