gh0s7/mckernel
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

move_pages(): fix barrier in parallel implementation

Browse Source
This commit is contained in:
Balazs Gerofi
2017-05-12 13:20:35 +09:00
parent 4c0f401424
commit d48d44d365
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
kernel/syscall.c
View File

@ -8218,7 +8218,7 @@ int move_pages_smp_handler(int cpu_index, int nr_cpus, void *arg)
/* Barrier */ /* Barrier */
ihk_atomic_inc(&mpsr->phase_done); ihk_atomic_inc(&mpsr->phase_done);
while (ihk_atomic_read(&mpsr->phase_done) != while (ihk_atomic_read(&mpsr->phase_done) <
(phase * nr_cpus)) { (phase * nr_cpus)) {
cpu_pause(); cpu_pause();
} }
@ -8227,7 +8227,7 @@ int move_pages_smp_handler(int cpu_index, int nr_cpus, void *arg)
goto out; goto out;
} }
kprintf("%s: phase %d done\n", __FUNCTION__, phase); dkprintf("%s: phase %d done\n", __FUNCTION__, phase);
++phase; ++phase;
/* PTE lookup in parallel */ /* PTE lookup in parallel */
@ -8296,7 +8296,7 @@ int move_pages_smp_handler(int cpu_index, int nr_cpus, void *arg)
pte_out: pte_out:
/* Barrier */ /* Barrier */
ihk_atomic_inc(&mpsr->phase_done); ihk_atomic_inc(&mpsr->phase_done);
while (ihk_atomic_read(&mpsr->phase_done) != while (ihk_atomic_read(&mpsr->phase_done) <
(phase * nr_cpus)) { (phase * nr_cpus)) {
cpu_pause(); cpu_pause();
} }
@ -8305,7 +8305,7 @@ pte_out:
goto out; goto out;
} }
kprintf("%s: phase %d done\n", __FUNCTION__, phase); dkprintf("%s: phase %d done\n", __FUNCTION__, phase);
++phase; ++phase;
if (cpu_index == 0) { if (cpu_index == 0) {
@ -8348,7 +8348,7 @@ pte_out:
/* Barrier */ /* Barrier */
ihk_atomic_inc(&mpsr->phase_done); ihk_atomic_inc(&mpsr->phase_done);
while (ihk_atomic_read(&mpsr->phase_done) != while (ihk_atomic_read(&mpsr->phase_done) <
(phase * nr_cpus)) { (phase * nr_cpus)) {
cpu_pause(); cpu_pause();
} }
@ -8357,7 +8357,7 @@ pte_out:
goto out; goto out;
} }
kprintf("%s: phase %d done\n", __FUNCTION__, phase); dkprintf("%s: phase %d done\n", __FUNCTION__, phase);
++phase; ++phase;
/* Copy, PTE update, memfree in parallel */ /* Copy, PTE update, memfree in parallel */