get layer: remove HEAD req & pass down response

Docker-DCO-1.1-Signed-off-by: Cristian Staretu <cristian.staretu@gmail.com> (github: unclejack)
This commit is contained in:
unclejack 2014-06-27 15:10:30 +03:00
parent bc35ac4afd
commit 78a499ac67

View file

@ -390,52 +390,42 @@ func (r *Registry) GetRemoteImageJSON(imgID, registry string, token []string) ([
func (r *Registry) GetRemoteImageLayer(imgID, registry string, token []string, imgSize int64) (io.ReadCloser, error) { func (r *Registry) GetRemoteImageLayer(imgID, registry string, token []string, imgSize int64) (io.ReadCloser, error) {
var ( var (
retries = 5 retries = 5
headRes *http.Response client *http.Client
client *http.Client res *http.Response
hasResume bool = false imageURL = fmt.Sprintf("%simages/%s/layer", registry, imgID)
imageURL = fmt.Sprintf("%simages/%s/layer", registry, imgID)
) )
headReq, err := r.reqFactory.NewRequest("HEAD", imageURL, nil)
if err != nil {
return nil, fmt.Errorf("Error while getting from the server: %s\n", err)
}
setTokenAuth(headReq, token)
for i := 1; i <= retries; i++ {
headRes, client, err = r.doRequest(headReq)
if err != nil && i == retries {
return nil, fmt.Errorf("Eror while making head request: %s\n", err)
} else if err != nil {
time.Sleep(time.Duration(i) * 5 * time.Second)
continue
}
break
}
if headRes.Header.Get("Accept-Ranges") == "bytes" && imgSize > 0 {
hasResume = true
}
req, err := r.reqFactory.NewRequest("GET", imageURL, nil) req, err := r.reqFactory.NewRequest("GET", imageURL, nil)
if err != nil { if err != nil {
return nil, fmt.Errorf("Error while getting from the server: %s\n", err) return nil, fmt.Errorf("Error while getting from the server: %s\n", err)
} }
setTokenAuth(req, token) setTokenAuth(req, token)
if hasResume { for i := 1; i <= retries; i++ {
utils.Debugf("server supports resume") res, client, err = r.doRequest(req)
return utils.ResumableRequestReader(client, req, 5, imgSize), nil if err != nil {
} res.Body.Close()
utils.Debugf("server doesn't support resume") if i == retries {
res, _, err := r.doRequest(req) return nil, fmt.Errorf("Server error: Status %d while fetching image layer (%s)",
if err != nil { res.StatusCode, imgID)
return nil, err }
time.Sleep(time.Duration(i) * 5 * time.Second)
continue
}
break
} }
if res.StatusCode != 200 { if res.StatusCode != 200 {
res.Body.Close() res.Body.Close()
return nil, fmt.Errorf("Server error: Status %d while fetching image layer (%s)", return nil, fmt.Errorf("Server error: Status %d while fetching image layer (%s)",
res.StatusCode, imgID) res.StatusCode, imgID)
} }
if res.Header.Get("Accept-Ranges") == "bytes" && imgSize > 0 {
utils.Debugf("server supports resume")
return utils.ResumableRequestReaderWithInitialResponse(client, req, 5, imgSize, res), nil
}
utils.Debugf("server doesn't support resume")
return res.Body, nil return res.Body, nil
} }