Skip to content

Commit

Permalink
Retry file deletion if it fails
Browse files Browse the repository at this point in the history
The file deletion could fail if it is still held by the web server.

This CL adds retry logic to retry the deletion.

Closes #533.

Change-Id: Ib42ed8db11f32897a29e3b58c1be89d05f5dd034
  • Loading branch information
kqyang committed Jan 2, 2019
1 parent 5bf8ad5 commit 6d6db76
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 2 deletions.
6 changes: 5 additions & 1 deletion packager/hls/base/media_playlist.cc
Original file line number Diff line number Diff line change
Expand Up @@ -636,7 +636,11 @@ void MediaPlaylist::RemoveOldSegment(int64_t start_time) {
while (segments_to_be_removed_.size() >
hls_params_.preserved_segments_outside_live_window) {
VLOG(2) << "Deleting " << segments_to_be_removed_.front();
File::Delete(segments_to_be_removed_.front().c_str());
if (!File::Delete(segments_to_be_removed_.front().c_str())) {
LOG(WARNING) << "Failed to delete " << segments_to_be_removed_.front()
<< "; Will retry later.";
break;
}
segments_to_be_removed_.pop_front();
}
}
Expand Down
6 changes: 5 additions & 1 deletion packager/mpd/base/representation.cc
Original file line number Diff line number Diff line change
Expand Up @@ -500,7 +500,11 @@ void Representation::RemoveSegments(int64_t start_time,
while (segments_to_be_removed_.size() >
mpd_options_.mpd_params.preserved_segments_outside_live_window) {
VLOG(2) << "Deleting " << segments_to_be_removed_.front();
File::Delete(segments_to_be_removed_.front().c_str());
if (!File::Delete(segments_to_be_removed_.front().c_str())) {
LOG(WARNING) << "Failed to delete " << segments_to_be_removed_.front()
<< "; Will retry later.";
break;
}
segments_to_be_removed_.pop_front();
}
}
Expand Down

0 comments on commit 6d6db76

Please # to comment.