loadbalance pr1

Cargo.toml

@@ -14,6 +14,7 @@ members = [
     "apps/task/sleep",
     "apps/task/yield",
     "apps/task/priority",
+    "apps/task/unbalance",
 
     "crates/allocator",
     "crates/arm_gic",

apps/net/httpserver/Cargo.toml

@@ -6,5 +6,11 @@ authors = ["Yuekai Jia <[email protected]>"]
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
+[features]
+default = ["libax/default"]
+sched_cfs = ["libax/sched_cfs"]
+sched_rr = ["libax/sched_rr"]
+sched_fifo = ["libax/sched_fifo"]
+
 [dependencies]
-libax = { path = "../../../ulib/libax", features = ["paging", "multitask", "net"] }
+libax = { path = "../../../ulib/libax", default-features = false, features = ["paging", "multitask", "net", "irq"] }

apps/task/parallel/expect_info_smp1_fifo.out

@@ -16,6 +16,7 @@ Initialize kernel page table...
 Initialize platform devices...
 Initialize scheduling...
   use FIFO scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 Primary CPU 0 init OK.
 part 0: TaskId(4) \[0, 125000)

apps/task/parallel/expect_info_smp4_cfs.out

@@ -0,0 +1,62 @@
+smp = 4
+build_mode = release
+log_level = info
+
+CPU 0 started
+Found physcial memory regions:
+ .text (READ | EXECUTE | RESERVED)
+ .rodata (READ | RESERVED)
+ .data (READ | WRITE | RESERVED)
+ .percpu (READ | WRITE | RESERVED)
+ boot stack (READ | WRITE | RESERVED)
+ .bss (READ | WRITE | RESERVED)
+ free memory (READ | WRITE | FREE)
+Initialize global memory allocator...
+Initialize kernel page table...
+Initialize platform devices...
+Initialize scheduling...
+  use Completely Fair scheduler.
+  use basic method load balance manager.
+Initialize interrupt handlers...
+CPU 0 init OK
+CPU 1 started
+CPU 2 started
+CPU 3 started
+CPU 1 init OK
+CPU 2 init OK
+CPU 3 init OK
+part 0: TaskId([0-9]\+) \[0, 125000)
+part 1: TaskId([0-9]\+) \[125000, 250000)
+part 2: TaskId([0-9]\+) \[250000, 375000)
+part 3: TaskId([0-9]\+) \[375000, 500000)
+part 4: TaskId([0-9]\+) \[500000, 625000)
+part 5: TaskId([0-9]\+) \[625000, 750000)
+part 6: TaskId([0-9]\+) \[750000, 875000)
+part 7: TaskId([0-9]\+) \[875000, 1000000)
+part 8: TaskId([0-9]\+) \[1000000, 1125000)
+part 9: TaskId([0-9]\+) \[1125000, 1250000)
+part 10: TaskId([0-9]\+) \[1250000, 1375000)
+part 11: TaskId([0-9]\+) \[1375000, 1500000)
+part 12: TaskId([0-9]\+) \[1500000, 1625000)
+part 13: TaskId([0-9]\+) \[1625000, 1750000)
+part 14: TaskId([0-9]\+) \[1750000, 1875000)
+part 15: TaskId([0-9]\+) \[1875000, 2000000)
+part 15: TaskId([0-9]\+) finished
+part 0: TaskId([0-9]\+) finished
+part 1: TaskId([0-9]\+) finished
+part 2: TaskId([0-9]\+) finished
+part 3: TaskId([0-9]\+) finished
+part 4: TaskId([0-9]\+) finished
+part 5: TaskId([0-9]\+) finished
+part 6: TaskId([0-9]\+) finished
+part 7: TaskId([0-9]\+) finished
+part 8: TaskId([0-9]\+) finished
+part 9: TaskId([0-9]\+) finished
+part 10: TaskId([0-9]\+) finished
+part 11: TaskId([0-9]\+) finished
+part 12: TaskId([0-9]\+) finished
+part 13: TaskId([0-9]\+) finished
+part 14: TaskId([0-9]\+) finished
+sum = 61783189038
+Parallel summation tests run OK!
+Shutting down...

apps/task/parallel/expect_info_smp4_rr.out

@@ -16,6 +16,7 @@ Initialize kernel page table...
 Initialize platform devices...
 Initialize scheduling...
   use Round-robin scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 CPU 0 init OK
 CPU 1 started

apps/task/parallel/test_cmd

@@ -1,2 +1,3 @@
 test_one "LOG=info" "expect_info_smp1_fifo.out"
 test_one "SMP=4 LOG=info APP_FEATURES=sched_rr" "expect_info_smp4_rr.out"
+test_one "SMP=4 LOG=info APP_FEATURES=sched_cfs" "expect_info_smp4_cfs.out"

apps/task/priority/expect_info_smp1_cfs.out

@@ -15,6 +15,7 @@ Initialize global memory allocator...
 Initialize kernel page table...
 Initialize scheduling...
   use Completely Fair scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 Primary CPU 0 init OK.
 part 0: TaskId(4) \[0, 40)

apps/task/priority/expect_info_smp1_fifo.out

@@ -15,6 +15,7 @@ Initialize global memory allocator...
 Initialize kernel page table...
 Initialize scheduling...
   use FIFO scheduler.
+  use basic method load balance manager.
 Primary CPU 0 init OK.
 part 0: TaskId(4) \[0, 40)
 part 0: TaskId(4) finished

apps/task/priority/expect_info_smp1_rr.out

@@ -15,6 +15,7 @@ Initialize global memory allocator...
 Initialize kernel page table...
 Initialize scheduling...
   use Round-robin scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 Primary CPU 0 init OK.
 part 0: TaskId(4) \[0, 40)

apps/task/priority/expect_info_smp4_cfs.out

@@ -21,13 +21,14 @@ Initialize global memory allocator...
 Initialize kernel page table...
 Initialize scheduling...
   use Completely Fair scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 Primary CPU [0-9]\+ init OK.
-part 0: TaskId(7) \[0, 40)
-part 1: TaskId(8) \[0, 40)
-part 2: TaskId(9) \[0, 40)
-part 3: TaskId(10) \[0, 40)
-part 4: TaskId(11) \[0, 4)
+part [0-9]\+: TaskId([0-9]\+) \[0, 40)
+part [0-9]\+: TaskId([0-9]\+) \[0, 40)
+part [0-9]\+: TaskId([0-9]\+) \[0, 40)
+part [0-9]\+: TaskId([0-9]\+) \[0, 40)
+part [0-9]\+: TaskId([0-9]\+) \[0, 4)
 part [0-9]\+: TaskId([0-9]\+) finished
 part [0-9]\+: TaskId([0-9]\+) finished
 part [0-9]\+: TaskId([0-9]\+) finished

apps/task/sleep/expect_info_smp4_fifo.out

@@ -16,6 +16,7 @@ Initialize kernel page table...
 Initialize platform devices...
 Initialize scheduling...
   use FIFO scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 Hello, main task!
 main task sleep for 1\.[0-9]\+s

apps/task/sleep/expect_info_smp4_rr.out

@@ -16,6 +16,7 @@ Initialize kernel page table...
 Initialize platform devices...
 Initialize scheduling...
   use Round-robin scheduler.
+  use basic method load balance manager.
 Initialize interrupt handlers...
 Hello, main task!
 main task sleep for 1\.[0-9]\+s

apps/task/unbalance/Cargo.toml

@@ -0,0 +1,16 @@
+[package]
+name = "arceos-unbalance"
+version = "0.1.0"
+edition = "2021"
+authors = ["Haoxing Ye <[email protected]>"]
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[features]
+default = ["libax/default"]
+sched_cfs = ["libax/sched_cfs"]
+sched_rr = ["libax/sched_rr"]
+sched_fifo = ["libax/sched_fifo"]
+
+[dependencies]
+libax = { path = "../../../ulib/libax", default-features = false, features = ["alloc", "paging", "multitask", "irq"] }

apps/task/unbalance/expect_info_smp1_cfs.out

@@ -0,0 +1,101 @@
+smp = 1
+build_mode = release
+log_level = info
+
+Primary CPU 0 started,
+Found physcial memory regions:
+ .text (READ | EXECUTE | RESERVED)
+ .rodata (READ | RESERVED)
+ .data (READ | WRITE | RESERVED)
+ .percpu (READ | WRITE | RESERVED)
+ boot stack (READ | WRITE | RESERVED)
+ .bss (READ | WRITE | RESERVED)
+ free memory (READ | WRITE | FREE)
+Initialize global memory allocator...
+Initialize kernel page table...
+Initialize platform devices...
+Initialize scheduling...
+  use Completely Fair scheduler.
+  use basic method load balance manager.
+Initialize interrupt handlers...
+Primary CPU 0 init OK.
+part 24: TaskId(4) [0, 30)
+part 23: TaskId(5) [0, 30)
+part 22: TaskId(6) [0, 25)
+part 21: TaskId(7) [0, 20)
+part 20: TaskId(8) [0, 15)
+part 19: TaskId(9) [0, 10)
+part 18: TaskId(10) [0, 9)
+part 17: TaskId(11) [0, 8)
+part 16: TaskId(12) [0, 7)
+part 15: TaskId(13) [0, 6)
+part 14: TaskId(14) [0, 5)
+part 13: TaskId(15) [0, 4)
+part 12: TaskId(16) [0, 3)
+part 11: TaskId(17) [0, 2)
+part 10: TaskId(18) [0, 5)
+part 9: TaskId(19) [0, 5)
+part 8: TaskId(20) [0, 5)
+part 7: TaskId(21) [0, 5)
+part 6: TaskId(22) [0, 5)
+part 5: TaskId(23) [0, 5)
+part 4: TaskId(24) [0, 5)
+part 3: TaskId(25) [0, 5)
+part 2: TaskId(26) [0, 5)
+part 1: TaskId(27) [0, 5)
+part 0: TaskId(28) [0, 100)
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+part [0-9]\+: TaskId([0-9]\+) finished
+sum = 5310778284
+leave time:
+task 0 =
+task 1 =
+task 2 =
+task 3 =
+task 4 =
+task 5 =
+task 6 =
+task 7 =
+task 8 =
+task 9 =
+task 10 =
+task 11 =
+task 12 =
+task 13 =
+task 14 =
+task 15 =
+task 16 =
+task 17 =
+task 18 =
+task 19 =
+task 20 =
+task 21 =
+task 22 =
+task 23 =
+task 24 =
+leave time max:
+Unbalance tests run OK!
+Shutting down...