CernVM-FS
2.12.0
|
#include <jobinfo.h>
Private Member Functions | |
void | Init () |
Private Attributes | |
int64_t | id_ |
UniquePtr< Pipe < kPipeDownloadJobsResults > > | pipe_job_results |
Pipe used for the return value. More... | |
UniquePtr< Tube < DataTubeElement > > | data_tube_ |
const std::string * | url_ |
bool | compressed_ |
bool | probe_hosts_ |
bool | head_request_ |
bool | follow_redirects_ |
bool | force_nocache_ |
pid_t | pid_ |
uid_t | uid_ |
gid_t | gid_ |
void * | cred_data_ |
InterruptCue * | interrupt_cue_ |
cvmfs::Sink * | sink_ |
const shash::Any * | expected_hash_ |
const std::string * | extra_info_ |
off_t | range_offset_ |
off_t | range_size_ |
CURL * | curl_handle_ |
curl_slist * | headers_ |
char * | info_header_ |
char * | tracing_header_pid_ |
char * | tracing_header_gid_ |
char * | tracing_header_uid_ |
z_stream | zstream_ |
shash::ContextPtr | hash_context_ |
std::string | proxy_ |
bool | nocache_ |
Failures | error_code_ |
int | http_code_ |
unsigned char | num_used_proxies_ |
unsigned char | num_used_hosts_ |
unsigned char | num_retries_ |
unsigned | backoff_ms_ |
unsigned int | current_host_chain_index_ |
bool | allow_failure_ |
Static Private Attributes | |
static atomic_int64 | next_uuid = 0 |
download::JobInfo::JobInfo | ( | const std::string * | u, |
const bool | c, | ||
const bool | ph, | ||
const shash::Any * | h, | ||
cvmfs::Sink * | s | ||
) |
Sink version: downloads entire data chunk where URL u points to
Definition at line 12 of file jobinfo.cc.
download::JobInfo::JobInfo | ( | const std::string * | u, |
const bool | ph | ||
) |
No sink version: Only downloads header where the URL u points to
Definition at line 23 of file jobinfo.cc.
|
inline |
|
inline |
|
inline |
Definition at line 209 of file jobinfo.h.
Referenced by download::Interrupted(), and SetAllowFailure().
|
inline |
Definition at line 205 of file jobinfo.h.
Referenced by download::DownloadManager::Backoff(), and SetBackoffMs().
|
inline |
Definition at line 173 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::DownloadManager::InitializeRequest(), SetCompressed(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 143 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 135 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 181 of file jobinfo.h.
Referenced by download::DownloadManager::ReleaseCredential(), and SetCredData().
|
inline |
Definition at line 190 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), download::DownloadManager::ReleaseCredential(), SetCurlHandle(), download::DownloadManager::SetNocache(), download::DownloadManager::SetRegularCache(), download::DownloadManager::SetUrlOptions(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 206 of file jobinfo.h.
Referenced by SetCurrentHostChainIndex(), and download::DownloadManager::SwitchHost().
|
inline |
Definition at line 200 of file jobinfo.h.
Referenced by download::CallbackCurlHeader(), download::DownloadManager::CanRetry(), cvmfs::Fetcher::Fetch(), download::DownloadManager::Fetch(), swissknife::CommandPull::Main(), download::DownloadManager::MainDownload(), swissknife::ReportDownloadError(), SetErrorCode(), StreamingCacheManager::Stream(), download::DownloadManager::SwitchHost(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 184 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), SetExpectedHash(), download::DownloadManager::SetUrlOptions(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 185 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), and SetExtraInfo().
|
inline |
Definition at line 176 of file jobinfo.h.
Referenced by download::CallbackCurlHeader(), and SetFollowRedirects().
|
inline |
Definition at line 177 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), and SetForceNocache().
|
inline |
Definition at line 164 of file jobinfo.h.
Referenced by download::DownloadManager::SetUrlOptions().
|
inline |
Definition at line 170 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), and download::DownloadManager::MainDownload().
|
inline |
Definition at line 160 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 167 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 165 of file jobinfo.h.
Referenced by download::DownloadManager::SetRegularCache().
|
inline |
Definition at line 161 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 158 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 168 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), and download::DownloadManager::MainDownload().
|
inline |
Definition at line 159 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 162 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::DownloadManager::InitializeRequest(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 180 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), and SetGid().
|
inline |
Definition at line 197 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), SetHashContext(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 175 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), and SetHeadRequest().
|
inline |
Definition at line 191 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), SetHeaders(), download::DownloadManager::SetNocache(), download::DownloadManager::SetRegularCache(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 201 of file jobinfo.h.
Referenced by download::CallbackCurlHeader(), HttpObjectFetcher< CatalogT, HistoryT, ReflogT >::Download(), swissknife::CommandPull::Main(), swissknife::ReportDownloadError(), and SetHttpCode().
|
inline |
Definition at line 210 of file jobinfo.h.
Referenced by download::DownloadManager::Backoff(), download::CallbackCurlData(), download::CallbackCurlHeader(), download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), download::Interrupted(), download::DownloadManager::MainDownload(), download::PrepareDownloadDestination(), download::DownloadManager::ProbeHosts(), download::DownloadManager::SetUrlOptions(), download::DownloadManager::SwitchHost(), download::DownloadManager::SwitchProxy(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 192 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), and SetInfoHeader().
|
private |
Definition at line 39 of file jobinfo.cc.
Referenced by JobInfo().
|
inline |
Definition at line 182 of file jobinfo.h.
Referenced by SetInterruptCue(), and download::DownloadManager::VerifyAndFinalize().
bool download::JobInfo::IsFileNotFound | ( | ) |
Tells whether the error is because of a non-existing file. Should only be called if error_code is not kFailOk
Definition at line 32 of file jobinfo.cc.
Referenced by publish::DownloadRootObjects(), and publish::IsMasterReplica().
|
inline |
Definition at line 148 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 139 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 199 of file jobinfo.h.
Referenced by download::DownloadManager::CanRetry(), SetNocache(), download::DownloadManager::SetNocache(), download::DownloadManager::SetRegularCache(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 204 of file jobinfo.h.
Referenced by download::DownloadManager::Backoff(), download::DownloadManager::CanRetry(), and SetNumRetries().
|
inline |
Definition at line 203 of file jobinfo.h.
Referenced by SetNumUsedHosts(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 202 of file jobinfo.h.
Referenced by SetNumUsedProxies(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 178 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), SetPid(), and download::DownloadManager::SetUrlOptions().
|
inline |
Definition at line 174 of file jobinfo.h.
Referenced by SetProbeHosts(), download::DownloadManager::SetUrlOptions(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 198 of file jobinfo.h.
Referenced by download::CallbackCurlHeader(), SetProxy(), download::DownloadManager::SetUrlOptions(), download::DownloadManager::SwitchProxy(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 187 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), SetRangeOffset(), and download::DownloadManager::SetUrlOptions().
|
inline |
Definition at line 188 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), and SetRangeSize().
|
inline |
|
inline |
Definition at line 257 of file jobinfo.h.
Referenced by download::DownloadManager::Backoff(), and download::DownloadManager::InitializeRequest().
|
inline |
Definition at line 214 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and cvmfs::Fetcher::GetTls().
|
inline |
Definition at line 223 of file jobinfo.h.
Referenced by download::DownloadManager::ReleaseCredential().
|
inline |
Definition at line 236 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest().
|
inline |
Definition at line 258 of file jobinfo.h.
Referenced by download::DownloadManager::SetUrlOptions().
|
inline |
Definition at line 250 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::CallbackCurlHeader(), download::DownloadManager::InitializeRequest(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 228 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch().
|
inline |
Definition at line 230 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 217 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest().
|
inline |
Definition at line 219 of file jobinfo.h.
Referenced by HttpObjectFetcher< CatalogT, HistoryT, ReflogT >::Download().
|
inline |
|
inline |
|
inline |
Definition at line 237 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
|
inline |
Definition at line 251 of file jobinfo.h.
Referenced by download::CallbackCurlHeader(), and download::DownloadManager::InitializeRequest().
|
inline |
Definition at line 238 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
|
inline |
Definition at line 249 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), download::DownloadManager::SetNocache(), and download::DownloadManager::SetRegularCache().
|
inline |
Definition at line 256 of file jobinfo.h.
Referenced by download::DownloadManager::Backoff(), and download::DownloadManager::InitializeRequest().
|
inline |
Definition at line 254 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 252 of file jobinfo.h.
Referenced by download::DownloadManager::InitializeRequest(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
|
inline |
Definition at line 215 of file jobinfo.h.
Referenced by cvmfs::Fetcher::GetTls().
|
inline |
Definition at line 248 of file jobinfo.h.
Referenced by download::DownloadManager::SetUrlOptions().
|
inline |
Definition at line 233 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 234 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch(), and StreamingCacheManager::Stream().
|
inline |
Definition at line 226 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch().
|
inline |
Definition at line 241 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 239 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
Definition at line 243 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch().
|
inline |
|
inline |
Definition at line 213 of file jobinfo.h.
Referenced by cvmfs::Fetcher::Fetch().
|
inline |
|
inline |
Definition at line 183 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::CallbackCurlHeader(), download::DownloadManager::Fetch(), download::PrepareDownloadDestination(), SetSink(), download::DownloadManager::SetUrlOptions(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 194 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), and SetTracingHeaderGid().
|
inline |
Definition at line 193 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), and SetTracingHeaderPid().
|
inline |
Definition at line 195 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), and SetTracingHeaderUid().
|
inline |
Definition at line 179 of file jobinfo.h.
Referenced by download::DownloadManager::Fetch(), and SetUid().
|
inline |
Definition at line 172 of file jobinfo.h.
Referenced by download::CallbackCurlData(), download::CallbackCurlHeader(), download::DownloadManager::Fetch(), download::DownloadManager::InitializeRequest(), swissknife::ReportDownloadError(), SetUrl(), download::DownloadManager::SetUrlOptions(), and download::DownloadManager::VerifyAndFinalize().
|
inline |
Definition at line 196 of file jobinfo.h.
Referenced by SetZstream().
|
private |
Definition at line 112 of file jobinfo.h.
Referenced by allow_failure(), Init(), and SetAllowFailure().
|
private |
Definition at line 108 of file jobinfo.h.
Referenced by backoff_ms(), Init(), and SetBackoffMs().
|
private |
Definition at line 74 of file jobinfo.h.
Referenced by compressed(), Init(), JobInfo(), and SetCompressed().
|
private |
Definition at line 82 of file jobinfo.h.
Referenced by cred_data(), GetCredDataPtr(), Init(), and SetCredData().
|
private |
Definition at line 93 of file jobinfo.h.
Referenced by curl_handle(), GetCurlHandle(), Init(), and SetCurlHandle().
|
private |
Definition at line 109 of file jobinfo.h.
Referenced by current_host_chain_index(), Init(), and SetCurrentHostChainIndex().
|
private |
Tube (bounded thread-safe queue) to transport data from CURL callback to be decompressed in Fetch() instead of MainDownload()
Definition at line 72 of file jobinfo.h.
Referenced by CreateDataTube(), GetDataTubePtr(), IsValidDataTube(), and ~JobInfo().
|
private |
Definition at line 103 of file jobinfo.h.
Referenced by error_code(), GetErrorCodePtr(), Init(), IsFileNotFound(), and SetErrorCode().
|
private |
Definition at line 85 of file jobinfo.h.
Referenced by expected_hash(), Init(), JobInfo(), and SetExpectedHash().
|
private |
Definition at line 86 of file jobinfo.h.
Referenced by extra_info(), Init(), and SetExtraInfo().
|
private |
Definition at line 77 of file jobinfo.h.
Referenced by follow_redirects(), Init(), and SetFollowRedirects().
|
private |
Definition at line 78 of file jobinfo.h.
Referenced by force_nocache(), Init(), and SetForceNocache().
|
private |
|
private |
Definition at line 100 of file jobinfo.h.
Referenced by GetHashContextPtr(), hash_context(), and SetHashContext().
|
private |
Definition at line 76 of file jobinfo.h.
Referenced by head_request(), Init(), JobInfo(), and SetHeadRequest().
|
private |
Definition at line 94 of file jobinfo.h.
Referenced by GetHeadersPtr(), headers(), Init(), and SetHeaders().
|
private |
Definition at line 104 of file jobinfo.h.
Referenced by http_code(), Init(), IsFileNotFound(), and SetHttpCode().
|
private |
|
private |
Definition at line 95 of file jobinfo.h.
Referenced by info_header(), Init(), and SetInfoHeader().
|
private |
Definition at line 83 of file jobinfo.h.
Referenced by GetInterruptCuePtr(), Init(), interrupt_cue(), and SetInterruptCue().
|
staticprivate |
|
private |
Definition at line 102 of file jobinfo.h.
Referenced by Init(), nocache(), and SetNocache().
|
private |
Definition at line 107 of file jobinfo.h.
Referenced by Init(), num_retries(), and SetNumRetries().
|
private |
Definition at line 106 of file jobinfo.h.
Referenced by Init(), num_used_hosts(), and SetNumUsedHosts().
|
private |
Definition at line 105 of file jobinfo.h.
Referenced by Init(), num_used_proxies(), and SetNumUsedProxies().
|
private |
|
private |
Pipe used for the return value.
Definition at line 69 of file jobinfo.h.
Referenced by CreatePipeJobResults(), GetPipeJobResultPtr(), Init(), IsValidPipeJobResults(), and ~JobInfo().
|
private |
Definition at line 75 of file jobinfo.h.
Referenced by Init(), JobInfo(), probe_hosts(), and SetProbeHosts().
|
private |
Definition at line 101 of file jobinfo.h.
Referenced by proxy(), and SetProxy().
|
private |
Definition at line 89 of file jobinfo.h.
Referenced by Init(), range_offset(), and SetRangeOffset().
|
private |
Definition at line 90 of file jobinfo.h.
Referenced by Init(), range_size(), and SetRangeSize().
|
private |
|
private |
Definition at line 97 of file jobinfo.h.
Referenced by Init(), SetTracingHeaderGid(), and tracing_header_gid().
|
private |
Definition at line 96 of file jobinfo.h.
Referenced by Init(), SetTracingHeaderPid(), and tracing_header_pid().
|
private |
Definition at line 98 of file jobinfo.h.
Referenced by Init(), SetTracingHeaderUid(), and tracing_header_uid().
|
private |
|
private |
|
private |
Definition at line 99 of file jobinfo.h.
Referenced by GetZstreamPtr(), Init(), SetZstream(), and zstream().