Fix delete error code on the containerd daemon side.

Random-Liu · Random-Liu · commit ffcb1cc9be3e · 2019-10-09T00:28:51.000-07:00
Signed-off-by: Lantao Liu &lt;lantaol@google.com&gt;
diff --git a/runtime/v1/linux/task.go b/runtime/v1/linux/task.go
@@ -91,9 +91,12 @@ func (t *Task) PID() uint32 {
 
 // Delete the task and return the exit status
 func (t *Task) Delete(ctx context.Context) (*runtime.Exit, error) {
-	rsp, err := t.shim.Delete(ctx, empty)
-	if err != nil && !errdefs.IsNotFound(err) {
-		return nil, errdefs.FromGRPC(err)
+	rsp, shimErr := t.shim.Delete(ctx, empty)
+	if shimErr != nil {
+		shimErr = errdefs.FromGRPC(shimErr)
+		if !errdefs.IsNotFound(shimErr) {
+			return nil, shimErr
+		}
 	}
 	t.tasks.Delete(ctx, t.id)
 	if err := t.shim.KillShim(ctx); err != nil {
@@ -102,6 +105,9 @@ func (t *Task) Delete(ctx context.Context) (*runtime.Exit, error) {
 	if err := t.bundle.Delete(); err != nil {
 		log.G(ctx).WithError(err).Error("failed to delete bundle")
 	}
+	if shimErr != nil {
+		return nil, shimErr
+	}
 	t.events.Publish(ctx, runtime.TaskDeleteEventTopic, &eventstypes.TaskDelete{
 		ContainerID: t.id,
 		ExitStatus:  rsp.ExitStatus,
diff --git a/runtime/v2/shim.go b/runtime/v2/shim.go
@@ -222,11 +222,14 @@ func (s *shim) Close() error {
 }
 
 func (s *shim) Delete(ctx context.Context) (*runtime.Exit, error) {
-	response, err := s.task.Delete(ctx, &task.DeleteRequest{
+	response, shimErr := s.task.Delete(ctx, &task.DeleteRequest{
 		ID: s.ID(),
 	})
-	if err != nil && !errdefs.IsNotFound(err) {
-		return nil, errdefs.FromGRPC(err)
+	if shimErr != nil {
+		shimErr = errdefs.FromGRPC(shimErr)
+		if !errdefs.IsNotFound(shimErr) {
+			return nil, shimErr
+		}
 	}
 	// remove self from the runtime task list
 	// this seems dirty but it cleans up the API across runtimes, tasks, and the service
@@ -238,6 +241,9 @@ func (s *shim) Delete(ctx context.Context) (*runtime.Exit, error) {
 	if err := s.bundle.Delete(); err != nil {
 		log.G(ctx).WithError(err).Error("failed to delete bundle")
 	}
+	if shimErr != nil {
+		return nil, shimErr
+	}
 	return &runtime.Exit{
 		Status:    response.ExitStatus,
 		Timestamp: response.ExitedAt,
diff --git a/services/tasks/local.go b/services/tasks/local.go
@@ -241,7 +241,7 @@ func (l *local) Delete(ctx context.Context, r *api.DeleteTaskRequest, _ ...grpc.
 	}
 	exit, err := t.Delete(ctx)
 	if err != nil {
-		return nil, err
+		return nil, errdefs.ToGRPC(err)
 	}
 	return &api.DeleteResponse{
 		ExitStatus: exit.Status,
@@ -257,7 +257,7 @@ func (l *local) DeleteProcess(ctx context.Context, r *api.DeleteProcessRequest,
 	}
 	process, err := t.Process(ctx, r.ExecID)
 	if err != nil {
-		return nil, err
+		return nil, errdefs.ToGRPC(err)
 	}
 	exit, err := process.Delete(ctx)
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -241,7 +241,7 @@ func (l local) Delete(ctx context.Context, r api.DeleteTaskRequest, _ ...grpc.`
`241`	`241`	`}`
`242`	`242`	`exit, err := t.Delete(ctx)`
`243`	`243`	`if err != nil {`
`244`		`- return nil, err`
	`244`	`+ return nil, errdefs.ToGRPC(err)`
`245`	`245`	`}`
`246`	`246`	`return &api.DeleteResponse{`
`247`	`247`	`ExitStatus: exit.Status,`
`@@ -257,7 +257,7 @@ func (l local) DeleteProcess(ctx context.Context, r api.DeleteProcessRequest,`
`257`	`257`	`}`
`258`	`258`	`process, err := t.Process(ctx, r.ExecID)`
`259`	`259`	`if err != nil {`
`260`		`- return nil, err`
	`260`	`+ return nil, errdefs.ToGRPC(err)`
`261`	`261`	`}`
`262`	`262`	`exit, err := process.Delete(ctx)`
`263`	`263`	`if err != nil {`