Skip to content

Commit

Permalink
Address nits from self-review
Browse files Browse the repository at this point in the history
Signed-off-by: Brad Davidson <[email protected]>
(cherry picked from commit 9ff0943)
Signed-off-by: Brad Davidson <[email protected]>
  • Loading branch information
brandond committed Dec 1, 2022
1 parent ac23090 commit 06c5219
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 13 deletions.
14 changes: 13 additions & 1 deletion pkg/rootless/portdriver.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,13 +6,23 @@ package rootless
import (
"io"
"path"
"strings"

"github.com/rootless-containers/rootlesskit/pkg/port"
portbuiltin "github.com/rootless-containers/rootlesskit/pkg/port/builtin"
portslirp4netns "github.com/rootless-containers/rootlesskit/pkg/port/slirp4netns"
"github.com/sirupsen/logrus"
)

type logrusDebugWriter struct {
}

func (w *logrusDebugWriter) Write(p []byte) (int, error) {
s := strings.TrimSuffix(string(p), "\n")
logrus.Debug(s)
return len(p), nil
}

type portDriver interface {
NewParentDriver() (port.ParentDriver, error)
NewChildDriver() port.ChildDriver
Expand Down Expand Up @@ -74,7 +84,9 @@ func (s *slirp4netnsDriver) APISocketPath() string {
return ""
}

func getDriver(driverName string, logWriter io.Writer) portDriver {
func getDriver(driverName string) portDriver {
logWriter := &logrusDebugWriter{}

if driverName == "slirp4netns" {
return &slirp4netnsDriver{logWriter: logWriter}
}
Expand Down
14 changes: 2 additions & 12 deletions pkg/rootless/rootless.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,8 @@ func Rootless(stateDir string, enableIPv6 bool) error {

hasFD := os.Getenv(pipeFD) != ""
hasChildEnv := os.Getenv(childEnv) != ""
driverName := strings.ToLower(os.Getenv(portDriverEnv))
rootlessDir := filepath.Join(stateDir, "rootless")
driver := getDriver(driverName, &logrusDebugWriter{})
driver := getDriver(strings.ToLower(os.Getenv(portDriverEnv)))

if hasFD {
logrus.Debug("Running rootless child")
Expand Down Expand Up @@ -166,7 +165,7 @@ func createParentOpt(driver portDriver, stateDir string, enableIPv6 bool) (*pare
mtu := 0
if val := os.Getenv(mtuEnv); val != "" {
if v, err := strconv.ParseInt(val, 10, 0); err != nil {
logrus.Warn("Failed to parse rootless mtu; using default")
logrus.Warn("Failed to parse rootless mtu value; using default")
} else {
mtu = int(v)
}
Expand Down Expand Up @@ -217,15 +216,6 @@ func createParentOpt(driver portDriver, stateDir string, enableIPv6 bool) (*pare
return opt, nil
}

type logrusDebugWriter struct {
}

func (w *logrusDebugWriter) Write(p []byte) (int, error) {
s := strings.TrimSuffix(string(p), "\n")
logrus.Debug(s)
return len(p), nil
}

func createChildOpt(driver portDriver) (*child.Opt, error) {
opt := &child.Opt{}
opt.TargetCmd = os.Args
Expand Down

0 comments on commit 06c5219

Please sign in to comment.