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

containerd-shim-kata-v2: add the service Update support

Browse Source 
Add the Update api support to update a running
process's resouce.

Signed-off-by: fupan <lifupan@gmail.com>
This commit is contained in:
fupan 2018-11-19 11:41:45 +08:00
parent 642231ba25
commit 47326f566c
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
containerd-shim-v2/service.go
View File

@ -6,6 +6,7 @@ package containerdshim
import ( import (
"context" "context"
"encoding/json"
"os" "os"
sysexec "os/exec" sysexec "os/exec"
"path/filepath" "path/filepath"
@ -24,6 +25,7 @@ import (
"github.com/kata-containers/runtime/pkg/katautils" "github.com/kata-containers/runtime/pkg/katautils"
vc "github.com/kata-containers/runtime/virtcontainers" vc "github.com/kata-containers/runtime/virtcontainers"
"github.com/kata-containers/runtime/virtcontainers/pkg/oci" "github.com/kata-containers/runtime/virtcontainers/pkg/oci"
"github.com/opencontainers/runtime-spec/specs-go"
"github.com/containerd/containerd/api/types/task" "github.com/containerd/containerd/api/types/task"
ptypes "github.com/gogo/protobuf/types" ptypes "github.com/gogo/protobuf/types"
@ -574,7 +576,20 @@ func (s *service) Stats(ctx context.Context, r *taskAPI.StatsRequest) (*taskAPI.
// Update a running container // Update a running container
func (s *service) Update(ctx context.Context, r *taskAPI.UpdateTaskRequest) (*ptypes.Empty, error) { func (s *service) Update(ctx context.Context, r *taskAPI.UpdateTaskRequest) (*ptypes.Empty, error) {
return nil, errdefs.ErrNotImplemented s.Lock()
defer s.Unlock()
var resources specs.LinuxResources
if err := json.Unmarshal(r.Resources.Value, &resources); err != nil {
return empty, err
}
err := s.sandbox.UpdateContainer(r.ID, resources)
if err != nil {
return nil, errdefs.ToGRPC(err)
}
return empty, nil
} }
// Wait for a process to exit // Wait for a process to exit