mir/criu
2
0
Fork 0
mirror of https://github.com/checkpoint-restore/criu synced 2025-08-22 09:58:09 +00:00
Code Issues Releases Wiki Activity

seize: Wait the freezer to complete before processing tags

Browse Source 
Currently, when we use cgroup freezer to seize the tasks we start freezer
and then without waiting the completion of transition procedure we are
seizing tasks read from freezer @tasks file, using fgets.

This is fragile construction because fgets uses internal buffer and tasks
we've read might be exiting same time while we're freezing them,
the kernel won't freeze these exiting tasks because they are dying
anyway and I fear we might read a pid here which is not even in
our cgroup anymore but reused with another out of cgroup task.

Thus lets do the following: use iterations to freeze tasks waiting
for freezer to change its state and then collect/seize all tasks
in one pass.

For example on container I'm playing with it takes just one iteration

 | (00.013690) cg: Set 1 is criu one
 | (00.013705) freezing processes: 1800000 attempst with 100 ms steps
 | (00.013720) freezer.state=THAWED
 | (00.013795) freezer.state=FREEZING
 | (00.113962) freezer.state=FROZEN
 | (00.113990) freezing processes: 1 attempts done
 | (00.114073) SEIZE 240893 (comm systemd): success
 | (00.114110) Warn  (ptrace.c:121): Unable to interrupt task: 240905 (comm kthreadd/1) (Operation not permitted)
 | (00.114136) Warn  (ptrace.c:121): Unable to interrupt task: 240906 (comm khelper) (Operation not permitted)
 | (00.114155) SEIZE 240969 (comm screen): success
 | (00.114166) SEIZE 240970 (comm sendmail): success
 | (00.114179) SEIZE 240971 (comm sendmail): success
 | (00.114189) SEIZE 240972 (comm saslauthd): success
 | (00.114202) SEIZE 240973 (comm crond): success
 | (00.114211) SEIZE 240974 (comm agetty): success
 | (00.114221) SEIZE 240975 (comm agetty): success
 | ...

Signed-off-by: Cyrill Gorcunov <gorcunov@virtuozzo.com>
Acked-by: Andrew Vagin <avagin@gmail.com>
Signed-off-by: Pavel Emelyanov <xemul@virtuozzo.com>
This commit is contained in:
Cyrill Gorcunov 2016-08-02 18:34:00 +03:00 committed by Pavel Emelyanov
parent 9fae23fbe2
commit c44683c13a
1 changed files with 25 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
criu/seize.c
View File

@ -363,50 +363,40 @@ static int freeze_processes(void)
close(fd); close(fd);
return -1; return -1;
} }
}
/* /*
* There is not way to wait a specified state, so we need to poll the * Wait the freezer to complete before
* freezer.state. * processing tasks. They might be exiting
* Here is one extra attempt to check that everything are frozen. * before freezing complete so we should
*/ * not read @tasks pids while freezer in
for (i = 0; i <= nr_attempts; i++) { * transition stage.
if (seize_cgroup_tree(opts.freeze_cgroup, state) < 0) */
goto err; for (i = 0; i <= nr_attempts; i++) {
state = get_freezer_state(fd);
if (!state) {
close(fd);
return -1;
}
if (state == frozen) if (state == frozen)
break; break;
if (alarm_timeouted())
state = get_freezer_state(fd); goto err;
if (!state) nanosleep(&req, NULL);
goto err;
if (state == frozen) {
/*
* Enumerate all tasks one more time to collect all new
* tasks, which can be born while the cgroup is being frozen.
*/
continue;
} }
if (alarm_timeouted()) if (i > nr_attempts) {
pr_err("Unable to freeze cgroup %s\n", opts.freeze_cgroup);
if (!pr_quelled(LOG_DEBUG))
log_unfrozen_stacks(opts.freeze_cgroup);
goto err; goto err;
}
nanosleep(&req, NULL); pr_debug("freezing processes: %lu attempts done\n", i);
} }
if (i > nr_attempts) { exit_code = seize_cgroup_tree(opts.freeze_cgroup, state);
pr_err("Unable to freeze cgroup %s\n", opts.freeze_cgroup);
if (!pr_quelled(LOG_DEBUG))
log_unfrozen_stacks(opts.freeze_cgroup);
goto err;
}
pr_debug("freezing processes: %lu attempts done\n", i);
exit_code = 0;
err: err:
if (exit_code == 0 || freezer_thawed) { if (exit_code == 0 || freezer_thawed) {
lseek(fd, 0, SEEK_SET); lseek(fd, 0, SEEK_SET);