GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/upload_facility.cc
Date: 2026-02-01 02:35:56
Exec Total Coverage
Lines: 72 88 81.8%
Branches: 26 55 47.3%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "upload_facility.h"
6
7 #include <cassert>
8
9 #include "upload_gateway.h"
10 #include "upload_local.h"
11 #include "upload_s3.h"
12 #include "util/exception.h"
13
14 namespace upload {
15
16 atomic_int64 UploadStreamHandle::g_upload_stream_tag = 0;
17
18 16739015 AbstractUploader::UploadJob::UploadJob(UploadStreamHandle *handle,
19 UploadBuffer buffer,
20 16739015 const CallbackTN *callback)
21 16739015 : type(Upload)
22 16739015 , stream_handle(handle)
23 16739015 , tag_(handle->tag)
24 16739015 , buffer(buffer)
25 16739015 , callback(callback) { }
26
27 9779328 AbstractUploader::UploadJob::UploadJob(UploadStreamHandle *handle,
28 9779328 const shash::Any &content_hash)
29 9779328 : type(Commit)
30 9779328 , stream_handle(handle)
31 9779328 , tag_(handle->tag)
32 9779328 , buffer()
33 9779367 , callback(NULL)
34 9779367 , content_hash(content_hash) { }
35
36 2611 void AbstractUploader::RegisterPlugins() {
37 2611 RegisterPlugin<LocalUploader>();
38 2611 RegisterPlugin<S3Uploader>();
39 2611 RegisterPlugin<GatewayUploader>();
40 2611 }
41
42 4438 AbstractUploader::AbstractUploader(const SpoolerDefinition &spooler_definition)
43 4438 : spooler_definition_(spooler_definition)
44 4438 , num_upload_tasks_(spooler_definition.num_upload_tasks)
45
3/6
✓ Branch 3 taken 4438 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 4438 times.
✗ Branch 7 not taken.
✓ Branch 11 taken 4438 times.
✗ Branch 12 not taken.
 4438 , jobs_in_flight_(spooler_definition.number_of_concurrent_uploads) { }
46
47
48 4438 bool AbstractUploader::Initialize() {
49
2/2
✓ Branch 1 taken 5614 times.
✓ Branch 2 taken 4438 times.
 10052 for (unsigned i = 0; i < GetNumTasks(); ++i) {
50
1/2
✓ Branch 2 taken 5614 times.
✗ Branch 3 not taken.
 5614 Tube<UploadJob> *t = new Tube<UploadJob>();
51 5614 tubes_upload_.TakeTube(t);
52
1/2
✓ Branch 2 taken 5614 times.
✗ Branch 3 not taken.
 5614 tasks_upload_.TakeConsumer(new TaskUpload(this, t));
53 }
54 4438 tubes_upload_.Activate();
55 4438 tasks_upload_.Spawn();
56 4438 return true;
57 }
58
59 649 bool AbstractUploader::FinalizeSession(bool /*commit*/,
60 const std::string & /*old_root_hash*/,
61 const std::string & /*new_root_hash*/,
62 const RepositoryTag & /*tag*/) {
63 649 return true;
64 }
65
66
67 6341 int AbstractUploader::CreateAndOpenTemporaryChunkFile(std::string *path) const {
68 const std::string tmp_path = CreateTempPath(
69
3/6
✓ Branch 1 taken 6341 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 6341 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 6341 times.
✗ Branch 8 not taken.
 12682 spooler_definition_.temporary_path + "/" + "chunk", 0644);
70
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 6341 times.
 6341 if (tmp_path.empty()) {
71 ✗ LogCvmfs(kLogSpooler, kLogStderr,
72 "Failed to create temp file in %s for upload of file chunk"
73 " (errno: %d).",
74 ✗ spooler_definition_.temporary_path.c_str(), errno);
75 ✗ return -1;
76 }
77
78
1/2
✓ Branch 2 taken 6341 times.
✗ Branch 3 not taken.
 6341 const int tmp_fd = open(tmp_path.c_str(), O_WRONLY);
79
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 6341 times.
 6341 if (tmp_fd < 0) {
80 ✗ LogCvmfs(kLogSpooler, kLogStderr,
81 "Failed to open temp file '%s' for upload of file chunk "
82 "(errno: %d)",
83 ✗ tmp_path.c_str(), errno);
84 ✗ unlink(tmp_path.c_str());
85 } else {
86
1/2
✓ Branch 1 taken 6341 times.
✗ Branch 2 not taken.
 6341 *path = tmp_path;
87 }
88
89 6341 return tmp_fd;
90 6341 }
91
92 4437 void AbstractUploader::TearDown() { tasks_upload_.Terminate(); }
93
94 4069 void AbstractUploader::WaitForUpload() const { jobs_in_flight_.WaitForZero(); }
95
96 94 void AbstractUploader::InitCounters(perf::StatisticsTemplate *statistics) {
97
3/6
✓ Branch 2 taken 94 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 94 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 94 times.
✗ Branch 9 not taken.
 94 counters_ = new UploadCounters(*statistics);
98 94 }
99
100 9800 void AbstractUploader::CountUploadedChunks() const {
101
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 9800 times.
 9800 if (counters_.IsValid()) {
102 ✗ perf::Inc(counters_->n_chunks_added);
103 }
104 9800 }
105
106 ✗ void AbstractUploader::DecUploadedChunks() const {
107 ✗ if (counters_.IsValid()) {
108 ✗ perf::Dec(counters_->n_chunks_added);
109 }
110 }
111
112 9800 void AbstractUploader::CountUploadedBytes(int64_t bytes_written) const {
113
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 9800 times.
 9800 if (counters_.IsValid()) {
114 ✗ perf::Xadd(counters_->sz_uploaded_bytes, bytes_written);
115 }
116 9800 }
117
118 ✗ void AbstractUploader::CountDuplicates() const {
119 ✗ if (counters_.IsValid()) {
120 ✗ perf::Inc(counters_->n_chunks_duplicated);
121 }
122 }
123
124 1392 void AbstractUploader::CountUploadedCatalogs() const {
125
2/2
✓ Branch 1 taken 94 times.
✓ Branch 2 taken 1298 times.
 1392 if (counters_.IsValid()) {
126 94 perf::Inc(counters_->n_catalogs_added);
127 }
128 1392 }
129
130 1392 void AbstractUploader::CountUploadedCatalogBytes(int64_t bytes_written) const {
131
2/2
✓ Branch 1 taken 94 times.
✓ Branch 2 taken 1298 times.
 1392 if (counters_.IsValid()) {
132 94 perf::Xadd(counters_->sz_uploaded_catalog_bytes, bytes_written);
133 }
134 1392 }
135
136 //------------------------------------------------------------------------------
137
138
139 26522438 void TaskUpload::Process(AbstractUploader::UploadJob *upload_job) {
140
2/3
✓ Branch 0 taken 16742174 times.
✓ Branch 1 taken 9780264 times.
✗ Branch 2 not taken.
 26522438 switch (upload_job->type) {
141 16742174 case AbstractUploader::UploadJob::Upload:
142 16742174 uploader_->StreamedUpload(upload_job->stream_handle, upload_job->buffer,
143 upload_job->callback);
144 16742174 break;
145
146 9780264 case AbstractUploader::UploadJob::Commit:
147 9780264 uploader_->FinalizeStreamedUpload(upload_job->stream_handle,
148 9780264 upload_job->content_hash);
149 9780264 break;
150
151 ✗ default:
152 ✗ PANIC(NULL);
153 }
154
155
1/2
✓ Branch 0 taken 26522438 times.
✗ Branch 1 not taken.
 26522438 delete upload_job;
156 26522438 }
157
158 } // namespace upload
159