diff options
| author | Dan Engelbrecht <[email protected]> | 2025-04-03 14:28:51 +0200 |
|---|---|---|
| committer | GitHub Enterprise <[email protected]> | 2025-04-03 14:28:51 +0200 |
| commit | 64cd6e328bee3a94bc0bf10441b4057f7be34d1c (patch) | |
| tree | c1656ae98110ed24b88ac82e32ad3d849bea3ae9 /src/zen/cmds/builds_cmd.cpp | |
| parent | `zen oplog-export`, `zen oplog-import` for `--url` (cloud) and `--builds` (bu... (diff) | |
| download | archived-zen-64cd6e328bee3a94bc0bf10441b4057f7be34d1c.tar.xz archived-zen-64cd6e328bee3a94bc0bf10441b4057f7be34d1c.zip | |
build store save access times (#341)v5.6.3-pre0
* save payload size in log for buildstore
* read/write access times and manifest for buldstore
* use retry when removing temporary files
Diffstat (limited to 'src/zen/cmds/builds_cmd.cpp')
| -rw-r--r-- | src/zen/cmds/builds_cmd.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/zen/cmds/builds_cmd.cpp b/src/zen/cmds/builds_cmd.cpp index f6b7299cb..d503ae45e 100644 --- a/src/zen/cmds/builds_cmd.cpp +++ b/src/zen/cmds/builds_cmd.cpp @@ -4932,7 +4932,7 @@ namespace { FilteredWrittenBytesPerSecond.Stop(); } - RemoveFile(CompressedChunkPath); + RemoveFileWithRetry(CompressedChunkPath); std::vector<uint32_t> CompletedSequences = CompleteChunkTargets(ChunkTargetPtrs, SequenceIndexChunksLeftToWriteCounters); @@ -5761,7 +5761,7 @@ namespace { FilteredWrittenBytesPerSecond.Stop(); } - RemoveFile(CompressedChunkPath); + RemoveFileWithRetry(CompressedChunkPath); std::vector<uint32_t> CompletedSequences = CompleteChunkTargets(ChunkTargetPtrs, SequenceIndexChunksLeftToWriteCounters); @@ -6169,7 +6169,7 @@ namespace { throw std::runtime_error(fmt::format("Block {} is malformed", BlockDescription.BlockHash)); } WritePartsComplete++; - RemoveFile(BlockChunkPath); + RemoveFileWithRetry(BlockChunkPath); if (WritePartsComplete == TotalPartWriteCount) { FilteredWrittenBytesPerSecond.Stop(); @@ -6328,7 +6328,7 @@ namespace { if (!BlockChunkPath.empty()) { - RemoveFile(BlockChunkPath); + RemoveFileWithRetry(BlockChunkPath); } WritePartsComplete++; @@ -6508,7 +6508,7 @@ namespace { if (!BlockChunkPath.empty()) { - RemoveFile(BlockChunkPath); + RemoveFileWithRetry(BlockChunkPath); } WritePartsComplete++; |