summaryrefslogtreecommitdiffhomepage
path: root/dev/kernel/src/UserProcessScheduler.cc
diff options
context:
space:
mode:
authorAmlal El Mahrouss <amlal@nekernel.org>2025-05-18 15:15:52 +0200
committerAmlal El Mahrouss <amlal@nekernel.org>2025-05-18 15:15:52 +0200
commit0266d8058990a496b935abd76417abcfe4e9cffd (patch)
treedb4ffa8b49575ff2f81b98d3dfc078d87a4eb2f5 /dev/kernel/src/UserProcessScheduler.cc
parent163f32fbfbfa2fb0744787769fb3d4865f57d8dd (diff)
dev(sched): Improvements and work in progress fixes.
what? - The main algorithm got improved for real time tasks, and SMP usage. - The SMP usage was present before, I just reintroduced it after realizing that it won't scale well from what I have right now. - Also removed weird implementations quirks from previous sketch. - Such as the core 0 being reserved for the boot core. - Also moved FS init code after IDT initalization. - To avoid weird FS format behavior. - Wrap HPET signature in a macro. next? - Work on the HAL's userspace transition mechanism. Signed-off-by: Amlal El Mahrouss <amlal@nekernel.org>
Diffstat (limited to 'dev/kernel/src/UserProcessScheduler.cc')
-rw-r--r--dev/kernel/src/UserProcessScheduler.cc38
1 files changed, 17 insertions, 21 deletions
diff --git a/dev/kernel/src/UserProcessScheduler.cc b/dev/kernel/src/UserProcessScheduler.cc
index b0d56c5d..165cfb5d 100644
--- a/dev/kernel/src/UserProcessScheduler.cc
+++ b/dev/kernel/src/UserProcessScheduler.cc
@@ -494,37 +494,28 @@ SizeT UserProcessScheduler::Run() noexcept {
//! Check if the process needs to be run.
if (UserProcessHelper::CanBeScheduled(process)) {
- if (process.StackSize > kSchedMaxStackSz) {
- kout << "Process: " << process.Name << ", has not a valid stack size! Crashing it...\r";
- process.Crash();
- continue;
- }
-
kout << ((*process.Name) ? process.Name : "USER_PROCESS") << " will be scheduled...\r";
process.PTime = static_cast<Int32>(process.Affinity);
- if (process.PTime < process.RTime) {
+ if (process.PTime < process.RTime && AffinityKind::kRealTime != process.Affinity) {
if (process.RTime < (Int32) AffinityKind::kVeryHigh)
- process.RTime = (Int32) AffinityKind::kLowUsage;
+ process.RTime = (Int32) AffinityKind::kLowUsage / 2;
else if (process.RTime < (Int32) AffinityKind::kHigh)
- process.RTime = (Int32) AffinityKind::kStandard;
+ process.RTime = (Int32) AffinityKind::kStandard / 3;
else if (process.RTime < (Int32) AffinityKind::kStandard)
- process.RTime = (Int32) AffinityKind::kHigh;
+ process.RTime = (Int32) AffinityKind::kHigh / 4;
- process.PTime += process.RTime;
+ process.PTime -= process.RTime;
process.RTime = 0UL;
}
if (!UserProcessHelper::Switch(process.StackFrame, process.ProcessId)) {
- break;
+ continue;
}
-
- mTeam.AsArray()[this->TheCurrentProcess().Leak().ProcessId] =
- this->TheCurrentProcess().Leak();
-
- this->TheCurrentProcess() = process;
} else {
+ kout << ((*process.Name) ? process.Name : "USER_PROCESS") << " will be scheduled later...\r";
+
++process.RTime;
--process.PTime;
}
@@ -575,14 +566,13 @@ ErrorOr<PID> UserProcessHelper::TheCurrentPID() {
/// @retval false cannot be schedulded.
Bool UserProcessHelper::CanBeScheduled(const USER_PROCESS& process) {
if (process.Status != ProcessStatusKind::kRunning) return No;
-
+ if (process.StackSize > kSchedMaxStackSz) return No;
if (!process.Name[0]) return No;
// real time processes shouldn't wait that much.
if (process.Affinity == AffinityKind::kRealTime) return Yes;
- if (process.Signal.SignalID == SIGKILL || process.Signal.SignalID == SIGABRT ||
- process.Signal.SignalID == SIGTRAP) {
+ if (process.Signal.SignalID == SIGTRAP) {
return No;
}
@@ -625,7 +615,10 @@ Bool UserProcessHelper::Switch(HAL::StackFramePtr frame_ptr, PID new_pid) {
UserProcessHelper::TheCurrentPID().Leak().Leak() = UserProcessHelper::TheCurrentPID();
- break;
+ UserProcessScheduler::The().TheCurrentProcess() =
+ UserProcessScheduler::The().TheCurrentTeam().AsArray()[new_pid];
+
+ return YES;
}
continue;
@@ -653,6 +646,9 @@ Bool UserProcessHelper::Switch(HAL::StackFramePtr frame_ptr, PID new_pid) {
UserProcessScheduler::The().TheCurrentTeam().AsArray()[new_pid].PTime;
HardwareThreadScheduler::The()[index].Leak()->Wake(YES);
+ UserProcessScheduler::The().TheCurrentProcess() =
+ UserProcessScheduler::The().TheCurrentTeam().AsArray()[new_pid];
+
return YES;
}