github/kata-containers
1
0
Fork 1
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-06-28 00:07:16 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #8023 from cmaf/runtime-rs-ch-pause-resume

Browse Source 
runtime-rs: Update status for pause and resume
This commit is contained in:
Chelsea Mafrica 2023-11-08 11:34:47 -08:00 committed by GitHub
commit 83e731328f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/runtime-rs/crates/runtimes/virt_container/src/container_manager/container.rs
View File

@ -366,28 +366,42 @@ impl Container {
} }
pub async fn pause(&self) -> Result<()> { pub async fn pause(&self) -> Result<()> {
let inner = self.inner.read().await; let mut inner = self.inner.write().await;
if inner.init_process.get_status().await == ProcessStatus::Paused { let status = inner.init_process.get_status().await;
warn!(self.logger, "container is paused no need to pause"); if status != ProcessStatus::Running {
warn!(
self.logger,
"container is in {:?} state, will not pause", status
);
return Ok(()); return Ok(());
} }
self.agent self.agent
.pause_container(self.container_id.clone().into()) .pause_container(self.container_id.clone().into())
.await .await
.context("agent pause container")?; .context("agent pause container")?;
inner.set_state(ProcessStatus::Paused).await;
Ok(()) Ok(())
} }
pub async fn resume(&self) -> Result<()> { pub async fn resume(&self) -> Result<()> {
let inner = self.inner.read().await; let mut inner = self.inner.write().await;
if inner.init_process.get_status().await == ProcessStatus::Running { let status = inner.init_process.get_status().await;
warn!(self.logger, "container is running no need to resume"); if status != ProcessStatus::Paused {
warn!(
self.logger,
"container is in {:?} state, will not resume", status
);
return Ok(()); return Ok(());
} }
self.agent self.agent
.resume_container(self.container_id.clone().into()) .resume_container(self.container_id.clone().into())
.await .await
.context("agent pause container")?; .context("agent pause container")?;
inner.set_state(ProcessStatus::Running).await;
Ok(()) Ok(())
} }