vbatts/registry
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

fix testcase TestReadStreamWithOffset incompatible with oss

Browse source 
Signed-off-by: tgic <farmer1992@gmail.com>
This commit is contained in:
tgic 2015-07-05 01:14:24 +08:00
parent 2a8535626f
commit 8e5c901a26
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
registry/storage/driver/oss/oss.go
View file

@ -276,12 +276,18 @@ func (d *driver) ReadStream(ctx context.Context, path string, offset int64) (io.
resp, err := d.Bucket.GetResponseWithHeaders(d.ossPath(path), headers) resp, err := d.Bucket.GetResponseWithHeaders(d.ossPath(path), headers)
if err != nil { if err != nil {
if ossErr, ok := err.(*oss.Error); ok && ossErr.Code == "InvalidRange" {
return ioutil.NopCloser(bytes.NewReader(nil)), nil
}
return nil, parseError(path, err) return nil, parseError(path, err)
} }
// Due to Aliyun OSS API, status 200 and whole object will be return instead of an
// InvalidRange error when range is invalid.
//
// OSS sever will always return http.StatusPartialContent if range is acceptable.
if resp.StatusCode != http.StatusPartialContent {
resp.Body.Close()
return ioutil.NopCloser(bytes.NewReader(nil)), nil
}
return resp.Body, nil return resp.Body, nil
} }