1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
use libcgroups::common::{CgroupManager, FreezerState};
use super::{Container, ContainerStatus};
use crate::error::LibcontainerError;
impl Container {
/// Resumes all processes within the container
///
/// # Example
///
/// ```no_run
/// use libcontainer::container::builder::ContainerBuilder;
/// use libcontainer::syscall::syscall::SyscallType;
///
/// # fn main() -> anyhow::Result<()> {
/// let mut container = ContainerBuilder::new(
/// "74f1a4cb3801".to_owned(),
/// SyscallType::default(),
/// )
/// .as_init("/var/run/docker/bundle")
/// .build()?;
///
/// container.resume()?;
/// # Ok(())
/// # }
/// ```
pub fn resume(&mut self) -> Result<(), LibcontainerError> {
self.refresh_status()?;
// check if container can be resumed :
// for example, a running process cannot be resumed
if !self.can_resume() {
tracing::error!(status = ?self.status(), id = ?self.id(), "cannot resume container");
return Err(LibcontainerError::IncorrectStatus(self.status()));
}
let cmanager =
libcgroups::common::create_cgroup_manager(libcgroups::common::CgroupConfig {
cgroup_path: self.spec()?.cgroup_path,
systemd_cgroup: self.systemd(),
container_name: self.id().to_string(),
})?;
// resume the frozen container
cmanager.freeze(FreezerState::Thawed)?;
tracing::debug!("saving running status");
self.set_status(ContainerStatus::Running).save()?;
tracing::debug!("container {} resumed", self.id());
Ok(())
}
}