Merge pull request #2122 from darfux/v2_pause_resume_behavior

v2: Change the event and error behavior of pause/resume
This commit is contained in:
Peng Tao 2019-10-10 16:52:09 +08:00 committed by GitHub
commit 729b5faf52
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -592,18 +592,18 @@ func (s *service) Pause(ctx context.Context, r *taskAPI.PauseRequest) (_ *ptypes
err = s.sandbox.PauseContainer(r.ID)
if err == nil {
c.status = task.StatusPaused
s.send(&eventstypes.TaskPaused{
ContainerID: c.id,
})
return empty, nil
}
c.status, err = s.getContainerStatus(c.id)
if err != nil {
if status, err := s.getContainerStatus(c.id); err != nil {
c.status = task.StatusUnknown
} else {
c.status = status
}
s.send(&eventstypes.TaskPaused{
ContainerID: c.id,
})
return empty, err
}
@ -624,18 +624,18 @@ func (s *service) Resume(ctx context.Context, r *taskAPI.ResumeRequest) (_ *ptyp
err = s.sandbox.ResumeContainer(c.id)
if err == nil {
c.status = task.StatusRunning
s.send(&eventstypes.TaskResumed{
ContainerID: c.id,
})
return empty, nil
}
c.status, err = s.getContainerStatus(c.id)
if err != nil {
if status, err := s.getContainerStatus(c.id); err != nil {
c.status = task.StatusUnknown
} else {
c.status = status
}
s.send(&eventstypes.TaskResumed{
ContainerID: c.id,
})
return empty, err
}