| /external/llvm-project/libcxx/test/std/thread/futures/futures.overview/ |
| D | launch.pass.cpp | 28 LIBCPP_STATIC_ASSERT(static_cast<int>(std::launch::any) == in main()
29 … (static_cast<int>(std::launch::async) | static_cast<int>(std::launch::deferred)), ""); in main()
31 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async | std::launch::deferred), ""); in main()
32 static_assert(std::launch(0) == (std::launch::async & std::launch::deferred), ""); in main()
33 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async ^ std::launch::deferred), ""); in main()
34 LIBCPP_STATIC_ASSERT(std::launch::deferred == ~std::launch::async, ""); in main()
35 std::launch x = std::launch::async; in main()
36 x &= std::launch::deferred; in main()
37 assert(x == std::launch(0)); in main()
38 x = std::launch::async; in main()
[all …]
|
| /external/libcxx/test/std/thread/futures/futures.overview/ |
| D | launch.pass.cpp | 29 LIBCPP_STATIC_ASSERT(static_cast<int>(std::launch::any) == in main()
30 … (static_cast<int>(std::launch::async) | static_cast<int>(std::launch::deferred)), ""); in main()
32 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async | std::launch::deferred), ""); in main()
33 static_assert(std::launch(0) == (std::launch::async & std::launch::deferred), ""); in main()
34 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async ^ std::launch::deferred), ""); in main()
35 LIBCPP_STATIC_ASSERT(std::launch::deferred == ~std::launch::async, ""); in main()
36 std::launch x = std::launch::async; in main()
37 x &= std::launch::deferred; in main()
38 assert(x == std::launch(0)); in main()
39 x = std::launch::async; in main()
[all …]
|
| /external/tensorflow/tensorflow/compiler/mlir/tensorflow/transforms/ |
| D | launch_to_device_attribute.cc | 67 tf_device::LaunchOp launch, in AssignDevicesInRegion() argument
74 op->setAttr(kDeviceAttr, launch.deviceAttr()); in AssignDevicesInRegion()
80 op->setAttr(kDeviceAttr, launch.deviceAttr()); in AssignDevicesInRegion()
82 } else if (device_str_attr.getValue() != launch.device()) { in AssignDevicesInRegion()
83 return launch.emitOpError() in AssignDevicesInRegion()
87 << launch.device() << "'"; in AssignDevicesInRegion()
90 return launch.emitOpError() in AssignDevicesInRegion()
101 tf_device::LaunchOp launch) { in HoistOpsAndAnnotateWithDevice() argument
103 launch.replaceAllUsesWith(launch.GetBody().getTerminator()->getOperands()); in HoistOpsAndAnnotateWithDevice()
106 if (failed(AssignDevicesInRegion(tf_dialect, launch, launch.body()))) in HoistOpsAndAnnotateWithDevice()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | JobExceptionHandlingTest.kt | 25 launch(job, start = ATOMIC) { in <lambda>()
62 val job = launch(parent) { in <lambda>()
86 val child = launch(job, start = ATOMIC) { in <lambda>()
110 launch(job) { in <lambda>()
113 launch { in <lambda>()
146 launch(job, start = ATOMIC) { in <lambda>()
148 launch(start = ATOMIC) { in <lambda>()
174 launch(job) { in <lambda>()
176 launch { in <lambda>()
210 launch(job, start = ATOMIC) { in <lambda>()
[all …]
|
| D | JobNestedExceptionsTest.kt | 18 launch(job) { in testExceptionUnwrapping()
20 launch { in testExceptionUnwrapping()
21 launch { in testExceptionUnwrapping()
22 launch { in testExceptionUnwrapping()
42 launch(job) { in testExceptionUnwrappingWithSuspensions()
44 launch { in testExceptionUnwrappingWithSuspensions()
45 launch { in testExceptionUnwrappingWithSuspensions()
46 launch { in testExceptionUnwrappingWithSuspensions()
47 launch { in testExceptionUnwrappingWithSuspensions()
71 … val job = launch(NonCancellable + CoroutineName("outer"), start = CoroutineStart.ATOMIC) { in testNestedAtomicThrow()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | UnconfinedTest.kt | 14 launch(Dispatchers.Unconfined) { in <lambda>()
16 launch { in <lambda>()
18 launch { in <lambda>()
22 launch { in <lambda>()
45 launch(start = CoroutineStart.ATOMIC) { in <lambda>()
58 launch(Unconfined) { in <lambda>()
62 launch(Unconfined) { in <lambda>()
66 launch(Unconfined) { in <lambda>()
76 launch(Dispatchers.Unconfined) { in <lambda>()
79 launch { in <lambda>()
[all …]
|
| D | CoroutinesTest.kt | 29 val job = launch { in <lambda>()
44 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
59 val j1 = launch { in <lambda>()
61 val j2 = launch { in <lambda>()
76 launch { in <lambda>()
90 val job = launch { in <lambda>()
105 val job = launch { in <lambda>()
124 launch { in <lambda>()
126 launch { in <lambda>()
156 launch { in <lambda>()
[all …]
|
| D | ExperimentalDispatchModeTest.kt | 13 launch(parent) { in <lambda>()
16 launch(Dispatchers.Unconfined) { in <lambda>()
27 launch(parent) { in <lambda>()
30 val job = launch(Dispatchers.Unconfined) { in <lambda>()
44 launch(parent) { in <lambda>()
46 val job = launch(Dispatchers.Unconfined, start = CoroutineStart.LAZY) { in <lambda>()
61 launch(parent) { in <lambda>()
64 launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
77 launch(parent) { in <lambda>()
80 launch(Dispatchers.Unconfined, start = CoroutineStart.ATOMIC) { in <lambda>()
[all …]
|
| D | AtomicCancellationCommonTest.kt | 15 val job = launch { in <lambda>()
26 val job = launch(start = CoroutineStart.ATOMIC) { in <lambda>()
43 launch { // will cancel job as soon as deferred completes in <lambda>()
48 job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
65 val jobToJoin = launch { // not yet complete in testJobJoinCancellable()
70 launch { // will cancel job as soon as jobToJoin completes in testJobJoinCancellable()
75 job = launch(start = CoroutineStart.UNDISPATCHED) { in testJobJoinCancellable()
93 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
109 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
|
| D | SupervisorTest.kt | 21 val job1 = launch(supervisor + CoroutineName("job1")) { in <lambda>()
27 val job2 = launch(supervisor + CoroutineName("job2")) { in <lambda>()
47 launch { in <lambda>()
50 launch { in <lambda>()
65 val job = launch { in <lambda>()
70 val failingJob = launch { in <lambda>()
114 launch { in <lambda>()
119 launch { in <lambda>()
138 launch { in <lambda>()
143 launch { in <lambda>()
[all …]
|
| D | WithContextTest.kt | 49 launch(coroutineContext) { // make sure there is not early dispatch here in <lambda>()
65 launch(coroutineContext) { // make sure there is not early dispatch here in <lambda>()
82 launch(coroutineContext) { // make sure there is not early dispatch to here in <lambda>()
113 launch(coroutineContext) { // make sure there is not early dispatch to here in <lambda>()
150 job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
175 job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
204 job = launch(Job()) { in <lambda>()
233 job = launch(Job()) { in <lambda>()
267 launch { in <lambda>()
287 launch { in <lambda>()
[all …]
|
| /external/tensorflow/tensorflow/compiler/mlir/tensorflow/tests/ |
| D | launch_to_device_attribute.mlir | 1 // RUN: tf-opt %s -split-input-file -verify-diagnostics -tf-launch-to-device-attribute | FileCheck …
5 // by parent `tf_device.launch`.
11 %launch:2 = "tf_device.launch"() ( {
16 … tf_executor.yield %a, %launch#0, %launch#1, %c : tensor<i1>, tensor<f32>, tensor<i32>, tensor<i1>
27 // CHECK-NOT: "tf_device.launch"
32 // assigned by parent `tf_device.launch`.
38 %launch:2 = "tf_device.launch"() ( {
44 … tf_executor.yield %a, %launch#0, %launch#1, %d : tensor<i1>, tensor<f32>, tensor<i32>, tensor<i1>
57 // CHECK-NOT: "tf_device.launch"
66 %launch:2 = "tf_device.launch"() ( {
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherTest.kt | 21 val blockingJob = launch(blockingDispatcher.value) { in <lambda>()
25 val nonBlockingJob = launch(dispatcher) { in <lambda>()
38 val blocking = launch(blockingDispatcher.value) { in <lambda>()
40 launch(dispatcher) { in <lambda>()
55 val blocking = launch(blockingDispatcher.value) { in testScheduleBlockingThreadCount()
56 launch(blockingDispatcher.value) { in testScheduleBlockingThreadCount()
70 val tasks = (1..tasksNum).map { launch(blockingDispatcher.value) { barrier.await() } } in <lambda>()
72 val cpuTask = launch(dispatcher) { in <lambda>()
90 …listOf(launch(blockingDispatcher) { firstBarrier.await() }, launch(blockingDispatcher2) { secondBa… in <lambda>()
94 launch(dispatcher) { in <lambda>()
[all …]
|
| D | CoroutineDispatcherTest.kt | 45 val outerJob = launch(dispatcher) { in <lambda>()
46 val d1 = launch(dispatcher) { expect(3) } in <lambda>()
47 val d2 = launch(dispatcher) { expect(4) } in <lambda>()
48 val d3 = launch(dispatcher) { expect(2) } in <lambda>()
93 (1..10).map { launch(blockingDispatcher.value) { Thread.sleep(100) } }.joinAll() in <lambda>()
101 val outerJob = launch(dispatcher) { in <lambda>()
103 val innerJob = launch(dispatcher) { in <lambda>()
123 val job = launch(dispatcher, CoroutineStart.UNDISPATCHED) { in <lambda>()
139 launch(dispatcher) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestRunBlockingOrderTest.kt | 15 launch { in <lambda>()
24 launch { in <lambda>()
35 launch { in <lambda>()
45 launch { in <lambda>()
49 launch { in <lambda>()
60 launch { in testVeryLongDelay()
64 launch { in testVeryLongDelay()
|
| D | TestRunBlockingTest.kt | 34 val job = launch { in <lambda>()
146 val job= launch { in <lambda>()
161 val job = launch { in <lambda>()
183 val job = launch { in <lambda>()
210 launch { in <lambda>()
238 launch { in <lambda>()
241 launch { in <lambda>()
256 val job = launch { in <lambda>()
268 val job = launch { in <lambda>()
279 launch { in <lambda>()
[all …]
|
| /external/llvm-project/libcxx/test/std/thread/futures/futures.async/ |
| D | async.pass.cpp | 112 std::launch AnyPolicy = std::launch::async | std::launch::deferred; in main()
113 LIBCPP_ASSERT(AnyPolicy == std::launch::any); in main()
118 test<int>(checkInt, false, std::launch::async, f0); in main()
119 test<int>(checkInt, true, std::launch::deferred, f0); in main()
125 test<int&>(checkIntRef, false, std::launch::async, f1); in main()
126 test<int&>(checkIntRef, true, std::launch::deferred, f1); in main()
132 test<void>(checkVoid, false, std::launch::async, f2); in main()
133 test<void>(checkVoid, true, std::launch::deferred, f2); in main()
149 std::future<void> f = std::async(std::launch::deferred, f5, 3); in main()
|
| /external/libcxx/test/std/thread/futures/futures.async/ |
| D | async.pass.cpp | 113 std::launch AnyPolicy = std::launch::async | std::launch::deferred; in main()
114 LIBCPP_ASSERT(AnyPolicy == std::launch::any); in main()
119 test<int>(checkInt, false, std::launch::async, f0); in main()
120 test<int>(checkInt, true, std::launch::deferred, f0); in main()
126 test<int&>(checkIntRef, false, std::launch::async, f1); in main()
127 test<int&>(checkIntRef, true, std::launch::deferred, f1); in main()
133 test<void>(checkVoid, false, std::launch::async, f2); in main()
134 test<void>(checkVoid, true, std::launch::deferred, f2); in main()
150 std::future<void> f = std::async(std::launch::deferred, f5, 3); in main()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | AtomicCancellationTest.kt | 16 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
32 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
53 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
69 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
96 launch { // will cancel job as soon as deferred completes in <lambda>()
101 job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
120 val jobToJoin = launch { // not yet complete in <lambda>()
125 launch { // will cancel job as soon as jobToJoin completes in <lambda>()
130 job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | RendezvousChannelTest.kt | 16 val sender = launch { in <lambda>()
24 val receiver = launch { in <lambda>()
43 launch { in <lambda>()
64 launch { in <lambda>()
87 launch { in <lambda>()
114 launch { in <lambda>()
130 launch { in <lambda>()
149 launch { in <lambda>()
170 launch { in <lambda>()
194 launch { in testIteratorTwoWithYield()
[all …]
|
| D | ChannelUndeliveredElementFailureTest.kt | 26 val job = launch(start = CoroutineStart.UNDISPATCHED) { in isElementCancelException()
36 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
49 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
60 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
75 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
86 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
101 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
112 val job = launch(start = CoroutineStart.UNDISPATCHED) { in testReceiveOrClosedSelectCancelledFail()
127 val job = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/ |
| D | SelectRendezvousChannelTest.kt | 19 launch { in <lambda>()
38 launch { in <lambda>()
70 launch { in <lambda>()
86 launch { in <lambda>()
104 launch { in <lambda>()
124 launch { in <lambda>()
157 launch { in <lambda>()
173 launch { in <lambda>()
206 launch { in <lambda>()
253 launch { in <lambda>()
[all …]
|
| /external/llvm-project/lldb/unittests/Process/gdb-remote/ |
| D | GDBRemoteCommunicationClientTest.cpp | 77 std::future<bool> write_result = std::async(std::launch::async, [&] { in TEST_F()
86 write_result = std::async(std::launch::async, [&] { in TEST_F()
97 std::future<bool> write_result = std::async(std::launch::async, [&] { in TEST_F()
106 write_result = std::async(std::launch::async, [&] { in TEST_F()
118 std::launch::async, [&] { return client.GetpPacketSupported(tid); }); in TEST_F()
124 std::launch::async, [&] { return client.ReadRegister(tid, reg_num); }); in TEST_F()
131 read_result = std::async(std::launch::async, in TEST_F()
143 std::future<bool> async_result = std::async(std::launch::async, [&] { in TEST_F()
152 async_result = std::async(std::launch::async, [&] { in TEST_F()
162 std::launch::async, [&] { return client.SyncThreadState(tid); }); in TEST_F()
[all …]
|
| /external/llvm-project/clang/test/Driver/ |
| D | hip-launch-api.hip | 5 // By default FE assumes -fhip-new-launch-api.
9 // NEW: "-fhip-new-launch-api"
12 // RUN: -fhip-new-launch-api 2>&1 | FileCheck -check-prefixes=NEW %s
13 // NEW: "-fhip-new-launch-api"
16 // RUN: -fno-hip-new-launch-api 2>&1 | FileCheck -check-prefixes=OLD %s
17 // OLD-NOT: "-fhip-new-launch-api"
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/tailcall/ |
| D | SimpleChannelBenchmark.kt | 27 launch { in <lambda>()
31 launch { in <lambda>()
39 launch { in <lambda>()
43 launch { in <lambda>()
51 launch { in <lambda>()
55 launch { in <lambda>()
|