Skip to content

Commit df61e36

Browse files
committed
fix http concurrency
Add tests
1 parent 0a857fa commit df61e36

File tree

3 files changed

+406
-201
lines changed

3 files changed

+406
-201
lines changed

sdk/src/Services/S3/Custom/Transfer/Internal/FilePartDataHandler.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public async Task ProcessPartAsync(
9090
partNumber, offset);
9191

9292
// Write part data to file at the calculated offset
93-
await WritePartToFileAsync(offset, response, cancellationToken)
93+
await WritePartToFileAsync(partNumber, offset, response, cancellationToken)
9494
.ConfigureAwait(false);
9595

9696
_logger.DebugFormat("FilePartDataHandler: [Part {0}] File write completed successfully",
@@ -192,6 +192,7 @@ private long GetPartOffset(GetObjectResponse response, int partNumber)
192192
/// Writes part data from GetObjectResponse ResponseStream to the file at the specified offset.
193193
/// </summary>
194194
private async Task WritePartToFileAsync(
195+
int partNumber,
195196
long offset,
196197
GetObjectResponse response,
197198
CancellationToken cancellationToken)
@@ -213,7 +214,7 @@ private async Task WritePartToFileAsync(
213214
// Seek to the correct offset for this part
214215
fileStream.Seek(offset, SeekOrigin.Begin);
215216

216-
_logger.DebugFormat("FilePartDataHandler: Writing {0} bytes to file at offset {1}",
217+
_logger.DebugFormat("FilePartDataHandler: [Part {0} Writing {1} bytes to file at offset {2}", partNumber,
217218
response.ContentLength, offset);
218219

219220
// Use GetObjectResponse's stream copy logic which includes:
@@ -232,7 +233,7 @@ await response.WriteResponseStreamAsync(
232233
await fileStream.FlushAsync(cancellationToken)
233234
.ConfigureAwait(false);
234235

235-
_logger.DebugFormat("FilePartDataHandler: Successfully wrote {0} bytes at offset {1}",
236+
_logger.DebugFormat("FilePartDataHandler: [Part {0}] Successfully wrote {1} bytes at offset {2}", partNumber,
236237
response.ContentLength, offset);
237238
}
238239
}

0 commit comments

Comments
 (0)