Correctly check and propagate errors in v2 session

Signed-off-by: Stephen J Day <stephen.day@docker.com>
This commit is contained in:
Stephen J Day 2014-12-22 14:58:08 -08:00 committed by Derek McGowan
parent 22c7328529
commit 6f09abd5c9

View file

@ -65,7 +65,7 @@ func (r *Session) GetV2ImageManifest(imageName, tagName string, auth *RequestAut
if err != nil { if err != nil {
return nil, err return nil, err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return nil, err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)
@ -105,8 +105,8 @@ func (r *Session) PostV2ImageMountBlob(imageName, sumType, sum string, auth *Req
if err != nil { if err != nil {
return false, err return false, err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return false, err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)
if err != nil { if err != nil {
@ -136,8 +136,8 @@ func (r *Session) GetV2ImageBlob(imageName, sumType, sum string, blobWrtr io.Wri
if err != nil { if err != nil {
return err return err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)
if err != nil { if err != nil {
@ -167,8 +167,8 @@ func (r *Session) GetV2ImageBlobReader(imageName, sumType, sum string, auth *Req
if err != nil { if err != nil {
return nil, 0, err return nil, 0, err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return nil, 0, err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)
if err != nil { if err != nil {
@ -204,8 +204,8 @@ func (r *Session) PutV2ImageBlob(imageName, sumType, sumStr string, blobRdr io.R
return err return err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)
if err != nil { if err != nil {
@ -222,8 +222,8 @@ func (r *Session) PutV2ImageBlob(imageName, sumType, sumStr string, blobRdr io.R
queryParams := url.Values{} queryParams := url.Values{}
queryParams.Add("digest", sumType+":"+sumStr) queryParams.Add("digest", sumType+":"+sumStr)
req.URL.RawQuery = queryParams.Encode() req.URL.RawQuery = queryParams.Encode()
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return err
} }
res, _, err = r.doRequest(req) res, _, err = r.doRequest(req)
if err != nil { if err != nil {
@ -254,8 +254,8 @@ func (r *Session) PutV2ImageManifest(imageName, tagName string, manifestRdr io.R
if err != nil { if err != nil {
return err return err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)
if err != nil { if err != nil {
@ -288,7 +288,7 @@ func (r *Session) GetV2RemoteTags(imageName string, auth *RequestAuthorization)
if err != nil { if err != nil {
return nil, err return nil, err
} }
if err := auth.Authorize(req) { if err := auth.Authorize(req); err != nil {
return nil, err return nil, err
} }
res, _, err := r.doRequest(req) res, _, err := r.doRequest(req)