| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | SchedulerTest.kt | 47 val scheduler = Dispatchers.Default.asScheduler() in <lambda>() constant
161 runSchedulerTest(nThreads = n) { scheduler -> in <lambda>() method
189 val scheduler = dispatcher.asScheduler() in <lambda>() constant
243 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
249 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
267 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
273 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
279 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
285 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
302 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
[all …]
|
| D | SchedulerStressTest.kt | 24 val scheduler = dispatcher.asScheduler() in <lambda>() constant
31 val scheduler = dispatcher.asScheduler() in <lambda>() constant
63 val scheduler = dispatcher.asScheduler() in <lambda>() constant
70 val scheduler = dispatcher.asScheduler() in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | SchedulerTest.kt | 47 val scheduler = Dispatchers.Default.asScheduler() in <lambda>() constant
161 runSchedulerTest(nThreads = n) { scheduler -> in <lambda>() method
189 val scheduler = dispatcher.asScheduler() in <lambda>() constant
243 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
249 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
267 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
273 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
279 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
285 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
302 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
[all …]
|
| D | SchedulerStressTest.kt | 24 val scheduler = dispatcher.asScheduler() in <lambda>() constant
31 val scheduler = dispatcher.asScheduler() in <lambda>() constant
63 val scheduler = dispatcher.asScheduler() in <lambda>() constant
70 val scheduler = dispatcher.asScheduler() in <lambda>() constant
|
| /external/cronet/net/third_party/quiche/src/quiche/common/ |
| D | btree_scheduler_test.cc | 22 void ScheduleIds(BTreeScheduler<Id, Priority>& scheduler, in ScheduleIds()
30 std::vector<Id> PopAll(BTreeScheduler<Id, Priority>& scheduler) { in PopAll()
46 BTreeScheduler<int, int> scheduler; in TEST() local
83 BTreeScheduler<int, int> scheduler; in TEST() local
105 BTreeScheduler<int, int> scheduler; in TEST() local
134 BTreeScheduler<int, int> scheduler; in TEST() local
160 BTreeScheduler<int, int> scheduler; in TEST() local
171 BTreeScheduler<int, int> scheduler; in TEST() local
182 BTreeScheduler<int, int> scheduler; in TEST() local
193 BTreeScheduler<int, int> scheduler; in TEST() local
[all …]
|
| /external/webrtc/net/dcsctp/tx/ |
| D | stream_scheduler_test.cc | 50 std::map<StreamID, size_t> GetPacketCounts(StreamScheduler& scheduler, in GetPacketCounts()
74 TestStream(StreamScheduler& scheduler, in TestStream()
95 StreamScheduler scheduler(kMtu); in TEST() local
102 StreamScheduler scheduler(kMtu); in TEST() local
117 StreamScheduler scheduler(kMtu); in TEST() local
134 StreamScheduler scheduler(kMtu); in TEST() local
176 StreamScheduler scheduler(kMtu); in TEST() local
238 StreamScheduler scheduler(kMtu); in TEST() local
262 StreamScheduler scheduler(kMtu); in TEST() local
292 StreamScheduler scheduler(kMtu); in TEST() local
[all …]
|
| /external/swiftshader/third_party/marl/src/ |
| D | scheduler_test.cpp | 25 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F() local
30 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F() local
44 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
57 auto scheduler = marl::Scheduler::get(); in TEST_P() local
86 auto scheduler = marl::Scheduler::get(); in TEST_P() local
129 auto scheduler = marl::Scheduler::get(); in TEST_P() local
163 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
189 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
219 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
|
| D | marl_test.h | 62 auto scheduler = new marl::Scheduler(cfg); in SetUp() local
67 auto scheduler = marl::Scheduler::get(); in TearDown() local
69 delete scheduler; in TearDown() local
|
| /external/webrtc/video/ |
| D | decode_synchronizer_unittest.cc | 101 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
129 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
153 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
175 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
214 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
243 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST() local
|
| D | decode_synchronizer.cc | 116 auto scheduler = std::make_unique<SynchronizedFrameDecodeScheduler>(this); in CreateSynchronizedFrameScheduler() local
128 SynchronizedFrameDecodeScheduler* scheduler) { in OnFrameScheduled()
154 SynchronizedFrameDecodeScheduler* scheduler) { in RemoveFrameScheduler()
178 for (auto* scheduler : schedulers_) { in OnTick() local
|
| D | task_queue_frame_decode_scheduler_unittest.cc | 34 TaskQueueFrameDecodeScheduler scheduler(time_controller_.GetClock(), in TEST() local
60 TaskQueueFrameDecodeScheduler scheduler(time_controller_.GetClock(), in TEST() local
80 TaskQueueFrameDecodeScheduler scheduler(time_controller_.GetClock(), in TEST() local
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | adaptive_shared_batch_scheduler_test.cc | 47 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
72 std::shared_ptr<Scheduler> scheduler; in TEST() local
124 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
167 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
240 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
315 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
368 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
402 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
430 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
453 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
[all …]
|
| D | serial_device_batch_scheduler_test.cc | 44 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
69 std::shared_ptr<Scheduler> scheduler; in TEST() local
118 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
145 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
229 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
277 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
331 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
367 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
|
| D | shared_batch_scheduler_test.cc | 67 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
107 std::shared_ptr<Scheduler> scheduler, Scheduler::QueueOptions queue_options, in CreateQueue()
203 auto scheduler = CreateSharedBatchScheduler(num_batch_threads); in TEST_P() local
271 auto scheduler = CreateSharedBatchScheduler(/*num_batch_threads=*/2, &env); in TEST_P() local
355 auto scheduler = CreateSharedBatchScheduler(1, &env); in TEST_P() local
413 auto scheduler = CreateSharedBatchScheduler(2); in TEST_P() local
456 auto scheduler = CreateSharedBatchScheduler(2, &env); in TEST_P() local
509 auto scheduler = CreateSharedBatchScheduler(1, &env); in TEST_P() local
558 auto scheduler = CreateSharedBatchScheduler(/*num_batch_threads*/ 1); in TEST_P() local
632 auto scheduler = CreateSharedBatchScheduler(/*num_batch_threads*/ 2); in TEST_P() local
[all …]
|
| D | basic_batch_scheduler_test.cc | 46 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
73 std::unique_ptr<BasicBatchScheduler<FakeTask>> scheduler; in TEST() local
|
| /external/grpc-grpc/test/core/client_channel/lb_policy/ |
| D | static_stride_scheduler_test.cc | 67 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
82 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
97 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
119 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
141 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
175 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
194 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
212 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
|
| D | static_stride_scheduler_benchmark.cc | 61 const absl::optional<StaticStrideScheduler> scheduler = in BM_StaticStrideSchedulerPickNonAtomic() local
76 const absl::optional<StaticStrideScheduler> scheduler = in BM_StaticStrideSchedulerPickAtomic() local
92 const absl::optional<StaticStrideScheduler> scheduler = in BM_StaticStrideSchedulerMake() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/migration/ |
| D | TestCoroutineScopeTest.kt | 39 val scheduler = TestCoroutineScheduler() in <lambda>() constant
46 val scheduler = TestCoroutineScheduler() in <lambda>() constant
54 val scheduler = TestCoroutineScheduler() in <lambda>() constant
70 val scheduler = TestCoroutineScheduler() in <lambda>() constant
|
| /external/ComputeLibrary/src/runtime/ |
| D | RuntimeContext.cpp | 36 void RuntimeContext::set_scheduler(IScheduler *scheduler) in set_scheduler()
42 IScheduler *RuntimeContext::scheduler() in scheduler() function in arm_compute::RuntimeContext
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 27 private final Scheduler scheduler; field in RoboExecutorService
32 private final Scheduler scheduler; field in RoboExecutorService.AdvancingFutureTask
34 public AdvancingFutureTask(Scheduler scheduler, Callable<V> callable) { in AdvancingFutureTask()
39 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask()
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | blockingcall.h | 36 auto scheduler = Scheduler::get(); in call() local
61 auto scheduler = Scheduler::get(); in call() local
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/cancellation/ |
| D | CancellationServer.java | 55 ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); in main() local
80 private final ScheduledExecutorService scheduler; field in CancellationServer.SlowEcho
83 public SlowEcho(ScheduledExecutorService scheduler) { in SlowEcho()
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/ |
| D | ScheduledRetryingExecutor.java | 61 private final ListeningScheduledExecutorService scheduler; field in ScheduledRetryingExecutor
71 RetryAlgorithm<ResponseT> retryAlgorithm, ScheduledExecutorService scheduler) { in ScheduledRetryingExecutor()
|
| /external/mesa3d/src/intel/vulkan/grl/gpu/ |
| D | morton_msb_radix_bitonic_sort.h | 112 struct MSBDispatchArgs get_msb_dispatch_args(global struct VContextScheduler* scheduler) in get_msb_dispatch_args()
292 void DO_Create_Separate_BLS_Work(global struct VContextScheduler* scheduler, global struct MSBRadix… in DO_Create_Separate_BLS_Work()
322 void DO_Create_SG_Merged_BLS_Work_Parallel(global struct VContextScheduler* scheduler, global struc… in DO_Create_SG_Merged_BLS_Work_Parallel()
395 void DO_Create_SG_Merged_BLS_Work(global struct VContextScheduler* scheduler, global struct MSBRadi… in DO_Create_SG_Merged_BLS_Work()
459 void DO_Create_Work(global struct VContextScheduler* scheduler, global struct MSBRadixContext* cont… in DO_Create_Work()
566 global struct VContextScheduler* scheduler, in sort_morton_codes_msb_begin()
610 scheduler(global struct VContextScheduler* scheduler, global ulong* buf0, global ulong* buf1) in scheduler() argument
673 void kernel sort_morton_codes_bottom_level( global struct VContextScheduler* scheduler, global ulon… in sort_morton_codes_bottom_level()
713 void kernel sort_morton_codes_msb_count_items( global struct VContextScheduler* scheduler) in sort_morton_codes_msb_count_items()
814 global struct VContextScheduler* scheduler, global ulong* input) in sort_morton_codes_msb_bin_items()
|
| /external/pdfium/core/fxcrt/ |
| D | cfx_timer_unittest.cpp | 32 MockTimerScheduler scheduler; in TEST() local
62 MockTimerScheduler scheduler; in TEST() local
|