Skip to content

Commit

Permalink
Some more style fixes
Browse files Browse the repository at this point in the history
Signed-off-by: Alexandr Morozov <lk4d4math@gmail.com>
  • Loading branch information
LK4D4 committed Aug 29, 2014
1 parent 6eaac7d commit 114838c
Show file tree
Hide file tree
Showing 6 changed files with 23 additions and 26 deletions.
2 changes: 1 addition & 1 deletion engine/table.go
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ func (t *Table) WriteListTo(dst io.Writer) (n int64, err error) {
if _, err := dst.Write([]byte{','}); err != nil {
return -1, err
}
n += 1
n++
}
}
if _, err := dst.Write([]byte{']'}); err != nil {
Expand Down
5 changes: 2 additions & 3 deletions graph/pull.go
Original file line number Diff line number Diff line change
Expand Up @@ -80,10 +80,9 @@ func (s *TagStore) pullRepository(r *registry.Session, out io.Writer, localName,
if err != nil {
if strings.Contains(err.Error(), "HTTP code: 404") {
return fmt.Errorf("Error: image %s not found", remoteName)
} else {
// Unexpected HTTP error
return err
}
// Unexpected HTTP error
return err
}

log.Debugf("Retrieving the tag list")
Expand Down
4 changes: 2 additions & 2 deletions graph/push.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@ import (
func (s *TagStore) getImageList(localRepo map[string]string, requestedTag string) ([]string, map[string][]string, error) {
var (
imageList []string
imagesSeen map[string]bool = make(map[string]bool)
tagsByImage map[string][]string = make(map[string][]string)
imagesSeen = make(map[string]bool)
tagsByImage = make(map[string][]string)
)

for tag, id := range localRepo {
Expand Down
7 changes: 3 additions & 4 deletions graph/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -170,12 +170,11 @@ func (s *TagStore) CmdTarLayer(job *engine.Job) engine.Status {
}
defer fs.Close()

if written, err := io.Copy(job.Stdout, fs); err != nil {
written, err := io.Copy(job.Stdout, fs)
if err != nil {
return job.Error(err)
} else {
log.Debugf("rendered layer for %s of [%d] size", image.ID, written)
}

log.Debugf("rendered layer for %s of [%d] size", image.ID, written)
return engine.StatusOK
}
return job.Errorf("No such image: %s", name)
Expand Down
28 changes: 14 additions & 14 deletions graph/tags.go
Original file line number Diff line number Diff line change
Expand Up @@ -288,42 +288,42 @@ func validateTagName(name string) error {
return nil
}

func (s *TagStore) poolAdd(kind, key string) (chan struct{}, error) {
s.Lock()
defer s.Unlock()
func (store *TagStore) poolAdd(kind, key string) (chan struct{}, error) {
store.Lock()
defer store.Unlock()

if c, exists := s.pullingPool[key]; exists {
if c, exists := store.pullingPool[key]; exists {
return c, fmt.Errorf("pull %s is already in progress", key)
}
if c, exists := s.pushingPool[key]; exists {
if c, exists := store.pushingPool[key]; exists {
return c, fmt.Errorf("push %s is already in progress", key)
}

c := make(chan struct{})
switch kind {
case "pull":
s.pullingPool[key] = c
store.pullingPool[key] = c
case "push":
s.pushingPool[key] = c
store.pushingPool[key] = c
default:
return nil, fmt.Errorf("Unknown pool type")
}
return c, nil
}

func (s *TagStore) poolRemove(kind, key string) error {
s.Lock()
defer s.Unlock()
func (store *TagStore) poolRemove(kind, key string) error {
store.Lock()
defer store.Unlock()
switch kind {
case "pull":
if c, exists := s.pullingPool[key]; exists {
if c, exists := store.pullingPool[key]; exists {
close(c)
delete(s.pullingPool, key)
delete(store.pullingPool, key)
}
case "push":
if c, exists := s.pushingPool[key]; exists {
if c, exists := store.pushingPool[key]; exists {
close(c)
delete(s.pushingPool, key)
delete(store.pushingPool, key)
}
default:
return fmt.Errorf("Unknown pool type")
Expand Down
3 changes: 1 addition & 2 deletions utils/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -653,9 +653,8 @@ func ValidateContextDirectory(srcPath string, excludes []string) error {
if err != nil && os.IsPermission(err) {
finalError = fmt.Errorf("no permission to read from '%s'", filePath)
return err
} else {
currentFile.Close()
}
currentFile.Close()
}
return nil
})
Expand Down

0 comments on commit 114838c

Please sign in to comment.