| /external/robolectric-shadows/utils/src/test/java/org/robolectric/util/ |
| D | SchedulerTest.java | 18 private final Scheduler scheduler = new Scheduler(); field in SchedulerTest
25 scheduler.pause(); in setUp()
26 startTime = scheduler.getCurrentTime(); in setUp()
31 scheduler.setIdleState(CONSTANT_IDLE); in whenIdleStateIsConstantIdle_isPausedReturnsFalse()
32 assertThat(scheduler.isPaused()).isFalse(); in whenIdleStateIsConstantIdle_isPausedReturnsFalse()
37 scheduler.setIdleState(UNPAUSED); in whenIdleStateIsUnPaused_isPausedReturnsFalse()
38 assertThat(scheduler.isPaused()).isFalse(); in whenIdleStateIsUnPaused_isPausedReturnsFalse()
43 scheduler.setIdleState(PAUSED); in whenIdleStateIsPaused_isPausedReturnsTrue()
44 assertThat(scheduler.isPaused()).isTrue(); in whenIdleStateIsPaused_isPausedReturnsTrue()
49 scheduler.setIdleState(UNPAUSED); in pause_setsIdleState()
[all …]
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| D | SchedulerTest.java | 11 private Scheduler scheduler; field in SchedulerTest
15 scheduler = new Scheduler(); in setUp()
16 scheduler.pause(); in setUp()
22 scheduler.postDelayed(new AddToTranscript("one"), 0); in testTick_ReturnsTrueIffSomeJobWasRun()
23 scheduler.postDelayed(new AddToTranscript("two"), 0); in testTick_ReturnsTrueIffSomeJobWasRun()
24 scheduler.postDelayed(new AddToTranscript("three"), 1000); in testTick_ReturnsTrueIffSomeJobWasRun()
26 assertThat(scheduler.advanceBy(0), equalTo(true)); in testTick_ReturnsTrueIffSomeJobWasRun()
29 assertThat(scheduler.advanceBy(0), equalTo(false)); in testTick_ReturnsTrueIffSomeJobWasRun()
32 assertThat(scheduler.advanceBy(1000), equalTo(true)); in testTick_ReturnsTrueIffSomeJobWasRun()
38 scheduler.postDelayed(new AddToTranscript("one"), 1000); in testShadowPostDelayed()
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_sched.py | 46 scheduler = sched.scheduler(time.time, time.sleep)
48 z = scheduler.enter(x, 1, fun, (x,))
49 scheduler.run()
55 scheduler = sched.scheduler(time.time, time.sleep)
57 z = scheduler.enterabs(x, 1, fun, (x,))
58 scheduler.run()
66 scheduler = sched.scheduler(timer.time, timer.sleep)
67 scheduler.enter(1, 1, fun, (1,))
68 scheduler.enter(3, 1, fun, (3,))
69 t = threading.Thread(target=scheduler.run)
[all …]
|
| /external/v8/benchmarks/ |
| D | richards.js | 48 var scheduler = new Scheduler();
49 scheduler.addIdleTask(ID_IDLE, 0, null, COUNT);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
63 scheduler.addHandlerTask(ID_HANDLER_B, 3000, queue);
65 scheduler.addDeviceTask(ID_DEVICE_A, 4000, null);
67 scheduler.addDeviceTask(ID_DEVICE_B, 5000, null);
69 scheduler.schedule();
71 if (scheduler.queueCount != EXPECTED_QUEUE_COUNT ||
72 scheduler.holdCount != EXPECTED_HOLD_COUNT) {
[all …]
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowMediaPlayerTest.java | 59 private Scheduler scheduler; field in ShadowMediaPlayerTest
85 scheduler = Robolectric.getForegroundThreadScheduler(); in setUp()
86 scheduler.pause(); in setUp()
124 final long startTime = scheduler.getCurrentTime(); in testPrepare()
130 assertThat(scheduler.getCurrentTime()).isEqualTo(startTime + delay); in testPrepare()
185 final long startTime = scheduler.getCurrentTime(); in testPrepareAsyncAutoCallback()
190 scheduler.advanceToLastPostedRunnable(); in testPrepareAsyncAutoCallback()
191 assertThat(scheduler.getCurrentTime()).as("currentTime").isEqualTo( in testPrepareAsyncAutoCallback()
206 final long startTime = scheduler.getCurrentTime(); in testPrepareAsyncManualCallback()
209 assertThat(scheduler.getCurrentTime()).as("currentTime").isEqualTo( in testPrepareAsyncManualCallback()
[all …]
|
| D | ShadowMessageQueueTest.java | 31 private Scheduler scheduler; field in ShadowMessageQueueTest
62 scheduler = shadowQueue.getScheduler(); in setUp()
63 scheduler.pause(); in setUp()
116 assertThat(scheduler.size()).as("scheduler_size").isEqualTo(0); in enqueueMessage_doesntSchedule_whenQuitting()
122 scheduler.advanceTo(199); in enqueuedMessage_isSentToHandler()
124 scheduler.advanceTo(200); in enqueuedMessage_isSentToHandler()
131 assertThat(scheduler.size()).as("scheduler size:before").isEqualTo(1); in removedMessage_isNotSentToHandler()
133 scheduler.advanceToLastPostedRunnable(); in removedMessage_isNotSentToHandler()
134 assertThat(scheduler.size()).as("scheduler size:after").isEqualTo(0); in removedMessage_isNotSentToHandler()
143 scheduler.advanceToLastPostedRunnable(); in enqueueMessage_withZeroWhen_postsAtFront()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | adaptive_shared_batch_scheduler_test.cc | 44 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask() argument
46 Status status = scheduler->Schedule(&task); in ScheduleTask()
89 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
91 AdaptiveSharedBatchScheduler<FakeTask>::Create({}, &scheduler)); in TEST()
95 TF_ASSERT_OK(scheduler->AddQueue({}, queue_0_callback, &queue_0)); in TEST()
97 TF_ASSERT_OK(scheduler->AddQueue({}, queue_1_callback, &queue_1)); in TEST()
102 scheduler = nullptr; in TEST()
122 std::shared_ptr<Scheduler> scheduler; in TEST() local
125 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
130 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
[all …]
|
| D | basic_batch_scheduler_test.cc | 46 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask() argument
48 Status status = scheduler->Schedule(&task); in ScheduleTask()
73 std::unique_ptr<BasicBatchScheduler<FakeTask>> scheduler; in TEST() local
75 BasicBatchScheduler<FakeTask>::Create(options, callback, &scheduler)); in TEST()
76 EXPECT_EQ(10, scheduler->max_task_size()); in TEST()
77 EXPECT_EQ(0, scheduler->NumEnqueuedTasks()); in TEST()
78 EXPECT_EQ(3 * 10, scheduler->SchedulingCapacity()); in TEST()
79 TF_ASSERT_OK(ScheduleTask(3, scheduler.get())); in TEST()
80 EXPECT_EQ(1, scheduler->NumEnqueuedTasks()); in TEST()
81 EXPECT_EQ((3 * 10) - 3, scheduler->SchedulingCapacity()); in TEST()
[all …]
|
| D | shared_batch_scheduler_test.cc | 45 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask() argument
47 Status status = scheduler->Schedule(&task); in ScheduleTask()
94 std::shared_ptr<SharedBatchScheduler<FakeTask>> scheduler; in TEST() local
96 SharedBatchScheduler<FakeTask>::Create(options, &scheduler)); in TEST()
105 scheduler->AddQueue(queue_options, queue_0_callback, &queue_0)); in TEST()
108 scheduler->AddQueue(queue_options, queue_1_callback, &queue_1)); in TEST()
113 scheduler = nullptr; in TEST()
155 std::shared_ptr<SharedBatchScheduler<FakeTask>> scheduler; in TEST() local
156 TF_ASSERT_OK(SharedBatchScheduler<FakeTask>::Create(options, &scheduler)); in TEST()
162 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST()
[all …]
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowLooper.java | 21 private Scheduler scheduler = new Scheduler(); field in ShadowLooper
69 scheduler.reset();
108 scheduler.advanceBy(0);
118 scheduler.advanceBy(intervalMillis);
126 scheduler.advanceToLastPostedRunnable();
134 scheduler.advanceToNextPostedRunnable();
143 scheduler.runOneTask();
154 scheduler.postDelayed(runnable, delayMillis);
163 scheduler.postAtFrontOfQueue(runnable);
171 scheduler.pause();
[all …]
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 21 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() argument
30 this.scheduler = scheduler; in AdvancingFutureTask()
33 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask() argument
35 this.scheduler = scheduler; in AdvancingFutureTask()
41 scheduler.advanceToNextPostedRunnable(); in get()
48 this.scheduler = ShadowApplication.getInstance().getBackgroundThreadScheduler(); in RoboExecutorService()
61 scheduler.remove(runnable); in shutdownNow()
86 return schedule(new AdvancingFutureTask<T>(scheduler, tCallable)); in submit()
[all …]
|
| /external/strace/tests-mx32/ |
| D | sched_xetscheduler.c | 15 const char *scheduler; in main() local
18 scheduler = "SCHED_FIFO"; in main()
21 scheduler = "SCHED_RR"; in main()
25 scheduler = "SCHED_BATCH"; in main()
30 scheduler = "SCHED_IDLE"; in main()
35 scheduler = "SCHED_ISO"; in main()
40 scheduler = "SCHED_DEADLINE"; in main()
44 scheduler = "SCHED_OTHER"; in main()
47 rc, scheduler); in main()
|
| /external/strace/tests/ |
| D | sched_xetscheduler.c | 15 const char *scheduler; in main() local
18 scheduler = "SCHED_FIFO"; in main()
21 scheduler = "SCHED_RR"; in main()
25 scheduler = "SCHED_BATCH"; in main()
30 scheduler = "SCHED_IDLE"; in main()
35 scheduler = "SCHED_ISO"; in main()
40 scheduler = "SCHED_DEADLINE"; in main()
44 scheduler = "SCHED_OTHER"; in main()
47 rc, scheduler); in main()
|
| /external/strace/tests-m32/ |
| D | sched_xetscheduler.c | 15 const char *scheduler; in main() local
18 scheduler = "SCHED_FIFO"; in main()
21 scheduler = "SCHED_RR"; in main()
25 scheduler = "SCHED_BATCH"; in main()
30 scheduler = "SCHED_IDLE"; in main()
35 scheduler = "SCHED_ISO"; in main()
40 scheduler = "SCHED_DEADLINE"; in main()
44 scheduler = "SCHED_OTHER"; in main()
47 rc, scheduler); in main()
|
| /external/python/cpython2/Doc/library/ |
| D | sched.rst | 1 :mod:`sched` --- Event scheduler
5 :synopsis: General purpose event scheduler.
15 scheduler:
17 .. class:: scheduler(timefunc, delayfunc)
19 The :class:`scheduler` class defines a generic interface to scheduling events.
31 >>> s = sched.scheduler(time.time, time.sleep)
47 In multi-threaded environments, the :class:`scheduler` class has limitations
49 the one currently pending in a running scheduler, and holding up the main
79 :class:`scheduler` instances have the following methods and attributes:
82 .. method:: scheduler.enterabs(time, priority, action, argument)
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | sched.rst | 1 :mod:`sched` --- Event scheduler
5 :synopsis: General purpose event scheduler.
16 scheduler:
18 .. class:: scheduler(timefunc=time.monotonic, delayfunc=time.sleep)
20 The :class:`scheduler` class defines a generic interface to scheduling events.
34 :class:`scheduler` class can be safely used in multi-threaded
40 >>> s = sched.scheduler(time.time, time.sleep)
64 :class:`scheduler` instances have the following methods and attributes:
67 .. method:: scheduler.enterabs(time, priority, action, argument=(), kwargs={})
88 .. method:: scheduler.enter(delay, priority, action, argument=(), kwargs={})
[all …]
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowMessageQueue.java | 35 private Scheduler scheduler; field in ShadowMessageQueue
90 return scheduler; in getScheduler()
93 public void setScheduler(Scheduler scheduler) { in setScheduler() argument
94 this.scheduler = scheduler; in setScheduler()
143 scheduler.postAtFrontOfQueue(callback); in enqueueMessage()
145 scheduler.postDelayed(callback, when - scheduler.getCurrentTime()); in enqueueMessage()
|
| D | ShadowApplication.java | 358 … Handler scheduler, int initialCode, String initialData, Bundle initialExtras) { in sendOrderedBroadcast() argument
361 receivers.add(new Wrapper(resultReceiver, null, this.realApplication, null, scheduler)); in sendOrderedBroadcast()
388 final Handler scheduler = (wrapper.scheduler != null) ? wrapper.scheduler : getMainHandler(); in postIntent() local
392 scheduler.post(new Runnable() { in postIntent()
437 final Handler scheduler = (wrapper.scheduler != null) ? wrapper.scheduler : getMainHandler(); in postIntent() local
447 scheduler.post(new Runnable() { in postIntent()
535 …r(BroadcastReceiver receiver, IntentFilter filter, String broadcastPermission, Handler scheduler) {
536 …return registerReceiverWithContext(receiver, filter, broadcastPermission, scheduler, realApplicati…
539 …iver receiver, IntentFilter filter, String broadcastPermission, Handler scheduler, Context context…
541 … registeredReceivers.add(new Wrapper(receiver, filter, context, broadcastPermission, scheduler));
[all …]
|
| /external/v8/src/compiler/ |
| D | instruction-scheduler.h | 102 explicit SchedulingQueueBase(InstructionScheduler* scheduler) in SchedulingQueueBase() argument
103 : scheduler_(scheduler), in SchedulingQueueBase()
104 nodes_(scheduler->zone()) { in SchedulingQueueBase()
123 explicit CriticalPathFirstQueue(InstructionScheduler* scheduler) in CriticalPathFirstQueue() argument
124 : SchedulingQueueBase(scheduler) { } in CriticalPathFirstQueue()
135 explicit StressSchedulerQueue(InstructionScheduler* scheduler) in StressSchedulerQueue() argument
136 : SchedulingQueueBase(scheduler) { } in StressSchedulerQueue()
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | virtual_cluster.cc | 59 VirtualScheduler scheduler(&item, true, this, node_manager_.get()); in Run() local
60 TF_RETURN_IF_ERROR(scheduler.Init()); in Run()
70 OpContext op_context = scheduler.GetCurrNode(); in Run()
96 } while (scheduler.MarkCurrNodeExecuted(node_costs)); in Run()
99 scheduler.Summary(metadata); in Run()
104 scheduler.GetPeakMemoryUsage(); in Run()
|
| /external/ltp/tools/pounder21/doc/ |
| D | SCHEDULER | 24 The scheduler in the original pounder release was too simplistic--it would kick
56 - The tests/ directory represents our unpackaged "test scheduler" (if your tests/
58 need run "make install" to unpack a scheduler - see "The Provided Test Schedulers"
60 an unpacked test scheduler should look like). The files in the tests/ directory are
104 used by the test scheduler to stop tests.
131 test scheduler borrows a System V rc script-like structure for specifying how and
138 signifies a test, which means that the scheduler starts the test, waits for the
140 "test", which is to say that the scheduler will start the test, let it run in
157 directories, symbolic links, or files. The test scheduler will not run
163 Let's examine the following test scheduler hierarchy:
[all …]
|
| /external/tensorflow/tensorflow/core/grappler/costs/ |
| D | analytical_cost_estimator.cc | 67 VirtualScheduler scheduler(&item, use_static_shapes_, cluster_, in PredictCosts() local
69 auto status = scheduler.Init(); in PredictCosts()
78 OpContext op_context = scheduler.GetCurrNode(); in PredictCosts()
108 } while (scheduler.MarkCurrNodeExecuted(node_costs)); in PredictCosts()
111 *costs = scheduler.Summary(&run_metadata); in PredictCosts()
|
| /external/llvm/test/CodeGen/AMDGPU/ |
| D | si-scheduler.ll | 1 ; FIXME: The si scheduler crashes if when lane mask tracking is enabled, so
2 ; we need to disable this when the si scheduler is being used.
3 ; The only way the subtarget knows that the si machine scheduler is being used
4 ; is to specify -mattr=si-scheduler. If we just pass --misched=si, the backend
5 ; won't know what scheduler we are using.
6 ; RUN: llc -march=amdgcn -mcpu=SI --misched=si -mattr=si-scheduler < %s | FileCheck %s
8 ; The test checks the "si" machine scheduler pass works correctly.
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractScheduledServiceTest.java | 69 @Override protected Scheduler scheduler() { return configuration; } in scheduler() method in AbstractScheduledServiceTest.NullService
161 @Override protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceIsStopped()
188 @Override protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceFails()
273 protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.TestService
351 TestCustomScheduler scheduler = new TestCustomScheduler(); in testCustomSchedule_startStop() local
352 Future<?> future = scheduler.schedule(null, Executors.newScheduledThreadPool(10), task); in testCustomSchedule_startStop()
354 assertEquals(1, scheduler.scheduleCounter.get()); in testCustomSchedule_startStop()
357 assertEquals(2, scheduler.scheduleCounter.get()); in testCustomSchedule_startStop()
378 @Override protected Scheduler scheduler() { in testBig()
424 @Override protected Scheduler scheduler() { in scheduler() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
[all …]
|
| /external/ltp/tools/pounder21/ |
| D | pounder | 36 …tion] [-n ipaddr] [-m max_failures] [-f] [-h|-u|-r|-k|-l|-e subtests|-i subtests|-c scheduler] [-s]
39 -c scheduler Creates a new test scheduler called scheduler-tests.tar.gz in the pounder/schedulers f…
40 All subtests to be packaged with this scheduler must first be placed in the pounder/tests folder.
49 -l List (both included and excluded) subtests that came with the test scheduler
|