Skip to content

Commit

Permalink
Merge pull request docker-archive#2627 from fugr/fix-vet-warnings
Browse files Browse the repository at this point in the history
fix warnings found by go vet
  • Loading branch information
dongluochen authored Feb 11, 2017
2 parents 99b48d8 + 100dbaf commit 0395b55
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 6 deletions.
2 changes: 1 addition & 1 deletion api/events.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ func (eh *eventsHandler) Handle(e *cluster.Event) error {
eh.RLock()

for key, w := range eh.ws {
if _, err := fmt.Fprintf(w, string(data)); err != nil {
if _, err := fmt.Fprint(w, string(data)); err != nil {
// collect them to handle later under Lock
failed = append(failed, key)
continue
Expand Down
2 changes: 1 addition & 1 deletion cli/cli.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ func Run() {
log.SetOutput(os.Stdout)
level, err := log.ParseLevel(c.String("log-level"))
if err != nil {
log.Fatalf(err.Error())
log.Fatal(err.Error())
}
log.SetLevel(level)

Expand Down
11 changes: 7 additions & 4 deletions cluster/engine.go
Original file line number Diff line number Diff line change
Expand Up @@ -501,7 +501,7 @@ func (e *Engine) updateSpecs() error {
e.state = statePending
message := fmt.Sprintf("Engine (ID: %s, Addr: %s) shows up with another ID:%s. Please remove it from cluster, it can be added back.", e.ID, e.Addr, info.ID)
e.lastError = message
return fmt.Errorf(message)
return errors.New(message)
}

// delta is an estimation of time difference between manager and engine
Expand Down Expand Up @@ -547,7 +547,7 @@ func (e *Engine) updateSpecs() error {
kv := strings.SplitN(label, "=", 2)
if len(kv) != 2 {
message := fmt.Sprintf("Engine (ID: %s, Addr: %s) contains an invalid label (%s) not formatted as \"key=value\".", e.ID, e.Addr, label)
return fmt.Errorf(message)
return errors.New(message)
}

// If an engine managed by Swarm contains a label with key "node",
Expand All @@ -571,7 +571,10 @@ func (e *Engine) updateSpecs() error {

// RemoveImage deletes an image from the engine.
func (e *Engine) RemoveImage(name string, force bool) ([]types.ImageDelete, error) {
rmOpts := types.ImageRemoveOptions{force, true}
rmOpts := types.ImageRemoveOptions{
Force: force,
PruneChildren: true,
}
dels, err := e.apiClient.ImageRemove(context.Background(), name, rmOpts)
e.CheckConnectionErr(err)

Expand Down Expand Up @@ -669,7 +672,7 @@ func (e *Engine) refreshNetwork(ID string) error {

// RefreshNetworks refreshes the list of networks on the engine.
func (e *Engine) RefreshNetworks() error {
netLsOpts := types.NetworkListOptions{filters.NewArgs()}
netLsOpts := types.NetworkListOptions{Filters: filters.NewArgs()}
networks, err := e.apiClient.NetworkList(context.Background(), netLsOpts)
e.CheckConnectionErr(err)
if err != nil {
Expand Down

0 comments on commit 0395b55

Please sign in to comment.