mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
Harmonize the error management. Use fmt.Errorf instead of errors.New
This commit is contained in:
parent
ccac5b1382
commit
d17f78c373
2 changed files with 15 additions and 17 deletions
29
commands.go
29
commands.go
|
@ -3,7 +3,6 @@ package docker
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/dotcloud/docker/auth"
|
"github.com/dotcloud/docker/auth"
|
||||||
"github.com/dotcloud/docker/rcli"
|
"github.com/dotcloud/docker/rcli"
|
||||||
|
@ -132,7 +131,7 @@ func (srv *Server) CmdLogin(stdin io.ReadCloser, stdout io.Writer, args ...strin
|
||||||
password = readString(stdin, stdout)
|
password = readString(stdin, stdout)
|
||||||
|
|
||||||
if password == "" {
|
if password == "" {
|
||||||
return errors.New("Error : Password Required\n")
|
return fmt.Errorf("Error : Password Required")
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Fprint(stdout, "Email (", srv.runtime.authConfig.Email, "): ")
|
fmt.Fprint(stdout, "Email (", srv.runtime.authConfig.Email, "): ")
|
||||||
|
@ -171,7 +170,7 @@ func (srv *Server) CmdWait(stdin io.ReadCloser, stdout io.Writer, args ...string
|
||||||
if container := srv.runtime.Get(name); container != nil {
|
if container := srv.runtime.Get(name); container != nil {
|
||||||
fmt.Fprintln(stdout, container.Wait())
|
fmt.Fprintln(stdout, container.Wait())
|
||||||
} else {
|
} else {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
@ -223,7 +222,7 @@ func (srv *Server) CmdStop(stdin io.ReadCloser, stdout io.Writer, args ...string
|
||||||
}
|
}
|
||||||
fmt.Fprintln(stdout, container.Id)
|
fmt.Fprintln(stdout, container.Id)
|
||||||
} else {
|
} else {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
@ -245,7 +244,7 @@ func (srv *Server) CmdRestart(stdin io.ReadCloser, stdout io.Writer, args ...str
|
||||||
}
|
}
|
||||||
fmt.Fprintln(stdout, container.Id)
|
fmt.Fprintln(stdout, container.Id)
|
||||||
} else {
|
} else {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
@ -267,7 +266,7 @@ func (srv *Server) CmdStart(stdin io.ReadCloser, stdout io.Writer, args ...strin
|
||||||
}
|
}
|
||||||
fmt.Fprintln(stdout, container.Id)
|
fmt.Fprintln(stdout, container.Id)
|
||||||
} else {
|
} else {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
@ -320,7 +319,7 @@ func (srv *Server) CmdPort(stdin io.ReadCloser, stdout io.Writer, args ...string
|
||||||
name := cmd.Arg(0)
|
name := cmd.Arg(0)
|
||||||
privatePort := cmd.Arg(1)
|
privatePort := cmd.Arg(1)
|
||||||
if container := srv.runtime.Get(name); container == nil {
|
if container := srv.runtime.Get(name); container == nil {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
} else {
|
} else {
|
||||||
if frontend, exists := container.NetworkSettings.PortMapping[privatePort]; !exists {
|
if frontend, exists := container.NetworkSettings.PortMapping[privatePort]; !exists {
|
||||||
return fmt.Errorf("No private port '%s' allocated on %s", privatePort, name)
|
return fmt.Errorf("No private port '%s' allocated on %s", privatePort, name)
|
||||||
|
@ -383,7 +382,7 @@ func (srv *Server) CmdRm(stdin io.ReadCloser, stdout io.Writer, args ...string)
|
||||||
for _, name := range cmd.Args() {
|
for _, name := range cmd.Args() {
|
||||||
container := srv.runtime.Get(name)
|
container := srv.runtime.Get(name)
|
||||||
if container == nil {
|
if container == nil {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
if err := srv.runtime.Destroy(container); err != nil {
|
if err := srv.runtime.Destroy(container); err != nil {
|
||||||
fmt.Fprintln(stdout, "Error destroying container "+name+": "+err.Error())
|
fmt.Fprintln(stdout, "Error destroying container "+name+": "+err.Error())
|
||||||
|
@ -401,7 +400,7 @@ func (srv *Server) CmdKill(stdin io.ReadCloser, stdout io.Writer, args ...string
|
||||||
for _, name := range cmd.Args() {
|
for _, name := range cmd.Args() {
|
||||||
container := srv.runtime.Get(name)
|
container := srv.runtime.Get(name)
|
||||||
if container == nil {
|
if container == nil {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
if err := container.Kill(); err != nil {
|
if err := container.Kill(); err != nil {
|
||||||
fmt.Fprintln(stdout, "Error killing container "+name+": "+err.Error())
|
fmt.Fprintln(stdout, "Error killing container "+name+": "+err.Error())
|
||||||
|
@ -420,7 +419,7 @@ func (srv *Server) CmdImport(stdin io.ReadCloser, stdout io.Writer, args ...stri
|
||||||
}
|
}
|
||||||
src := cmd.Arg(0)
|
src := cmd.Arg(0)
|
||||||
if src == "" {
|
if src == "" {
|
||||||
return errors.New("Not enough arguments")
|
return fmt.Errorf("Not enough arguments")
|
||||||
} else if src == "-" {
|
} else if src == "-" {
|
||||||
archive = stdin
|
archive = stdin
|
||||||
} else {
|
} else {
|
||||||
|
@ -718,7 +717,7 @@ func (srv *Server) CmdExport(stdin io.ReadCloser, stdout io.Writer, args ...stri
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (srv *Server) CmdDiff(stdin io.ReadCloser, stdout io.Writer, args ...string) error {
|
func (srv *Server) CmdDiff(stdin io.ReadCloser, stdout io.Writer, args ...string) error {
|
||||||
|
@ -729,10 +728,10 @@ func (srv *Server) CmdDiff(stdin io.ReadCloser, stdout io.Writer, args ...string
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
if cmd.NArg() < 1 {
|
if cmd.NArg() < 1 {
|
||||||
return errors.New("Not enough arguments")
|
return fmt.Errorf("Not enough arguments")
|
||||||
}
|
}
|
||||||
if container := srv.runtime.Get(cmd.Arg(0)); container == nil {
|
if container := srv.runtime.Get(cmd.Arg(0)); container == nil {
|
||||||
return errors.New("No such container")
|
return fmt.Errorf("No such container")
|
||||||
} else {
|
} else {
|
||||||
changes, err := container.Changes()
|
changes, err := container.Changes()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -774,7 +773,7 @@ func (srv *Server) CmdLogs(stdin io.ReadCloser, stdout io.Writer, args ...string
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
return errors.New("No such container: " + cmd.Arg(0))
|
return fmt.Errorf("No such container: %s", cmd.Arg(0))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (srv *Server) CmdAttach(stdin io.ReadCloser, stdout io.Writer, args ...string) error {
|
func (srv *Server) CmdAttach(stdin io.ReadCloser, stdout io.Writer, args ...string) error {
|
||||||
|
@ -789,7 +788,7 @@ func (srv *Server) CmdAttach(stdin io.ReadCloser, stdout io.Writer, args ...stri
|
||||||
name := cmd.Arg(0)
|
name := cmd.Arg(0)
|
||||||
container := srv.runtime.Get(name)
|
container := srv.runtime.Get(name)
|
||||||
if container == nil {
|
if container == nil {
|
||||||
return errors.New("No such container: " + name)
|
return fmt.Errorf("No such container: %s", name)
|
||||||
}
|
}
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
if container.Config.OpenStdin {
|
if container.Config.OpenStdin {
|
||||||
|
|
|
@ -2,7 +2,6 @@ package docker
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/dotcloud/docker/rcli"
|
"github.com/dotcloud/docker/rcli"
|
||||||
"github.com/kr/pty"
|
"github.com/kr/pty"
|
||||||
|
@ -464,7 +463,7 @@ func (container *Container) WaitTimeout(timeout time.Duration) error {
|
||||||
|
|
||||||
select {
|
select {
|
||||||
case <-time.After(timeout):
|
case <-time.After(timeout):
|
||||||
return errors.New("Timed Out")
|
return fmt.Errorf("Timed Out")
|
||||||
case <-done:
|
case <-done:
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue