| /external/skqp/src/compute/skc/ |
| D | scheduler.cpp | 73 struct scheduler * scheduler;
133 struct skc_scheduler * scheduler = (struct skc_scheduler*) in skc_scheduler_create() local
134 skc_runtime_host_perm_alloc(runtime,SKC_MEM_FLAGS_READ_WRITE,sizeof(*scheduler)); in skc_scheduler_create()
137 new (scheduler) skc_scheduler(); in skc_scheduler_create()
140 scheduler->extent = (struct skc_scheduler_command*) in skc_scheduler_create()
141 … skc_runtime_host_perm_alloc(runtime,SKC_MEM_FLAGS_READ_WRITE,(sizeof(*scheduler->extent) * size)); in skc_scheduler_create()
143 scheduler->available.indices = (skc_ushort*) in skc_scheduler_create()
144 …skc_runtime_host_perm_alloc(runtime,SKC_MEM_FLAGS_READ_WRITE,sizeof(*scheduler->available.indices)… in skc_scheduler_create()
146 scheduler->available.rem = size; in skc_scheduler_create()
148 scheduler->waiting.indices = (skc_ushort*) in skc_scheduler_create()
[all …]
|
| /external/robolectric-shadows/utils/src/test/java/org/robolectric/util/ |
| D | SchedulerTest.java | 24 private final Scheduler scheduler = new Scheduler(); field in SchedulerTest
31 scheduler.pause(); in setUp()
32 startTime = scheduler.getCurrentTime(); in setUp()
37 scheduler.setIdleState(CONSTANT_IDLE); in whenIdleStateIsConstantIdle_isPausedReturnsFalse()
38 assertThat(scheduler.isPaused()).isFalse(); in whenIdleStateIsConstantIdle_isPausedReturnsFalse()
43 scheduler.setIdleState(UNPAUSED); in whenIdleStateIsUnPaused_isPausedReturnsFalse()
44 assertThat(scheduler.isPaused()).isFalse(); in whenIdleStateIsUnPaused_isPausedReturnsFalse()
49 scheduler.setIdleState(PAUSED); in whenIdleStateIsPaused_isPausedReturnsTrue()
50 assertThat(scheduler.isPaused()).isTrue(); in whenIdleStateIsPaused_isPausedReturnsTrue()
55 scheduler.setIdleState(UNPAUSED); in pause_setsIdleState()
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_sched.py | 45 scheduler = sched.scheduler(time.time, time.sleep)
47 z = scheduler.enter(x, 1, fun, (x,))
48 scheduler.run()
54 scheduler = sched.scheduler(time.time, time.sleep)
56 z = scheduler.enterabs(x, 1, fun, (x,))
57 scheduler.run()
64 scheduler = sched.scheduler(timer.time, timer.sleep)
65 scheduler.enter(1, 1, fun, (1,))
66 scheduler.enter(3, 1, fun, (3,))
67 t = threading.Thread(target=scheduler.run)
[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
32 scheduler->bind(); in TEST_F()
34 ASSERT_EQ(scheduler.get(), got); in TEST_F()
35 scheduler->unbind(); in TEST_F()
44 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
46 auto gotCfg = scheduler->config(); in TEST_F()
57 auto scheduler = marl::Scheduler::get(); in TEST_P() local
58 scheduler->unbind(); in TEST_P()
59 delete scheduler; in TEST_P()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | serial_device_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()
69 std::shared_ptr<Scheduler> scheduler; in TEST() local
74 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
77 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
81 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
84 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
87 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
89 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
118 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
[all …]
|
| D | adaptive_shared_batch_scheduler_test.cc | 47 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask() argument
49 Status status = scheduler->Schedule(&task); in ScheduleTask()
72 std::shared_ptr<Scheduler> scheduler; in TEST() local
75 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
78 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
82 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
85 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
88 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
92 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
97 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-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowMediaPlayerTest.java | 67 private Scheduler scheduler; field in ShadowMediaPlayerTest
93 scheduler = Robolectric.getForegroundThreadScheduler(); in setUp()
94 scheduler.pause(); in setUp()
146 final long startTime = scheduler.getCurrentTime(); in testPrepare()
152 assertThat(scheduler.getCurrentTime()).isEqualTo(startTime + delay); in testPrepare()
207 final long startTime = scheduler.getCurrentTime(); in testPrepareAsyncAutoCallback()
212 scheduler.advanceToLastPostedRunnable(); in testPrepareAsyncAutoCallback()
213 assertWithMessage("currentTime").that(scheduler.getCurrentTime()).isEqualTo( in testPrepareAsyncAutoCallback()
228 final long startTime = scheduler.getCurrentTime(); in testPrepareAsyncManualCallback()
231 assertWithMessage("currentTime").that(scheduler.getCurrentTime()).isEqualTo( in testPrepareAsyncManualCallback()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | KeepAliveManagerTest.java | 49 @Mock private ScheduledExecutorService scheduler; field in KeepAliveManagerTest
65 keepAliveManager = new KeepAliveManager(keepAlivePinger, scheduler, ticker, 1000, 2000, false); in setUp()
75 verify(scheduler, times(1)).schedule(sendPingCaptor.capture(), delayCaptor.capture(), in sendKeepAlivePings()
83 .when(scheduler).schedule(isA(Runnable.class), isA(Long.class), isA(TimeUnit.class)); in sendKeepAlivePings()
88 verify(scheduler, times(2)).schedule(isA(Runnable.class), delayCaptor.capture(), in sendKeepAlivePings()
97 verify(scheduler, times(3)).schedule(isA(Runnable.class), delayCaptor.capture(), in sendKeepAlivePings()
110 .when(scheduler).schedule(isA(Runnable.class), isA(Long.class), isA(TimeUnit.class)); in keepAlivePingDelayedByIncomingData()
115 verify(scheduler, times(1)).schedule(sendPingCaptor.capture(), isA(Long.class), in keepAlivePingDelayedByIncomingData()
129 verify(scheduler, times(2)).schedule(isA(Runnable.class), delayCaptor.capture(), in keepAlivePingDelayedByIncomingData()
172 verify(scheduler, times(1)) in onTransportTerminationCancelsShutdownFuture()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-interval.hpp | 54 …interval_initial_type(rxsc::scheduler::clock_type::time_point i, rxsc::scheduler::clock_type::dura… in interval_initial_type()
60 rxsc::scheduler::clock_type::time_point initial;
61 rxsc::scheduler::clock_type::duration period;
66 …interval(rxsc::scheduler::clock_type::time_point i, rxsc::scheduler::clock_type::duration p, coord… in interval()
100 std::is_convertible<Duration, rxsc::scheduler::clock_type::duration>::value,
123 auto interval(rxsc::scheduler::clock_type::duration period, Coordination cn) in interval()
125 … detail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::value, in interval()
126 …typename detail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::observabl… in interval()
127 …return detail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::make(… in interval()
133 auto interval(rxsc::scheduler::clock_type::time_point when, Duration period) in interval()
[all …]
|
| /external/pdfium/core/fxcrt/ |
| D | cfx_timer_unittest.cpp | 34 MockTimerScheduler scheduler; in TEST() local
35 EXPECT_CALL(scheduler, SetTimer(100, _)) in TEST()
37 EXPECT_CALL(scheduler, SetTimer(200, _)) in TEST()
39 EXPECT_CALL(scheduler, KillTimer(1001)); in TEST()
40 EXPECT_CALL(scheduler, KillTimer(1002)); in TEST()
48 auto timer1 = pdfium::MakeUnique<CFX_Timer>(&scheduler, &cb1, 100); in TEST()
49 auto timer2 = pdfium::MakeUnique<CFX_Timer>(&scheduler, &cb2, 200); in TEST()
64 MockTimerScheduler scheduler; in TEST() local
65 EXPECT_CALL(scheduler, SetTimer(100, _)) in TEST()
67 EXPECT_CALL(scheduler, KillTimer(1001)); in TEST()
[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/rust/crates/tokio/src/runtime/task/ |
| D | core.rs | 40 scheduler: UnsafeCell<Option<S>>, field
52 pub(super) scheduler: Scheduler<S>, field
105 scheduler: Scheduler { in new()
106 scheduler: UnsafeCell::new(None), in new()
121 self.scheduler.with_mut(f) in with_mut()
144 let scheduler = S::bind(task); in bind_scheduler() localVariable
147 self.scheduler.with_mut(|ptr| unsafe { in bind_scheduler()
148 *ptr = Some(scheduler); in bind_scheduler()
155 self.scheduler.with(|ptr| unsafe { (*ptr).is_some() }) in is_bound()
160 self.scheduler.with(|ptr| { in schedule()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Scheduler.kt | 9 import reactor.core.scheduler.Scheduler
26 public val scheduler: Scheduler in asCoroutineDispatcher() constant in kotlinx.coroutines.reactor.SchedulerCoroutineDispatcher
30 scheduler.schedule(block) in asCoroutineDispatcher()
35 val disposable = scheduler.schedule({ in asCoroutineDispatcher()
43 scheduler.schedule(block, timeMillis, TimeUnit.MILLISECONDS).asDisposableHandle() in asCoroutineDispatcher()
46 override fun toString(): String = scheduler.toString() in asCoroutineDispatcher()
48 …uals(other: Any?): Boolean = other is SchedulerCoroutineDispatcher && other.scheduler === scheduler in asCoroutineDispatcher()
50 override fun hashCode(): Int = System.identityHashCode(scheduler) in asCoroutineDispatcher()
|
| /external/skqp/src/compute/skc/platforms/cl_12/ |
| D | styling_cl_12.c | 48 struct skc_scheduler * const scheduler = impl->runtime->scheduler; in skc_styling_unmap_cb() local
51 SKC_SCHEDULER_SCHEDULE(scheduler,skc_styling_unmap_complete,grid); in skc_styling_unmap_cb()
91 struct skc_scheduler * const scheduler = runtime->scheduler; in skc_styling_pfn_seal() local
98 SKC_SCHEDULER_WAIT_WHILE(scheduler,impl->state != SKC_STYLING_STATE_UNSEALED); in skc_styling_pfn_seal()
136 SKC_SCHEDULER_SCHEDULE(impl->runtime->scheduler,skc_styling_unseal_complete,impl); in skc_styling_unseal_cb()
151 struct skc_scheduler * const scheduler = runtime->scheduler; in skc_styling_pfn_unseal() local
159 SKC_SCHEDULER_WAIT_WHILE(scheduler,impl->state != SKC_STYLING_STATE_UNSEALED); in skc_styling_pfn_unseal()
170 SKC_SCHEDULER_WAIT_WHILE(scheduler,impl->state != SKC_STYLING_STATE_SEALED); in skc_styling_pfn_unseal()
174 SKC_SCHEDULER_WAIT_WHILE(scheduler,impl->lock_count > 0); in skc_styling_pfn_unseal()
199 SKC_SCHEDULER_WAIT_WHILE(scheduler,impl->state != SKC_STYLING_STATE_UNSEALED); in skc_styling_pfn_unseal()
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | closure.h | 84 grpc_closure_scheduler* scheduler; member
108 grpc_closure_scheduler* scheduler) { argument
112 grpc_closure_scheduler* scheduler) {
116 closure->scheduler = scheduler;
130 #define GRPC_CLOSURE_INIT(closure, cb, cb_arg, scheduler) \ argument
131 grpc_closure_init(__FILE__, __LINE__, closure, cb, cb_arg, scheduler)
133 #define GRPC_CLOSURE_INIT(closure, cb, cb_arg, scheduler) \ argument
134 grpc_closure_init(closure, cb, cb_arg, scheduler)
158 grpc_closure_scheduler* scheduler) { argument
161 grpc_closure_scheduler* scheduler) {
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxScheduler.kt | 25 public val scheduler: Scheduler in asCoroutineDispatcher() constant in kotlinx.coroutines.rx2.SchedulerCoroutineDispatcher
29 scheduler.scheduleDirect(block) in asCoroutineDispatcher()
34 val disposable = scheduler.scheduleDirect({ in asCoroutineDispatcher()
42 val disposable = scheduler.scheduleDirect(block, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
47 override fun toString(): String = scheduler.toString() in asCoroutineDispatcher()
49 …uals(other: Any?): Boolean = other is SchedulerCoroutineDispatcher && other.scheduler === scheduler in asCoroutineDispatcher()
51 override fun hashCode(): Int = System.identityHashCode(scheduler) in asCoroutineDispatcher()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | delay.cpp | 9 auto scheduler = rxcpp::identity_current_thread(); variable
10 auto start = scheduler.now();
14 auto t = duration_cast<milliseconds>(scheduler.now() - start); in __anon9cdd0dfe0102()
19 auto values = rxcpp::observable<>::interval(start, period, scheduler).
34 auto scheduler = rxcpp::identity_current_thread(); variable
35 auto start = scheduler.now();
39 auto t = duration_cast<milliseconds>(scheduler.now() - start); in __anon9cdd0dfe0402()
44 auto values = rxcpp::observable<>::interval(start, period, scheduler).
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxScheduler.kt | 25 public val scheduler: Scheduler in asCoroutineDispatcher() constant in kotlinx.coroutines.rx3.SchedulerCoroutineDispatcher
29 scheduler.scheduleDirect(block) in asCoroutineDispatcher()
34 val disposable = scheduler.scheduleDirect({ in asCoroutineDispatcher()
42 val disposable = scheduler.scheduleDirect(block, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
47 override fun toString(): String = scheduler.toString() in asCoroutineDispatcher()
49 …uals(other: Any?): Boolean = other is SchedulerCoroutineDispatcher && other.scheduler === scheduler in asCoroutineDispatcher()
51 override fun hashCode(): Int = System.identityHashCode(scheduler) in asCoroutineDispatcher()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | basic_scheduler.rs | 202 enter(self, |scheduler, context| { in block_on()
204 let waker = scheduler.spawner.waker_ref(); in block_on()
211 if scheduler.spawner.was_woken() || !polled { in block_on()
220 let tick = scheduler.tick; in block_on()
221 scheduler.tick = scheduler.tick.wrapping_add(1); in block_on()
224 scheduler.spawner.pop().or_else(|| { in block_on()
239 .or_else(|| scheduler.spawner.pop()) in block_on()
246 scheduler.park.park().expect("failed to park"); in block_on()
279 scheduler in block_on()
290 fn enter<F, R, P>(scheduler: &mut Inner<P>, f: F) -> R in enter()
[all …]
|
| /external/Reactive-Extensions/RxCpp/ |
| D | DeveloperManual.md | 3 ## Some comments on the scheduler system
5 …scheduler in rxcpp v2 is based on the scheduler and worker constructs that *RxJava* uses (Eric Mei…
7 …scheduler``` owns a timeline that is exposed by the ```now()``` method. ```scheduler``` is also a …
15 ```coordination``` is a factory for ```coordinator```s and has a scheduler.
19 …n time (even ```subscribe_on``` and ```observe_on```) take a coordination parameter, not scheduler.
21 Here are some supplied functions that will produce a coordination using a particular scheduler.
32 …scheduler yet. A thread-pool scheduler requires taking a dependency on a thread-pool implementatio…
|