@@ -2,11 +2,11 @@ package main
22
33import (
44 "fmt"
5+ "log/slog"
56 "os"
67 "os/signal"
7- "syscall"
8- "log/slog"
98 "path/filepath"
9+ "syscall"
1010
1111 "github.com/containerd/nydus-snapshotter/cmd/containerd-nydus-grpc/pkg/command"
1212 "github.com/containerd/nydus-snapshotter/config"
@@ -19,7 +19,7 @@ import (
1919 "github.com/containers/nydus-storage-plugin/pkg/services/keychain/dockerconfig"
2020 podmanauth "github.com/containers/nydus-storage-plugin/pkg/services/keychain/podmanauth"
2121 "github.com/containers/nydus-storage-plugin/pkg/services/resolver"
22- )
22+ )
2323
2424func waitForSIGINT () {
2525 c := make (chan os.Signal , 1 )
@@ -31,27 +31,35 @@ func parseOctalMode(s string) (uint32, error) {
3131 var v uint32
3232 for i := 0 ; i < len (s ); i ++ {
3333 c := s [i ]
34- if c < '0' || c > '7' { return 0 , fmt .Errorf ("invalid octal: %s" , s ) }
34+ if c < '0' || c > '7' {
35+ return 0 , fmt .Errorf ("invalid octal: %s" , s )
36+ }
3537 v = (v << 3 ) | uint32 (c - '0' )
3638 }
3739 return v , nil
3840}
3941
40- func setupSlog (level string , toStdout bool , logDir string , root string ) error {
42+ func setupSlog (level string , toStdout bool , logDir string ) error {
4143 var lvl slog.Level
4244 switch level {
43- case "debug" : lvl = slog .LevelDebug
44- case "warn" , "warning" : lvl = slog .LevelWarn
45- case "error" : lvl = slog .LevelError
46- default : lvl = slog .LevelInfo
45+ case "debug" :
46+ lvl = slog .LevelDebug
47+ case "warn" , "warning" :
48+ lvl = slog .LevelWarn
49+ case "error" :
50+ lvl = slog .LevelError
51+ default :
52+ lvl = slog .LevelInfo
4753 }
4854 var w * os.File
4955 if toStdout || logDir == "" {
5056 w = os .Stdout
5157 } else {
5258 path := filepath .Join (logDir , "nydus-store.log" )
5359 f , err := os .OpenFile (path , os .O_CREATE | os .O_WRONLY | os .O_APPEND , 0644 )
54- if err != nil { return err }
60+ if err != nil {
61+ return err
62+ }
5563 w = f
5664 }
5765 h := slog .NewTextHandler (w , & slog.HandlerOptions {Level : lvl })
@@ -65,13 +73,13 @@ func main() {
6573 Name : "crio nydus store" ,
6674 Usage : "crio nydus store plugin" ,
6775 Version : "0.0.0" ,
68- Flags : append (flags .F ,
76+ Flags : append (flags .F ,
6977 & cli.StringFlag {Name : "fs-file-mode" , Usage : "octal file mode for files (e.g. 0400)" },
7078 & cli.StringFlag {Name : "fs-dir-mode" , Usage : "octal dir mode (e.g. 0500)" },
7179 & cli.StringFlag {Name : "fs-link-mode" , Usage : "octal symlink mode (e.g. 0400)" },
7280 ),
7381 Action : func (c * cli.Context ) error {
74- if err := setupSlog (flags .Args .LogLevel , flags .Args .LogToStdout , flags .Args .LogDir , flags . Args . RootDir ); err != nil {
82+ if err := setupSlog (flags .Args .LogLevel , flags .Args .LogToStdout , flags .Args .LogDir ); err != nil {
7583 return errors .Wrap (err , "failed to prepare logger" )
7684 }
7785
@@ -91,7 +99,7 @@ func main() {
9199 dockerconfig .NewDockerconfigKeychain (c .Context ),
92100 // Podman-compatible auth.json
93101 podmanauth .NewPodmanAuthKeychain (c .Context ),
94- }... ,
102+ }... ,
95103 )
96104 layManager , err := manager .NewLayerManager (c .Context , flags .Args .RootDir , hosts , & cfg )
97105 if err != nil {
@@ -103,13 +111,19 @@ func main() {
103111 dirMode := fs .DefaultDirMode ()
104112 linkMode := fs .DefaultLinkMode ()
105113 if v := c .String ("fs-file-mode" ); v != "" {
106- if m , err := parseOctalMode (v ); err == nil { fileMode = m }
114+ if m , err := parseOctalMode (v ); err == nil {
115+ fileMode = m
116+ }
107117 }
108118 if v := c .String ("fs-dir-mode" ); v != "" {
109- if m , err := parseOctalMode (v ); err == nil { dirMode = m }
119+ if m , err := parseOctalMode (v ); err == nil {
120+ dirMode = m
121+ }
110122 }
111123 if v := c .String ("fs-link-mode" ); v != "" {
112- if m , err := parseOctalMode (v ); err == nil { linkMode = m }
124+ if m , err := parseOctalMode (v ); err == nil {
125+ linkMode = m
126+ }
113127 }
114128
115129 // Recover orphan bind mounts from previous crashes
0 commit comments