Home
last modified time | relevance | path

Searched defs:scheduler (Results 1 – 25 of 142) sorted by relevance

123456

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DSchedulerTest.kt47 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 …]
DSchedulerStressTest.kt24 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/
DSchedulerTest.kt47 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 …]
DSchedulerStressTest.kt24 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/
Dbtree_scheduler_test.cc21 void ScheduleIds(BTreeScheduler<Id, Priority>& scheduler, in ScheduleIds()
29 std::vector<Id> PopAll(BTreeScheduler<Id, Priority>& scheduler) { in PopAll()
45 BTreeScheduler<int, int> scheduler; in TEST() local
82 BTreeScheduler<int, int> scheduler; in TEST() local
104 BTreeScheduler<int, int> scheduler; in TEST() local
133 BTreeScheduler<int, int> scheduler; in TEST() local
159 BTreeScheduler<int, int> scheduler; in TEST() local
170 BTreeScheduler<int, int> scheduler; in TEST() local
181 BTreeScheduler<int, int> scheduler; in TEST() local
192 BTreeScheduler<int, int> scheduler; in TEST() local
[all …]
/external/webrtc/net/dcsctp/tx/
Dstream_scheduler_test.cc50 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/
Dscheduler_test.cpp25 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
Dmarl_test.h62 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/
Ddecode_synchronizer_unittest.cc101 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
Ddecode_synchronizer.cc116 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
Dtask_queue_frame_decode_scheduler_unittest.cc34 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/
Dadaptive_shared_batch_scheduler_test.cc47 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 …]
Dserial_device_batch_scheduler_test.cc44 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
Dshared_batch_scheduler_test.cc67 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 …]
Dbasic_batch_scheduler_test.cc46 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
73 std::unique_ptr<BasicBatchScheduler<FakeTask>> scheduler; in TEST() local
/external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/migration/
DTestCoroutineScopeTest.kt39 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/
DRuntimeContext.cpp36 void RuntimeContext::set_scheduler(IScheduler *scheduler) in set_scheduler()
42 IScheduler *RuntimeContext::scheduler() in scheduler() function in arm_compute::RuntimeContext
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/
DRoboExecutorService.java21 private final Scheduler scheduler; field in RoboExecutorService
26 private final Scheduler scheduler; field in RoboExecutorService.AdvancingFutureTask
28 public AdvancingFutureTask(Scheduler scheduler, Callable<V> callable) { in AdvancingFutureTask()
33 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask()
/external/robolectric/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/
DRoboExecutorService.java27 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/
Dblockingcall.h36 auto scheduler = Scheduler::get(); in call() local
61 auto scheduler = Scheduler::get(); in call() local
/external/grpc-grpc/src/core/lib/iomgr/
Dclosure.h84 grpc_closure_scheduler* scheduler; member
108 grpc_closure_scheduler* scheduler) {
130 #define GRPC_CLOSURE_INIT(closure, cb, cb_arg, scheduler) \ argument
133 #define GRPC_CLOSURE_INIT(closure, cb, cb_arg, scheduler) \ argument
158 grpc_closure_scheduler* scheduler) {
178 #define GRPC_CLOSURE_CREATE(cb, cb_arg, scheduler) \ argument
181 #define GRPC_CLOSURE_CREATE(cb, cb_arg, scheduler) \ argument
/external/pdfium/core/fxcrt/
Dcfx_timer_unittest.cpp32 MockTimerScheduler scheduler; in TEST() local
62 MockTimerScheduler scheduler; in TEST() local
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowContextImpl.java167 Handler scheduler, in sendOrderedBroadcast()
190 Handler scheduler, in sendOrderedBroadcastAsUser()
214 Handler scheduler, in sendOrderedBroadcastAsUser()
246 String broadcastPermission, Handler scheduler, int flags) { in registerReceiver()
256 Handler scheduler) { in registerReceiver()
267 Handler scheduler) { in registerReceiverAsUser()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractScheduledServiceTest.java83 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.NullService
361 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.TestService
517 TestCustomScheduler scheduler = new TestCustomScheduler(); in testCustomSchedule_startStop() local
621 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
667 protected Scheduler scheduler() { in scheduler() method in TestFailingCustomScheduledService
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractScheduledServiceTest.java83 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.NullService
361 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.TestService
517 TestCustomScheduler scheduler = new TestCustomScheduler(); in testCustomSchedule_startStop() local
621 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
667 protected Scheduler scheduler() { in scheduler() method in TestFailingCustomScheduledService

123456