containerd-shim-kata-v2: retune the code style

Removed some unused variables and retuned some if/else code style, at the same time, do not export those functions and variables which will not used out this module. Fixes: kata-containers#572 Signed-off-by: fupan <[email protected]>
hyperhq · Aug 14, 2018 · c637940 · c637940
1 parent 8fdf25e
commit c637940
Show file tree

Hide file tree

Showing 11 changed files with 147 additions and 118 deletions.
diff --git a/cli/containerd-shim-kata-v2/main.go b/cli/containerd-shim-kata-v2/main.go
@@ -6,11 +6,11 @@
 package main
 
 import (
-"fmt"
-"os"
+	"fmt"
+	"os"
 
-"github.com/kata-containers/runtime/containerd-shim/kata"
-"github.com/containerd/containerd/runtime/v2/shim"
+	"github.com/containerd/containerd/runtime/v2/shim"
+	"github.com/kata-containers/runtime/containerd-shim/kata"
 )
 
 func main() {
@@ -19,4 +19,3 @@ func main() {
 		os.Exit(1)
 	}
 }
-
diff --git a/containerd-shim/kata/config.go b/containerd-shim/kata/config.go
@@ -19,23 +19,20 @@ import (
 )
 
 var defaultHypervisorPath = "/usr/bin/qemu-lite-system-x86_64"
-var defaultImagePath = "/usr/share/kata-containers/kata-containers.img"
 var defaultKernelPath = "/usr/share/kata-containers/vmlinuz.container"
 var defaultInitrdPath = "/usr/share/kata-containers/kata-containers-initrd.img"
 var defaultFirmwarePath = ""
 var defaultMachineAccelerators = ""
 
 const defaultKernelParams = ""
 const defaultMachineType = "pc"
-const defaultRootDirectory = "/var/run/kata-containers"
 const systemdUnitName = "kata-containers.target"
 
 const defaultVCPUCount uint32 = 1
 const defaultMaxVCPUCount uint32 = 0
 const defaultMemSize uint32 = 2048 // MiB
 const defaultBridgesCount uint32 = 1
 const defaultInterNetworkingModel = "macvtap"
-const defaultDisableBlockDeviceUse bool = false
 const defaultBlockDeviceDriver = "virtio-scsi"
 const defaultEnableIOThreads bool = false
 const defaultEnableMemPrealloc bool = false

diff --git a/containerd-shim/kata/container.go b/containerd-shim/kata/container.go
@@ -9,36 +9,34 @@ import (
 	"github.com/containerd/containerd/api/types/task"
 	"github.com/containerd/containerd/errdefs"
 	taskAPI "github.com/containerd/containerd/runtime/v2/task"
-	vc "github.com/kata-containers/runtime/virtcontainers"
 	"sync"
 	"time"
 )
 
-type Container struct {
+type container struct {
 	s        *service
+	ttyio    *ttyIO
 	pid      uint32
+	exit     uint32
 	id       string
 	stdin    string
 	stdout   string
 	stderr   string
-	ttyio    *TtyIO
 	terminal bool
 
 	exitIOch chan struct{}
 	exitch   chan uint32
 
-	bundle    string
-	execs     map[string]*Exec
-	container vc.VCContainer
-	status    task.Status
-	exit      uint32
-	time      time.Time
+	bundle string
+	execs  map[string]*exec
+	status task.Status
+	time   time.Time
 
 	mu sync.Mutex
 }
 
-func newContainer(s *service, r *taskAPI.CreateTaskRequest, pid uint32, container vc.VCContainer) *Container {
-	c := &Container{
+func newContainer(s *service, r *taskAPI.CreateTaskRequest, pid uint32) *container {
+	c := &container{
 		s:        s,
 		pid:      pid,
 		id:       r.ID,
@@ -47,7 +45,7 @@ func newContainer(s *service, r *taskAPI.CreateTaskRequest, pid uint32, containe
 		stdout:   r.Stdout,
 		stderr:   r.Stderr,
 		terminal: r.Terminal,
-		execs:    make(map[string]*Exec),
+		execs:    make(map[string]*exec),
 		status:   task.StatusCreated,
 		exitIOch: make(chan struct{}),
 		exitch:   make(chan uint32, 1),
@@ -56,7 +54,7 @@ func newContainer(s *service, r *taskAPI.CreateTaskRequest, pid uint32, containe
 	return c
 }
 
-func (c *Container) getExec(id string) (*Exec, error) {
+func (c *container) getExec(id string) (*exec, error) {
 	exec := c.execs[id]
 
 	if exec == nil {

diff --git a/containerd-shim/kata/delete.go b/containerd-shim/kata/delete.go
@@ -12,7 +12,7 @@ import (
 	"path"
 )
 
-func deleteContainer(s *service, c *Container) error {
+func deleteContainer(s *service, c *container) error {
 
 	status, err := s.sandbox.StatusContainer(c.id)
 	if err != nil {

diff --git a/containerd-shim/kata/exec.go b/containerd-shim/kata/exec.go
@@ -16,23 +16,25 @@ import (
 	"time"
 )
 
-type Exec struct {
+type exec struct {
+	container *container
+	cmds      *vc.Cmd
+	tty       *tty
+	ttyio     *ttyIO
 	id        string
 	pid       uint32
-	container *Container
-	cmds      *vc.Cmd
-	exitCode  int32
-	tty       *Tty
-	ttyio     *TtyIO
-	status    task.Status
+
+	exitCode int32
+
+	status task.Status
 
 	exitIOch chan struct{}
 	exitch   chan uint32
 
 	exitTime time.Time
 }
 
-type Tty struct {
+type tty struct {
 	stdin    string
 	stdout   string
 	stderr   string
@@ -60,7 +62,7 @@ func getEnvs(envs []string) []vc.EnvVar {
 	return vcEnvs
 }
 
-func newExec(c *Container, stdin, stdout, stderr string, terminal bool, jspec *googleProtobuf.Any) (*Exec, error) {
+func newExec(c *container, stdin, stdout, stderr string, terminal bool, jspec *googleProtobuf.Any) (*exec, error) {
 	var height uint32
 	var width uint32
 
@@ -75,7 +77,7 @@ func newExec(c *Container, stdin, stdout, stderr string, terminal bool, jspec *g
 		width = uint32(spec.ConsoleSize.Width)
 	}
 
-	tty := &Tty{
+	tty := &tty{
 		stdin:    stdin,
 		stdout:   stdout,
 		stderr:   stderr,
@@ -95,7 +97,7 @@ func newExec(c *Container, stdin, stdout, stderr string, terminal bool, jspec *g
 		NoNewPrivileges: spec.NoNewPrivileges,
 	}
 
-	exec := &Exec{
+	exec := &exec{
 		container: c,
 		cmds:      cmds,
 		tty:       tty,

diff --git a/containerd-shim/kata/metrics.go b/containerd-shim/kata/metrics.go
@@ -2,6 +2,7 @@
 //
 // SPDX-License-Identifier: Apache-2.0
 //
+
 package kata
 
 import (