Skip to content

Commit 94df6c0

Browse files
committed
fileservice: more logs for debugging EOF in Write
1 parent cc9ad9e commit 94df6c0

File tree

6 files changed

+12
-5
lines changed

6 files changed

+12
-5
lines changed

pkg/fileservice/aliyun_sdk.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,7 @@ func (a *AliyunSDK) Exists(
226226
if a.is404(err) {
227227
return false, nil
228228
}
229-
return false, err
229+
return false, wrapError("AliyunSDK.Exists", err)
230230
}
231231

232232
return true, nil

pkg/fileservice/aws_sdk_v2.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,7 @@ func (a *AwsSDKv2) Exists(
309309
return false, nil
310310
}
311311
}
312-
return false, err
312+
return false, wrapError("AwsSDKv2.Exists", err)
313313
}
314314
return output != nil, nil
315315
}

pkg/fileservice/disk_object_storage.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ func (d *diskObjectStorage) Exists(ctx context.Context, key string) (bool, error
9595
if os.IsNotExist(err) {
9696
return false, nil
9797
}
98-
return false, err
98+
return false, wrapError("diskObjectStorage.Exists", err)
9999
}
100100
return true, nil
101101
}

pkg/fileservice/error.go

+7
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ package fileservice
1616

1717
import (
1818
"errors"
19+
"fmt"
1920
"io"
2021
"net"
2122
"regexp"
@@ -108,3 +109,9 @@ func isDiskFull(err error) bool {
108109
str := err.Error()
109110
return strings.Contains(str, "disk quota exceeded")
110111
}
112+
113+
var errorF = fmt.Errorf
114+
115+
func wrapError(what string, err error) error {
116+
return errorF(what+": %w", err)
117+
}

pkg/fileservice/minio_sdk.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -312,7 +312,7 @@ func (a *MinioSDK) Exists(
312312
if a.is404(err) {
313313
return false, nil
314314
}
315-
return false, err
315+
return false, wrapError("MinioSDK.Exists", err)
316316
}
317317

318318
return true, nil

pkg/fileservice/qcloud_sdk.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,7 @@ func (a *QCloudSDK) Exists(
229229
if a.is404(err) {
230230
return false, nil
231231
}
232-
return false, err
232+
return false, wrapError("QCloudSDK.Exists", err)
233233
}
234234

235235
return true, nil

0 commit comments

Comments
 (0)