Merge pull request #672 from unclejack/small_cleanup_changes
clean up the code in a few places
This commit is contained in:
commit
1a983cf749
9 changed files with 21 additions and 49 deletions
|
@ -60,7 +60,7 @@ func DetectCompression(source []byte) Compression {
|
|||
// Len too short
|
||||
continue
|
||||
}
|
||||
if bytes.Compare(m, source[:len(m)]) == 0 {
|
||||
if bytes.Equal(m, source[:len(m)]) {
|
||||
return compression
|
||||
}
|
||||
}
|
||||
|
|
|
@ -53,7 +53,7 @@ func testCompressDecompress(t *testing.T, size int, compression Compression) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if bytes.Compare(orig, decompressed) != 0 {
|
||||
if !bytes.Equal(orig, decompressed) {
|
||||
t.Fatal("strange decompressed data")
|
||||
}
|
||||
}
|
||||
|
|
|
@ -100,10 +100,7 @@ func handleTarTypeBlockCharFifo(hdr *tar.Header, path string) error {
|
|||
mode |= syscall.S_IFIFO
|
||||
}
|
||||
|
||||
if err := syscall.Mknod(path, mode, int(mkdev(hdr.Devmajor, hdr.Devminor))); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
return syscall.Mknod(path, mode, int(mkdev(hdr.Devmajor, hdr.Devminor)))
|
||||
}
|
||||
|
||||
func handleLChmod(hdr *tar.Header, path string, hdrInfo os.FileInfo) error {
|
||||
|
|
|
@ -137,7 +137,7 @@ func main() {
|
|||
// start the prometheus metrics API for containerd
|
||||
serveMetricsAPI()
|
||||
|
||||
log.G(global).Infof("containerd successfully booted in %fs", time.Now().Sub(start).Seconds())
|
||||
log.G(global).Infof("containerd successfully booted in %fs", time.Since(start).Seconds())
|
||||
return handleSignals(signals, server)
|
||||
}
|
||||
|
||||
|
|
|
@ -49,10 +49,8 @@ var pprofGoroutinesCommand = cli.Command{
|
|||
return err
|
||||
}
|
||||
defer output.Close()
|
||||
if _, err := io.Copy(os.Stdout, output); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
_, err = io.Copy(os.Stdout, output)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
|
@ -67,10 +65,8 @@ var pprofHeapCommand = cli.Command{
|
|||
return err
|
||||
}
|
||||
defer output.Close()
|
||||
if _, err := io.Copy(os.Stdout, output); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
_, err = io.Copy(os.Stdout, output)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
|
@ -85,10 +81,8 @@ var pprofProfileCommand = cli.Command{
|
|||
return err
|
||||
}
|
||||
defer output.Close()
|
||||
if _, err := io.Copy(os.Stdout, output); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
_, err = io.Copy(os.Stdout, output)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
|
@ -112,11 +106,8 @@ var pprofTraceCommand = cli.Command{
|
|||
return err
|
||||
}
|
||||
defer output.Close()
|
||||
if _, err := io.Copy(os.Stdout, output); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
|
||||
_, err = io.Copy(os.Stdout, output)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
|
@ -131,10 +122,8 @@ var pprofBlockCommand = cli.Command{
|
|||
return err
|
||||
}
|
||||
defer output.Close()
|
||||
if _, err := io.Copy(os.Stdout, output); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
_, err = io.Copy(os.Stdout, output)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
|
@ -149,10 +138,8 @@ var pprofThreadcreateCommand = cli.Command{
|
|||
return err
|
||||
}
|
||||
defer output.Close()
|
||||
if _, err := io.Copy(os.Stdout, output); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
_, err = io.Copy(os.Stdout, output)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
|
|
6
cmd/dist/fetch.go
vendored
6
cmd/dist/fetch.go
vendored
|
@ -212,11 +212,7 @@ func (j *jobs) jobs() []string {
|
|||
defer j.mu.Unlock()
|
||||
|
||||
var jobs []string
|
||||
for _, j := range j.refs {
|
||||
jobs = append(jobs, j)
|
||||
}
|
||||
|
||||
return jobs
|
||||
return append(jobs, j.refs...)
|
||||
}
|
||||
|
||||
type statusInfo struct {
|
||||
|
|
7
cmd/dist/fetchobject.go
vendored
7
cmd/dist/fetchobject.go
vendored
|
@ -58,10 +58,7 @@ var fetchObjectCommand = cli.Command{
|
|||
}
|
||||
defer rc.Close()
|
||||
|
||||
if _, err := io.Copy(os.Stdout, rc); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
_, err = io.Copy(os.Stdout, rc)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
|
|
@ -57,10 +57,7 @@ func RemoveAll(name string) Applier {
|
|||
func CreateDir(name string, perm os.FileMode) Applier {
|
||||
return applyFn(func(root string) error {
|
||||
fullPath := filepath.Join(root, name)
|
||||
if err := os.MkdirAll(fullPath, perm); err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
return os.MkdirAll(fullPath, perm)
|
||||
})
|
||||
}
|
||||
|
||||
|
|
|
@ -137,9 +137,7 @@ func ChildrenHandler(provider content.Provider) HandlerFunc {
|
|||
var descs []ocispec.Descriptor
|
||||
|
||||
descs = append(descs, manifest.Config)
|
||||
for _, desc := range manifest.Layers {
|
||||
descs = append(descs, desc)
|
||||
}
|
||||
descs = append(descs, manifest.Layers...)
|
||||
|
||||
return descs, nil
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue