Skip to content

Commit 937a4e1

Browse files
authored
refactor(grpc): simplify download task success handling (#1581)
Signed-off-by: Gaius <gaius.qi@gmail.com>
1 parent b06dc0b commit 937a4e1

File tree

2 files changed

+16
-16
lines changed

2 files changed

+16
-16
lines changed

dragonfly-client/src/grpc/dfdaemon_download.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -483,15 +483,15 @@ impl DfdaemonDownload for DfdaemonDownloadServerHandler {
483483

484484
// Download task succeeded.
485485
info!("download task succeeded");
486-
if download_clone.range.is_none() {
487-
if let Err(err) =
488-
task_manager_clone.download_finished(task_clone.id.as_str())
489-
{
490-
error!("download task finished: {}", err);
491-
handle_error(&out_stream_tx, err).await;
492-
return;
493-
}
486+
if let Err(err) =
487+
task_manager_clone.download_finished(task_clone.id.as_str())
488+
{
489+
error!("download task finished: {}", err);
490+
handle_error(&out_stream_tx, err).await;
491+
return;
492+
}
494493

494+
if download_clone.range.is_none() {
495495
if let Some(output_path) = &download_clone.output_path {
496496
if !download_clone.force_hard_link {
497497
let output_path = Path::new(output_path.as_str());

dragonfly-client/src/grpc/dfdaemon_upload.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -480,15 +480,15 @@ impl DfdaemonUpload for DfdaemonUploadServerHandler {
480480

481481
// Download task succeeded.
482482
info!("download task succeeded");
483-
if download_clone.range.is_none() {
484-
if let Err(err) =
485-
task_manager_clone.download_finished(task_clone.id.as_str())
486-
{
487-
error!("download task finished: {}", err);
488-
handle_error(&out_stream_tx, err).await;
489-
return;
490-
}
483+
if let Err(err) =
484+
task_manager_clone.download_finished(task_clone.id.as_str())
485+
{
486+
error!("download task finished: {}", err);
487+
handle_error(&out_stream_tx, err).await;
488+
return;
489+
}
491490

491+
if download_clone.range.is_none() {
492492
if let Some(output_path) = &download_clone.output_path {
493493
if !download_clone.force_hard_link {
494494
let output_path = Path::new(output_path.as_str());

0 commit comments

Comments
 (0)