Home
last modified time | relevance | path

Searched refs:Scheduler (Results 1 – 25 of 208) sorted by relevance

123456789

/external/swiftshader/third_party/marl/src/
Dscheduler_test.cpp25 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F()
26 new marl::Scheduler(marl::Scheduler::Config())); in TEST_F()
30 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F()
31 new marl::Scheduler(marl::Scheduler::Config())); in TEST_F()
33 auto got = marl::Scheduler::get(); in TEST_F()
36 got = marl::Scheduler::get(); in TEST_F()
41 marl::Scheduler::Config cfg; in TEST_F()
44 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F()
57 auto scheduler = marl::Scheduler::get(); in TEST_P()
65 (new marl::Scheduler(marl::Scheduler::Config()))->bind(); in TEST_P()
[all …]
Dscheduler.cpp71 inline marl::Scheduler::Config setConfigDefaults( in setConfigDefaults()
72 const marl::Scheduler::Config& cfgIn) { in setConfigDefaults()
73 marl::Scheduler::Config cfg{cfgIn}; in setConfigDefaults()
88 thread_local Scheduler* Scheduler::bound = nullptr;
90 Scheduler* Scheduler::get() { in get()
94 void Scheduler::bind() { in bind()
113 void Scheduler::unbind() { in unbind()
132 Scheduler::Scheduler(const Config& config) in Scheduler() function in marl::Scheduler
148 Scheduler::~Scheduler() { in ~Scheduler()
168 void Scheduler::enqueue(Task&& task) { in enqueue()
[all …]
/external/swiftshader/third_party/marl/include/marl/
Dscheduler.h44 class Scheduler {
96 Scheduler(const Config&);
101 ~Scheduler();
105 static Scheduler* get();
223 friend class Scheduler; variable
276 Scheduler(const Scheduler&) = delete;
277 Scheduler(Scheduler&&) = delete;
278 Scheduler& operator=(const Scheduler&) = delete;
279 Scheduler& operator=(Scheduler&&) = delete;
337 Worker(Scheduler* scheduler, Mode mode, uint32_t id);
[all …]
Dblockingcall.h36 auto scheduler = Scheduler::get(); in call()
44 Scheduler::unbind(); in call()
61 auto scheduler = Scheduler::get(); in call()
69 Scheduler::unbind(); in call()
/external/swiftshader/third_party/llvm-10.0/llvm/lib/MCA/HardwareUnits/
DScheduler.cpp22 void Scheduler::initializeStrategy(std::unique_ptr<SchedulerStrategy> S) { in initializeStrategy()
32 void Scheduler::dump() const { in dump()
40 Scheduler::Status Scheduler::isAvailable(const InstRef &IR) { in isAvailable()
47 return Scheduler::SC_BUFFERS_FULL; in isAvailable()
49 return Scheduler::SC_DISPATCH_GROUP_STALL; in isAvailable()
60 return Scheduler::SC_LOAD_QUEUE_FULL; in isAvailable()
62 return Scheduler::SC_STORE_QUEUE_FULL; in isAvailable()
64 return Scheduler::SC_AVAILABLE; in isAvailable()
70 void Scheduler::issueInstructionImpl( in issueInstructionImpl()
99 void Scheduler::issueInstruction( in issueInstruction()
[all …]
/external/llvm-project/llvm/lib/MCA/HardwareUnits/
DScheduler.cpp22 void Scheduler::initializeStrategy(std::unique_ptr<SchedulerStrategy> S) { in initializeStrategy()
32 void Scheduler::dump() const { in dump()
40 Scheduler::Status Scheduler::isAvailable(const InstRef &IR) { in isAvailable()
47 return Scheduler::SC_BUFFERS_FULL; in isAvailable()
49 return Scheduler::SC_DISPATCH_GROUP_STALL; in isAvailable()
60 return Scheduler::SC_LOAD_QUEUE_FULL; in isAvailable()
62 return Scheduler::SC_STORE_QUEUE_FULL; in isAvailable()
64 return Scheduler::SC_AVAILABLE; in isAvailable()
70 void Scheduler::issueInstructionImpl( in issueInstructionImpl()
99 void Scheduler::issueInstruction( in issueInstruction()
[all …]
/external/llvm-project/llvm/include/llvm/Support/
DTaskQueue.h69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() argument
73 Scheduler.wait(); in ~TaskQueue()
97 Scheduler.async(std::move(T)); in async()
120 Scheduler.async(std::move(Continuation)); in completeTask()
124 ThreadPool &Scheduler; variable
/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/
DTaskQueue.h69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() argument
73 Scheduler.wait(); in ~TaskQueue()
97 Scheduler.async(std::move(T)); in async()
120 Scheduler.async(std::move(Continuation)); in completeTask()
124 ThreadPool &Scheduler; variable
/external/swiftshader/third_party/marl/docs/
Dscheduler.md1 # `marl::Scheduler`
5 - [`marl::Scheduler`](#marlscheduler)
10 - [`marl::Scheduler::Worker::run()`](#marlschedulerworkerrun)
11 - [`marl::Scheduler::Worker::runUntilIdle()`](#marlschedulerworkerrununtilidle)
12 - [`marl::Scheduler::Worker::waitForWork()`](#marlschedulerworkerwaitforwork)
13 - [`marl::Scheduler::Worker::spinForWork()`](#marlschedulerworkerspinforwork)
14 - [`marl::Scheduler::Worker::suspend()`](#marlschedulerworkersuspend)
19 The `marl::Scheduler` is the most complex part of marl and is responsible for executing tasks and k…
28 Binding is made using the `marl::Scheduler::bind()` and `marl::Scheduler::unbind()` methods.
32 …rious synchronization primitives to be called without requiring a pointer to the `marl::Scheduler`.
[all …]
/external/tensorflow/tensorflow/core/kernels/batching_util/
Dadaptive_shared_batch_scheduler_test.cc71 using Scheduler = AdaptiveSharedBatchScheduler<FakeTask>; in TEST() typedef
72 std::shared_ptr<Scheduler> scheduler; in TEST()
73 Scheduler::Options options; in TEST()
75 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
76 options = Scheduler::Options(); in TEST()
78 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
79 options = Scheduler::Options(); in TEST()
82 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
83 options = Scheduler::Options(); in TEST()
85 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
[all …]
Dserial_device_batch_scheduler_test.cc68 using Scheduler = SerialDeviceBatchScheduler<FakeTask>; in TEST() typedef
69 std::shared_ptr<Scheduler> scheduler; in TEST()
70 Scheduler::Options default_options; in TEST()
72 Scheduler::Options options = default_options; in TEST()
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()
88 options = Scheduler::Options(); in TEST()
[all …]
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractScheduledServiceTest.java20 import static com.google.common.util.concurrent.AbstractScheduledService.Scheduler.newFixedDelaySch…
24 import com.google.common.util.concurrent.AbstractScheduledService.Scheduler;
51 volatile Scheduler configuration = newFixedDelaySchedule(0, 10, TimeUnit.MILLISECONDS);
80 protected Scheduler scheduler() { in scheduler()
208 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceIsStopped()
240 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceFails()
277 protected Scheduler scheduler() { in testTimeout()
278 return Scheduler.newFixedDelaySchedule(0, 1, TimeUnit.NANOSECONDS); in testTimeout()
358 protected Scheduler scheduler() { in scheduler()
390 Scheduler schedule = Scheduler.newFixedRateSchedule(initialDelay, delay, unit); in testFixedRateSchedule()
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractScheduledServiceTest.java20 import static com.google.common.util.concurrent.AbstractScheduledService.Scheduler.newFixedDelaySch…
24 import com.google.common.util.concurrent.AbstractScheduledService.Scheduler;
51 volatile Scheduler configuration = newFixedDelaySchedule(0, 10, TimeUnit.MILLISECONDS);
80 protected Scheduler scheduler() { in scheduler()
208 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceIsStopped()
240 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceFails()
277 protected Scheduler scheduler() { in testTimeout()
278 return Scheduler.newFixedDelaySchedule(0, 1, TimeUnit.NANOSECONDS); in testTimeout()
358 protected Scheduler scheduler() { in scheduler()
390 Scheduler schedule = Scheduler.newFixedRateSchedule(initialDelay, delay, unit); in testFixedRateSchedule()
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractScheduledService.java114 public abstract static class Scheduler { class in AbstractScheduledService
124 public static Scheduler newFixedDelaySchedule(Duration initialDelay, Duration delay) { in newFixedDelaySchedule()
139 public static Scheduler newFixedDelaySchedule( in newFixedDelaySchedule()
143 return new Scheduler() { in newFixedDelaySchedule()
160 public static Scheduler newFixedRateSchedule(Duration initialDelay, Duration period) { in newFixedRateSchedule()
174 public static Scheduler newFixedRateSchedule( in newFixedRateSchedule()
178 return new Scheduler() { in newFixedRateSchedule()
191 private Scheduler() {}
338 protected abstract Scheduler scheduler();
482 public abstract static class CustomScheduler extends Scheduler {
/external/swiftshader/third_party/llvm-10.0/llvm/lib/CodeGen/
DPostRASchedulerList.cpp314 SchedulePostRATDList Scheduler(Fn, MLI, AA, RegClassInfo, AntiDepMode, in runOnMachineFunction() local
331 Scheduler.startBlock(&MBB); in runOnMachineFunction()
344 Scheduler.enterRegion(&MBB, I, Current, CurrentCount - Count); in runOnMachineFunction()
345 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
346 Scheduler.schedule(); in runOnMachineFunction()
347 Scheduler.exitRegion(); in runOnMachineFunction()
348 Scheduler.EmitSchedule(); in runOnMachineFunction()
351 Scheduler.Observe(MI, CurrentCount); in runOnMachineFunction()
360 Scheduler.enterRegion(&MBB, MBB.begin(), Current, CurrentCount); in runOnMachineFunction()
361 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
[all …]
/external/llvm/lib/CodeGen/
DPostRASchedulerList.cpp314 SchedulePostRATDList Scheduler(Fn, MLI, AA, RegClassInfo, AntiDepMode, in runOnMachineFunction() local
331 Scheduler.startBlock(&MBB); in runOnMachineFunction()
344 Scheduler.enterRegion(&MBB, I, Current, CurrentCount - Count); in runOnMachineFunction()
345 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
346 Scheduler.schedule(); in runOnMachineFunction()
347 Scheduler.exitRegion(); in runOnMachineFunction()
348 Scheduler.EmitSchedule(); in runOnMachineFunction()
351 Scheduler.Observe(MI, CurrentCount); in runOnMachineFunction()
360 Scheduler.enterRegion(&MBB, MBB.begin(), Current, CurrentCount); in runOnMachineFunction()
361 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
[all …]
/external/llvm-project/llvm/lib/CodeGen/
DPostRASchedulerList.cpp312 SchedulePostRATDList Scheduler(Fn, MLI, AA, RegClassInfo, AntiDepMode, in runOnMachineFunction() local
329 Scheduler.startBlock(&MBB); in runOnMachineFunction()
342 Scheduler.enterRegion(&MBB, I, Current, CurrentCount - Count); in runOnMachineFunction()
343 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
344 Scheduler.schedule(); in runOnMachineFunction()
345 Scheduler.exitRegion(); in runOnMachineFunction()
346 Scheduler.EmitSchedule(); in runOnMachineFunction()
349 Scheduler.Observe(MI, CurrentCount); in runOnMachineFunction()
358 Scheduler.enterRegion(&MBB, MBB.begin(), Current, CurrentCount); in runOnMachineFunction()
359 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
[all …]
/external/llvm-project/llvm/include/llvm/MCA/HardwareUnits/
DScheduler.h70 class Scheduler : public HardwareUnit {
157 Scheduler(const MCSchedModel &Model, LSUnitBase &Lsu) in Scheduler() function
158 : Scheduler(Model, Lsu, nullptr) {} in Scheduler()
160 Scheduler(const MCSchedModel &Model, LSUnitBase &Lsu, in Scheduler() function
162 : Scheduler(std::make_unique<ResourceManager>(Model), Lsu, in Scheduler()
165 Scheduler(std::unique_ptr<ResourceManager> RM, LSUnitBase &Lsu, in Scheduler() function
/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/MCA/HardwareUnits/
DScheduler.h70 class Scheduler : public HardwareUnit {
157 Scheduler(const MCSchedModel &Model, LSUnitBase &Lsu) in Scheduler() function
158 : Scheduler(Model, Lsu, nullptr) {} in Scheduler()
160 Scheduler(const MCSchedModel &Model, LSUnitBase &Lsu, in Scheduler() function
162 : Scheduler(std::make_unique<ResourceManager>(Model), Lsu, in Scheduler()
165 Scheduler(std::unique_ptr<ResourceManager> RM, LSUnitBase &Lsu, in Scheduler() function
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/
DShadowLooperTest.java25 import org.robolectric.util.Scheduler;
208 Scheduler old = sLooper.getScheduler(); in shouldSetNewScheduler_whenLooperIsReset()
248 Scheduler scheduler = shadowOf(mainLooper).getScheduler(); in soStaticRefsToLoopersInAppWorksAcrossTests_shouldRetainSameLooperForMainThreadBetweenResetsButGiveItAFreshScheduler()
251 Scheduler s = new Scheduler(); in soStaticRefsToLoopersInAppWorksAcrossTests_shouldRetainSameLooperForMainThreadBetweenResetsButGiveItAFreshScheduler()
282 Scheduler s = new Scheduler(); in reset_setsGlobalScheduler_forMainLooper_byDefault()
292 Scheduler s = new Scheduler(); in reset_setsGlobalScheduler_forMainLooper_withAdvancedScheduling()
302 Scheduler old = sLooper.getScheduler(); in reset_setsNewScheduler_forNonMainLooper_byDefault()
312 Scheduler s = new Scheduler(); in reset_setsSchedulerToMaster_forNonMainLooper_withAdvancedScheduling()
414 Scheduler s = ShadowLooper.getShadowMainLooper().getScheduler(); in withAdvancedScheduling_shouldDispatchMessagesOnBothLoopers_whenAdvancingForegroundThread()
/external/swiftshader/third_party/marl/
DREADME.md28 marl::Scheduler scheduler(marl::Scheduler::Config::allCores());
139 #### Create one instance of `marl::Scheduler`, use it for the lifetime of the process
141 The `marl::Scheduler` constructor can be expensive as it may spawn a number of hardware threads. \
142 Destructing the `marl::Scheduler` requires waiting on all tasks to complete.
144 Multiple `marl::Scheduler`s may fight each other for hardware thread utilization.
146 For these reasons, it is recommended to create a single `marl::Scheduler` for the lifetime of your …
152 marl::Scheduler scheduler(marl::Scheduler::Config::allCores());
164 …marl::Scheduler` may be simultaneously bound to any number of threads, and the scheduler can be re…
171 marl::Scheduler* scheduler = marl::Scheduler::get();
186 … terminating the thread. Forgetting to unbind will result in the `marl::Scheduler` destructor bloc…
[all …]
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/
DRoboExecutorService.java15 import org.robolectric.util.Scheduler;
21 private final Scheduler scheduler;
26 private final Scheduler scheduler;
28 public AdvancingFutureTask(Scheduler scheduler, Callable<V> callable) { in AdvancingFutureTask()
33 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAbstractScheduledService.java112 public abstract static class Scheduler { class in AbstractScheduledService
123 public static Scheduler newFixedDelaySchedule( in newFixedDelaySchedule()
127 return new Scheduler() { in newFixedDelaySchedule()
145 public static Scheduler newFixedRateSchedule( in newFixedRateSchedule()
149 return new Scheduler() { in newFixedRateSchedule()
162 private Scheduler() {}
309 protected abstract Scheduler scheduler();
441 public abstract static class CustomScheduler extends Scheduler {
/external/swiftshader/third_party/llvm-10.0/llvm/lib/MCA/Stages/
DExecuteStage.cpp26 HWStallEvent::GenericEventType toHWStallEventType(Scheduler::Status Status) { in toHWStallEventType()
28 case Scheduler::SC_LOAD_QUEUE_FULL: in toHWStallEventType()
30 case Scheduler::SC_STORE_QUEUE_FULL: in toHWStallEventType()
32 case Scheduler::SC_BUFFERS_FULL: in toHWStallEventType()
34 case Scheduler::SC_DISPATCH_GROUP_STALL: in toHWStallEventType()
36 case Scheduler::SC_AVAILABLE: in toHWStallEventType()
44 if (Scheduler::Status S = HWS.isAvailable(IR)) { in isAvailable()
/external/llvm-project/llvm/lib/MCA/Stages/
DExecuteStage.cpp26 HWStallEvent::GenericEventType toHWStallEventType(Scheduler::Status Status) { in toHWStallEventType()
28 case Scheduler::SC_LOAD_QUEUE_FULL: in toHWStallEventType()
30 case Scheduler::SC_STORE_QUEUE_FULL: in toHWStallEventType()
32 case Scheduler::SC_BUFFERS_FULL: in toHWStallEventType()
34 case Scheduler::SC_DISPATCH_GROUP_STALL: in toHWStallEventType()
36 case Scheduler::SC_AVAILABLE: in toHWStallEventType()
44 if (Scheduler::Status S = HWS.isAvailable(IR)) { in isAvailable()

123456789