swissknife_pull.cc File Reference

#include "cvmfs_config.h"
#include "swissknife_pull.h"
#include <inttypes.h>
#include <pthread.h>
#include <sys/stat.h>
#include <unistd.h>
#include <cstdlib>
#include <cstring>
#include <string>
#include <vector>
#include "catalog.h"
#include "compression/compression.h"
#include "crypto/hash.h"
#include "crypto/signature.h"
#include "history_sqlite.h"
#include "manifest.h"
#include "manifest_fetch.h"
#include "network/download.h"
#include "object_fetcher.h"
#include "path_filters/relaxed_path_filter.h"
#include "reflog.h"
#include "upload.h"
#include "util/atomic.h"
#include "util/concurrency.h"
#include "util/exception.h"
#include "util/logging.h"
#include "util/posix.h"
#include "util/shared_ptr.h"
#include "util/smalloc.h"
#include "util/string.h"

Include dependency graph for swissknife_pull.cc:

Go to the source code of this file.

Classes
class	swissknife::anonymous_namespace{swissknife_pull.cc}::ChunkJob
struct	swissknife::MainWorkerContext

Namespaces
	swissknife
	swissknife::anonymous_namespace{swissknife_pull.cc}

Macros
#define	_FILE_OFFSET_BITS   64
#define	__STDC_FORMAT_MACROS

Typedefs
typedef HttpObjectFetcher	swissknife::anonymous_namespace{swissknife_pull.cc}::ObjectFetcher

Functions
static void	swissknife::anonymous_namespace{swissknife_pull.cc}::SpoolerOnUpload (const upload::SpoolerResult &result)
static std::string	swissknife::MakePath (const shash::Any &hash)
static bool	swissknife::Peek (const string &remote_path)
static bool	swissknife::Peek (const shash::Any &remote_hash)
static void	swissknife::ReportDownloadError (const download::JobInfo &download_job)
static void	swissknife::Store (const string &local_path, const string &remote_path, const bool compressed_src)
static void	swissknife::Store (const string &local_path, const shash::Any &remote_hash, const bool compressed_src=true)
static void	swissknife::StoreBuffer (const unsigned char *buffer, const unsigned size, const std::string &dest_path, const bool compress)
static void	swissknife::StoreBuffer (const unsigned char *buffer, const unsigned size, const shash::Any &dest_hash, const bool compress)
static void	swissknife::WaitForStorage ()
static void *	swissknife::MainWorker (void *data)

Variables
SharedPtr< string >	swissknife::anonymous_namespace{swissknife_pull.cc}::stratum0_url
SharedPtr< string >	swissknife::anonymous_namespace{swissknife_pull.cc}::stratum1_url
SharedPtr< string >	swissknife::anonymous_namespace{swissknife_pull.cc}::temp_dir
unsigned	swissknife::anonymous_namespace{swissknife_pull.cc}::num_parallel = 1
bool	swissknife::anonymous_namespace{swissknife_pull.cc}::pull_history = false
bool	swissknife::anonymous_namespace{swissknife_pull.cc}::apply_timestamp_threshold = false
uint64_t	swissknife::anonymous_namespace{swissknife_pull.cc}::timestamp_threshold = 0
bool	swissknife::anonymous_namespace{swissknife_pull.cc}::is_garbage_collectable = false
bool	swissknife::anonymous_namespace{swissknife_pull.cc}::initial_snapshot = false
upload::Spooler *	swissknife::anonymous_namespace{swissknife_pull.cc}::spooler = NULL
int	swissknife::anonymous_namespace{swissknife_pull.cc}::pipe_chunks [2]
pthread_mutex_t	swissknife::anonymous_namespace{swissknife_pull.cc}::lock_pipe = PTHREAD_MUTEX_INITIALIZER
unsigned	swissknife::anonymous_namespace{swissknife_pull.cc}::retries = 3
catalog::RelaxedPathFilter *	swissknife::anonymous_namespace{swissknife_pull.cc}::pathfilter = NULL
atomic_int64	swissknife::anonymous_namespace{swissknife_pull.cc}::overall_chunks
atomic_int64	swissknife::anonymous_namespace{swissknife_pull.cc}::overall_new
atomic_int64	swissknife::anonymous_namespace{swissknife_pull.cc}::chunk_queue
bool	swissknife::anonymous_namespace{swissknife_pull.cc}::preload_cache = false
string *	swissknife::anonymous_namespace{swissknife_pull.cc}::preload_cachedir = NULL
bool	swissknife::anonymous_namespace{swissknife_pull.cc}::inspect_existing_catalogs = false
manifest::Reflog *	swissknife::anonymous_namespace{swissknife_pull.cc}::reflog = NULL

Macro Definition Documentation

#define __STDC_FORMAT_MACROS

Definition at line 11 of file swissknife_pull.cc.

#define _FILE_OFFSET_BITS   64

This file is part of the CernVM File System.

Replicates a cvmfs repository. Uses the cvmfs intrinsic Merkle trees to calculate the difference set.

Definition at line 9 of file swissknife_pull.cc.