| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvmBenchmark/kotlin/kotlinx/coroutines/channels/ |
| D | ChannelProducerConsumerBenchmark.kt | 16 …the time for a batch of such operations separated into the specified number of consumers/producers. in <lambda>()
63 val consumers = 1 in <lambda>() constant
64 run(producers, consumers) in <lambda>()
71 val consumers = max(1, _4_parallelism - 1) in <lambda>() constant
72 run(producers, consumers) in <lambda>()
78 val consumers = producers in <lambda>() constant
79 run(producers, consumers) in <lambda>()
82 private fun run(producers: Int, consumers: Int) { in <lambda>()
83 val n = (APPROX_BATCH_SIZE / producers * producers) / consumers * consumers in <lambda>()
84 val phaser = Phaser(producers + consumers + 1) in <lambda>()
[all …]
|
| /external/apache-commons-lang/src/test/java/org/apache/commons/lang3/function/ |
| D | ConsumersTest.java | 27 * Tests {@link Consumers}.
32 * Tests {@link Consumers#nop()}.
36 Stream.of("").forEach(Consumers.nop()); in testNop()
38 final Consumer<?> c1 = Consumers.nop(); in testNop()
40 final Consumer<Object> c2 = Consumers.nop(); in testNop()
42 final Consumer<String> c3 = Consumers.nop(); in testNop()
45 Consumers.nop().accept(null); in testNop()
46 Consumers.nop().accept(""); in testNop()
|
| /external/cronet/tot/third_party/boringssl/src/ |
| D | BREAKING-CHANGES.md | 3 …g changes require some care. We depend on tight feedback loops with our consumers so that we can l…
19 The vast majority of BoringSSL consumers are conveniently indexed in various Code Search instances.…
23 If some change has high cost (from having to fix consumers) and relatively little benefit to Boring…
25 …hat leads to a major improvement to all BoringSSL consumers, at the cost of fixing one or two cons…
27 ## Fixing consumers
35 3. Remove the original API once all consumers have been migrated.
56 …consumers fail to compile. Prefer to remove functions completely over leaving an always failing st…
58 If some parameter now must be `NULL`, change the type to an opaque struct pointer. Consumers passin…
60 … hope that consumers have some amount of test coverage. When doing so, try to fail on the common c…
72 …somewhere first then wait a couple of weeks for the change to appear in consumers. This ensures th…
[all …]
|
| /external/cronet/stable/third_party/boringssl/src/ |
| D | BREAKING-CHANGES.md | 3 …g changes require some care. We depend on tight feedback loops with our consumers so that we can l…
19 The vast majority of BoringSSL consumers are conveniently indexed in various Code Search instances.…
23 If some change has high cost (from having to fix consumers) and relatively little benefit to Boring…
25 …hat leads to a major improvement to all BoringSSL consumers, at the cost of fixing one or two cons…
27 ## Fixing consumers
35 3. Remove the original API once all consumers have been migrated.
56 …consumers fail to compile. Prefer to remove functions completely over leaving an always failing st…
58 If some parameter now must be `NULL`, change the type to an opaque struct pointer. Consumers passin…
60 … hope that consumers have some amount of test coverage. When doing so, try to fail on the common c…
72 …somewhere first then wait a couple of weeks for the change to appear in consumers. This ensures th…
[all …]
|
| /external/boringssl/src/ |
| D | BREAKING-CHANGES.md | 3 …g changes require some care. We depend on tight feedback loops with our consumers so that we can l…
19 The vast majority of BoringSSL consumers are conveniently indexed in various Code Search instances.…
23 If some change has high cost (from having to fix consumers) and relatively little benefit to Boring…
25 …hat leads to a major improvement to all BoringSSL consumers, at the cost of fixing one or two cons…
27 ## Fixing consumers
35 3. Remove the original API once all consumers have been migrated.
56 …consumers fail to compile. Prefer to remove functions completely over leaving an always failing st…
58 If some parameter now must be `NULL`, change the type to an opaque struct pointer. Consumers passin…
60 … hope that consumers have some amount of test coverage. When doing so, try to fail on the common c…
72 …somewhere first then wait a couple of weeks for the change to appear in consumers. This ensures th…
[all …]
|
| /external/sdv/vsomeip/third_party/boost/thread/example/ |
| D | perf_condition_variable.cpp | 83 SharedData(unsigned iterations, unsigned consumers) : in SharedData()
84 …iterations(iterations), counter(), semaphore(consumers) // Initialize to the number of consumers. … in SharedData()
98 unsigned const consumers = shared_data->semaphore; // (*) in producer_thread() local
103 // Wait till all consumers signal. in producer_thread()
104 while (consumers != shared_data->semaphore) in producer_thread()
109 // Signal consumers. in producer_thread()
148 std::vector<std::thread> consumers in benchmark_ping_pong() local
157 // Start the consumers. in benchmark_ping_pong()
159 consumers[i] = std::thread in benchmark_ping_pong()
164 // Wait till consumers finish. in benchmark_ping_pong()
[all …]
|
| /external/deqp/framework/delibs/decpp/ |
| D | deThreadSafeRingBuffer.cpp | 139 vector<Consumer *> consumers; in ThreadSafeRingBuffer_selfTest() local
145 consumers.push_back(new Consumer(buffer, numProducers)); in ThreadSafeRingBuffer_selfTest()
147 // Start consumers. in ThreadSafeRingBuffer_selfTest()
148 for (vector<Consumer *>::iterator i = consumers.begin(); i != consumers.end(); i++) in ThreadSafeRingBuffer_selfTest()
159 // Write end messages for consumers. in ThreadSafeRingBuffer_selfTest()
163 // Wait for consumers. in ThreadSafeRingBuffer_selfTest()
164 for (vector<Consumer *>::iterator i = consumers.begin(); i != consumers.end(); i++) in ThreadSafeRingBuffer_selfTest()
176 cmpSum += consumers[j]->getPayloadSum((uint16_t)i); in ThreadSafeRingBuffer_selfTest()
183 for (vector<Consumer *>::iterator i = consumers.begin(); i != consumers.end(); i++) in ThreadSafeRingBuffer_selfTest()
|
| D | deBlockBuffer.cpp | 92 … /* Feed back rest of messages to buffer (they are end messages) so other consumers wake up. */ in run()
177 vector<Consumer *> consumers; in runTest() local
183 consumers.push_back(new Consumer(buffer, numProducers)); in runTest()
185 // Start consumers. in runTest()
186 for (vector<Consumer *>::iterator i = consumers.begin(); i != consumers.end(); i++) in runTest()
197 // Write end messages for consumers. in runTest()
203 // Wait for consumers. in runTest()
204 for (vector<Consumer *>::iterator i = consumers.begin(); i != consumers.end(); i++) in runTest()
216 cmpSum += consumers[j]->getPayloadSum((uint16_t)i); in runTest()
223 for (vector<Consumer *>::iterator i = consumers.begin(); i != consumers.end(); i++) in runTest()
|
| /external/clang/lib/Frontend/ |
| D | MultiplexConsumer.cpp | 246 : Consumers(std::move(C)), MutationListener(), DeserializationListener() { in MultiplexConsumer()
251 for (auto &Consumer : Consumers) { in MultiplexConsumer()
271 for (auto &Consumer : Consumers) in Initialize()
277 for (auto &Consumer : Consumers) in HandleTopLevelDecl()
283 for (auto &Consumer : Consumers) in HandleInlineFunctionDefinition()
288 for (auto &Consumer : Consumers) in HandleCXXStaticMemberVarInstantiation()
293 for (auto &Consumer : Consumers) in HandleInterestingDecl()
298 for (auto &Consumer : Consumers) in HandleTranslationUnit()
303 for (auto &Consumer : Consumers) in HandleTagDeclDefinition()
308 for (auto &Consumer : Consumers) in HandleTagDeclRequiredDefinition()
[all …]
|
| /external/googleapis/google/api/serviceusage/v1/ |
| D | serviceusage_v1.yaml | 19 Enables services that service consumers want to use on Google Cloud
21 that service consumers no longer use.
23 The Service Usage API allows *service consumers* to manage the set
24 of *services* they interact with. Consumers can use the Service Usage API
31 ## Service consumers
34 invoke APIs on a service. A service can have many service consumers.
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/common/ |
| D | model.cc | 55 return FilterValues([](const ValueDef& v) { return v.consumers.empty(); }); in outputs()
83 return values_[id].consumers.empty(); in IsGraphOutput()
97 return values_[id].consumers; in FindConsumers()
215 v->consumers.push_back(node_ptr); in AddConsumer()
253 v_new->consumers.push_back(node_ptr); in ReplaceInput()
254 Erase(&v_old->consumers, node_ptr); in ReplaceInput()
269 Erase(&v->consumers, node_ptr); in RemoveConsumer()
278 Erase(&values_[value->id].consumers, node_ptr); in DeleteNode()
296 if (!v->consumers.empty()) { in DeleteValue()
297 for (auto node : v->consumers) { in DeleteValue()
[all …]
|
| /external/autotest/client/common_lib/cros/ |
| D | memory_eater.py | 45 def cleanup_consumers(consumers): argument
46 """Kill all processes in |consumers|
48 @param consumers: The list of consumers to clean.
50 while len(consumers):
51 job = consumers.pop()
93 """Gets pid of active consumers by all instances of the class."""
186 """Runs concurrent memory consumers to produce memory pressure.
|
| /external/grpc-grpc/test/core/surface/ |
| D | completion_queue_threading_test.cc | 218 static void test_threading(size_t producers, size_t consumers) { in test_threading() argument
220 gpr_malloc((producers + consumers) * sizeof(test_thread_options))); in test_threading()
228 gpr_log(GPR_INFO, "%s: %" PRIuPTR " producers, %" PRIuPTR " consumers", in test_threading()
229 "test_threading", producers, consumers); in test_threading()
233 gpr_malloc(sizeof(*threads) * (producers + consumers))); in test_threading()
234 for (i = 0; i < producers + consumers; i++) { in test_threading()
259 for (i = 0; i < producers + consumers; i++) { in test_threading()
264 // start phase2: operations will complete, and consumers will consume them in test_threading()
274 for (i = 0; i < producers + consumers; i++) { in test_threading()
282 for (i = 0; i < producers + consumers; i++) { in test_threading()
[all …]
|
| /external/cronet/stable/net/socket/ |
| D | datagram_client_socket.h | 27 // TODO(liza): Remove this method once consumers have been updated.
35 // TODO(liza): Remove this method once consumers have been updated.
42 // TODO(liza): Remove this method once consumers have been updated.
47 // TODO(liza): Rename this to Connect once consumers have been updated.
53 // TODO(liza): Rename this to ConnectUsingNetwork once consumers have been
61 // TODO(liza): Rename this to ConnectUsingDefaultNetwork once consumers have
|
| /external/cronet/tot/net/socket/ |
| D | datagram_client_socket.h | 27 // TODO(liza): Remove this method once consumers have been updated.
35 // TODO(liza): Remove this method once consumers have been updated.
42 // TODO(liza): Remove this method once consumers have been updated.
47 // TODO(liza): Rename this to Connect once consumers have been updated.
53 // TODO(liza): Rename this to ConnectUsingNetwork once consumers have been
61 // TODO(liza): Rename this to ConnectUsingDefaultNetwork once consumers have
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | dispatcher_impl.h | 57 // consumers consume the data from the iteration until there is no data left.
68 // one task for each outstanding iteration. Consumers periodically heartbeat to
71 // For non-round-robin-reads, there is no coordination among consumers. Each
74 // consumers to read from the same task at each step. This requires coordination
75 // to ensure that all consumers start reading from the new task in the same
82 // information is reported by consumers in their heartbeats.
98 // - When consumers heartbeat, they tell the dispatcher their current round and
104 // to add the new task. Once all consumers are ready to add the new task, we
106 // consumers. We set the "starting_round" field of the task to indicate the
107 // target round where all consumers should start reading from the task.
[all …]
|
| /external/google-cloud-java/java-dataproc-metastore/proto-google-cloud-dataproc-metastore-v1/src/main/java/com/google/cloud/metastore/v1/ |
| D | NetworkConfigOrBuilder.java | 35 …* repeated .google.cloud.metastore.v1.NetworkConfig.Consumer consumers = 1 [(.google.api.field_beh…
48 …* repeated .google.cloud.metastore.v1.NetworkConfig.Consumer consumers = 1 [(.google.api.field_beh…
61 …* repeated .google.cloud.metastore.v1.NetworkConfig.Consumer consumers = 1 [(.google.api.field_beh…
74 …* repeated .google.cloud.metastore.v1.NetworkConfig.Consumer consumers = 1 [(.google.api.field_beh…
88 …* repeated .google.cloud.metastore.v1.NetworkConfig.Consumer consumers = 1 [(.google.api.field_beh…
|
| /external/googleapis/google/api/serviceusage/v1beta1/ |
| D | serviceusage_v1beta1.yaml | 29 Enables services that service consumers want to use on Google Cloud
31 that service consumers no longer use.
33 The Service Usage API allows *service consumers* to manage the set
34 of *services* they interact with. Consumers can use the Service Usage API
41 ## Service consumers
44 invoke APIs on a service. A service can have many service consumers.
|
| /external/igt-gpu-tools/benchmarks/ |
| D | gem_latency.c | 139 struct consumer *consumers; member
358 p->consumers[n].go = 1; in producer()
384 p->consumers[n].go = 1; in producer()
450 printf("producers=%d, consumers=%d, nop=%d, workload=%d, flags=%x\n", in run()
496 p[n].consumers = calloc(nconsumers, sizeof(struct consumer)); in run()
498 p[n].consumers[m].producer = &p[n]; in run()
499 igt_mean_init(&p[n].consumers[m].latency); in run()
500 pthread_create(&p[n].consumers[m].thread, NULL, in run()
501 consumer, &p[n].consumers[m]); in run()
543 pthread_join(p[n].consumers[m].thread, NULL); in run()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | fusion_merger.h | 29 // ops B and C are its consumers. FusionMerger duplicates producer ops and fuses
30 // them into all consumers. The result is depicted on the right-hand side below.
46 // the differences in memory read and written and the number of consumers. The
53 // * Producer ops are fusible with _all_ consumers. If they are not fusible with
54 // at least one consumers, they won't be fused at all.
|
| /external/google-cloud-java/java-dataproc-metastore/proto-google-cloud-dataproc-metastore-v1beta/src/main/java/com/google/cloud/metastore/v1beta/ |
| D | NetworkConfigOrBuilder.java | 35 …* repeated .google.cloud.metastore.v1beta.NetworkConfig.Consumer consumers = 1 [(.google.api.field…
48 …* repeated .google.cloud.metastore.v1beta.NetworkConfig.Consumer consumers = 1 [(.google.api.field…
61 …* repeated .google.cloud.metastore.v1beta.NetworkConfig.Consumer consumers = 1 [(.google.api.field…
74 …* repeated .google.cloud.metastore.v1beta.NetworkConfig.Consumer consumers = 1 [(.google.api.field…
88 …* repeated .google.cloud.metastore.v1beta.NetworkConfig.Consumer consumers = 1 [(.google.api.field…
|
| /external/google-cloud-java/java-dataproc-metastore/proto-google-cloud-dataproc-metastore-v1alpha/src/main/java/com/google/cloud/metastore/v1alpha/ |
| D | NetworkConfigOrBuilder.java | 35 …* repeated .google.cloud.metastore.v1alpha.NetworkConfig.Consumer consumers = 1 [(.google.api.fiel…
48 …* repeated .google.cloud.metastore.v1alpha.NetworkConfig.Consumer consumers = 1 [(.google.api.fiel…
61 …* repeated .google.cloud.metastore.v1alpha.NetworkConfig.Consumer consumers = 1 [(.google.api.fiel…
74 …* repeated .google.cloud.metastore.v1alpha.NetworkConfig.Consumer consumers = 1 [(.google.api.fiel…
88 …* repeated .google.cloud.metastore.v1alpha.NetworkConfig.Consumer consumers = 1 [(.google.api.fiel…
|
| /external/google-cloud-java/java-private-catalog/grpc-google-cloud-private-catalog-v1beta1/src/main/java/com/google/cloud/privatecatalog/v1beta1/ |
| D | PrivateCatalogGrpc.java | 24 * `PrivateCatalog` allows catalog consumers to retrieve `Catalog`, `Product`
241 * `PrivateCatalog` allows catalog consumers to retrieve `Catalog`, `Product`
267 …* Search [Catalog][google.cloud.privatecatalog.v1beta1.Catalog] resources that consumers have acce…
283 …* Search [Product][google.cloud.privatecatalog.v1beta1.Product] resources that consumers have acce…
299 …* Search [Version][google.cloud.privatecatalog.v1beta1.Version] resources that consumers have acce…
316 * `PrivateCatalog` allows catalog consumers to retrieve `Catalog`, `Product`
349 * `PrivateCatalog` allows catalog consumers to retrieve `Catalog`, `Product`
384 …* Search [Catalog][google.cloud.privatecatalog.v1beta1.Catalog] resources that consumers have acce…
402 …* Search [Product][google.cloud.privatecatalog.v1beta1.Product] resources that consumers have acce…
420 …* Search [Version][google.cloud.privatecatalog.v1beta1.Version] resources that consumers have acce…
[all …]
|
| /external/pigweed/pw_allocator/public/pw_allocator/ |
| D | allocator.h | 29 /// The interface makes no guarantees about its implementation. Consumers of the
96 /// TODO(b/326509341): Remove when downstream consumers migrate.
105 /// TODO(b/326509341): Remove when downstream consumers migrate.
160 /// TODO(b/326509341): Remove when downstream consumers migrate.
169 /// TODO(b/326509341): Remove when downstream consumers migrate.
199 /// TODO(b/326509341): Remove when downstream consumers migrate.
239 /// TODO(b/326509341): Remove when downstream consumers migrate.
255 /// TODO(b/326509341): Remove when downstream consumers migrate.
279 /// TODO(b/326509341): Remove when downstream consumers migrate.
295 /// TODO(b/326509341): Remove when downstream consumers migrate.
[all …]
|
| /external/tensorflow/tensorflow/python/data/experimental/ops/ |
| D | data_service_ops.py | 276 When specified, consumers will read from the job in a strict round-robin
278 num_consumers: (Optional.) The number of consumers which will consume from
280 consumers will read from the job in a strict round-robin order, instead
283 producer from running out of data early and causing consumers to go out
302 service worker. Consumers of a shared job must use the same
493 specified, consumers will read from the job in a strict round-robin order,
495 num_consumers: (Optional.) The number of consumers which will consume from
497 consumers will read from the job in a strict round-robin order, instead of
500 producer from running out of data early and causing consumers to go out of
524 Consumers of a shared job must use the same `target_workers`. Defaults to
[all …]
|