GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/ingestion/task_write.cc
Date: 2025-07-06 02:35:01
Exec Total Coverage
Lines: 35 39 89.7%
Branches: 21 35 60.0%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5
6 #include "task_write.h"
7
8 #include <cstdlib>
9
10 #include "upload_facility.h"
11 #include "util/exception.h"
12 #include "util/logging.h"
13
14
15 11746696 void TaskWrite::OnBlockComplete(const upload::UploaderResults &results,
16 BlockItem *block_item) {
17
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 11746696 times.
 11746696 if (results.return_code != 0) {
18 ✗ PANIC(kLogStderr, "block upload failed (code: %d)", results.return_code);
19 }
20
21
1/2
✓ Branch 0 taken 11746696 times.
✗ Branch 1 not taken.
 11746696 delete block_item;
22 11746696 }
23
24
25 7514606 void TaskWrite::OnChunkComplete(const upload::UploaderResults &results,
26 ChunkItem *chunk_item) {
27
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 7514606 times.
 7514606 if (results.return_code != 0) {
28 ✗ PANIC(kLogStderr, "chunk upload failed (code: %d)", results.return_code);
29 }
30
31 7514606 FileItem *file_item = chunk_item->file_item();
32
1/2
✓ Branch 3 taken 7514606 times.
✗ Branch 4 not taken.
 15029212 file_item->RegisterChunk(FileChunk(
33 7514606 *chunk_item->hash_ptr(), chunk_item->offset(), chunk_item->size()));
34
1/2
✓ Branch 0 taken 7514606 times.
✗ Branch 1 not taken.
 7514606 delete chunk_item;
35
36
2/2
✓ Branch 1 taken 7502211 times.
✓ Branch 2 taken 12395 times.
 7514606 if (file_item->IsProcessed()) {
37 7502211 tubes_out_->DispatchAny(file_item);
38 }
39 7514606 }
40
41
42 19244322 void TaskWrite::Process(BlockItem *input_block) {
43 19244322 ChunkItem *chunk_item = input_block->chunk_item();
44
45 19246002 upload::UploadStreamHandle *handle = chunk_item->upload_handle();
46
2/2
✓ Branch 0 taken 7512086 times.
✓ Branch 1 taken 11732806 times.
 19244892 if (handle == NULL) {
47 // The closure passed here, is called by the AbstractUploader as soon as
48 // it successfully committed the complete chunk
49 22535478 handle = uploader_->InitStreamedUpload(
50
2/4
✓ Branch 1 taken 7511276 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 7512116 times.
✗ Branch 5 not taken.
 7512086 upload::AbstractUploader::MakeClosure(
51 &TaskWrite::OnChunkComplete, this, chunk_item));
52
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 7512116 times.
 7512116 assert(handle != NULL);
53 7512116 chunk_item->set_upload_handle(handle);
54 }
55
56
2/3
✓ Branch 1 taken 11738356 times.
✓ Branch 2 taken 7511456 times.
✗ Branch 3 not taken.
 19244292 switch (input_block->type()) {
57 11738356 case BlockItem::kBlockData:
58
1/2
✓ Branch 2 taken 11745646 times.
✗ Branch 3 not taken.
 11736316 uploader_->ScheduleUpload(
59 handle,
60 11736256 upload::AbstractUploader::UploadBuffer(input_block->size(),
61 11737306 input_block->data()),
62
1/2
✓ Branch 1 taken 11737306 times.
✗ Branch 2 not taken.
 11738356 upload::AbstractUploader::MakeClosure(
63 &TaskWrite::OnBlockComplete, this, input_block));
64 11745646 break;
65 7511456 case BlockItem::kBlockStop:
66 // If there is a sole piece and a legacy bulk chunk, two times the same
67 // chunk is being uploaded. Well. It doesn't hurt.
68
2/2
✓ Branch 1 taken 5 times.
✓ Branch 2 taken 7511541 times.
 7511456 if (chunk_item->IsSolePiece()) {
69
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 chunk_item->MakeBulkChunk();
70 }
71
1/2
✓ Branch 2 taken 7514006 times.
✗ Branch 3 not taken.
 7511546 uploader_->ScheduleCommit(handle, *chunk_item->hash_ptr());
72
1/2
✓ Branch 0 taken 7514006 times.
✗ Branch 1 not taken.
 7514006 delete input_block;
73 7514426 break;
74 ✗ default:
75 ✗ PANIC(NULL);
76 }
77 19260072 }
78