diff options
| author | Nikita Borzykh <sample@fastmail.com> | 2024-04-02 01:55:16 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-04-01 15:55:16 -0700 |
| commit | df9031e19a96a97f12613d7b4c90eb19b265d311 (patch) | |
| tree | cf33f2bc77af09d2f18b48fbcc2a74e9210e77e3 | |
| parent | 94008a84a492ed784dc90df48eada545d748f8a8 (diff) | |
| download | seaweedfs-df9031e19a96a97f12613d7b4c90eb19b265d311.tar.xz seaweedfs-df9031e19a96a97f12613d7b4c90eb19b265d311.zip | |
fix: ensure complete gRPC stream consumption in doListFilerEntries to prevent context canceled errors. (#5441)
| -rw-r--r-- | weed/s3api/s3api_objects_list_handlers.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/s3api/s3api_objects_list_handlers.go b/weed/s3api/s3api_objects_list_handlers.go index f332da856..b00e4630d 100644 --- a/weed/s3api/s3api_objects_list_handlers.go +++ b/weed/s3api/s3api_objects_list_handlers.go @@ -374,7 +374,7 @@ func (s3a *S3ApiServer) doListFilerEntries(client filer_pb.SeaweedFilerClient, d } if cursor.maxKeys <= 0 { cursor.isTruncated = true - return + continue } entry := resp.Entry nextMarker = entry.Name |