func (v *AzureBlobVolume) get(loc string) ([]byte, error) {
rdr, err := v.bsClient.GetBlob(v.containerName, loc)
if err != nil {
- if strings.Contains(err.Error(), "404 Not Found") {
- // "storage: service returned without a response body (404 Not Found)"
- return nil, os.ErrNotExist
- }
- return nil, err
- }
- switch err := err.(type) {
- case nil:
- default:
- log.Printf("ERROR IN Get(): %T %#v", err, err)
- return nil, err
+ return nil, v.translateError(err)
}
defer rdr.Close()
buf := bufs.Get(BlockSize)
n, err := io.ReadFull(rdr, buf)
switch err {
- case io.EOF, io.ErrUnexpectedEOF:
+ case nil, io.EOF, io.ErrUnexpectedEOF:
return buf[:n], nil
default:
bufs.Put(buf)
func (v *AzureBlobVolume) Compare(loc string, expect []byte) error {
rdr, err := v.bsClient.GetBlob(v.containerName, loc)
if err != nil {
- return err
+ return v.translateError(err)
}
defer rdr.Close()
return compareReaderWithBuf(rdr, expect, loc[:32])
func (v *AzureBlobVolume) Replication() int {
return v.replication
}
+
+// If possible, translate an Azure SDK error to a recognizable error
+// like os.ErrNotExist.
+func (v *AzureBlobVolume) translateError(err error) error {
+ switch {
+ case err == nil:
+ return err
+ case strings.Contains(err.Error(), "404 Not Found"):
+ // "storage: service returned without a response body (404 Not Found)"
+ return os.ErrNotExist
+ default:
+ return err
+ }
+}