![]() |
CernVM-FS
2.11.0
|
#include <pipeline.h>
Public Member Functions | |
ScrubbingPipeline () | |
~ScrubbingPipeline () | |
void | Spawn () |
void | Process (IngestionSource *source, shash::Algorithms hash_algorithm, shash::Suffix hash_suffix) |
void | WaitFor () |
void | OnFileProcessed (const ScrubbingResult &scrubbing_result) |
![]() | |
virtual | ~Observable () |
CallbackPtr | RegisterListener (typename BoundClosure< ScrubbingResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data) |
CallbackPtr | RegisterListener (typename BoundCallback< ScrubbingResult, DelegateT >::CallbackMethod method, DelegateT *delegate) |
CallbackPtr | RegisterListener (typename Callback< ScrubbingResult >::CallbackFunction fn) |
void | UnregisterListener (CallbackPtr callback_object) |
void | UnregisterListeners () |
Static Private Attributes | |
static const uint64_t | kMemLowWatermark = 384 * 1024 * 1024 |
static const uint64_t | kMemHighWatermark = 512 * 1024 * 1024 |
static const unsigned | kMaxFilesInFlight = 8000 |
static const unsigned | kNforkScrubbingCallback = 1 |
static const unsigned | kNforkHash = 2 |
static const unsigned | kNforkChunk = 1 |
static const unsigned | kNforkRead = 8 |
Additional Inherited Members | |
![]() | |
typedef Callbackable < ScrubbingResult > ::CallbackTN * | CallbackPtr |
![]() | |
typedef CallbackBase < ScrubbingResult > | CallbackTN |
![]() | |
static CallbackTN * | MakeClosure (typename BoundClosure< ScrubbingResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data) |
static CallbackTN * | MakeCallback (typename BoundCallback< ScrubbingResult, DelegateT >::CallbackMethod method, DelegateT *delegate) |
static CallbackTN * | MakeCallback (typename Callback< ScrubbingResult >::CallbackFunction function) |
![]() | |
typedef std::set< CallbackPtr > | Callbacks |
![]() | |
void | RegisterListener (CallbackPtr callback_object) |
Observable () | |
void | NotifyListeners (const ScrubbingResult ¶meter) |
Definition at line 111 of file pipeline.h.
ScrubbingPipeline::ScrubbingPipeline | ( | ) |
ScrubbingPipeline::~ScrubbingPipeline | ( | ) |
void ScrubbingPipeline::OnFileProcessed | ( | const ScrubbingResult & | scrubbing_result | ) |
Definition at line 240 of file pipeline.cc.
Referenced by ScrubbingPipeline().
void ScrubbingPipeline::Process | ( | IngestionSource * | source, |
shash::Algorithms | hash_algorithm, | ||
shash::Suffix | hash_suffix | ||
) |
Definition at line 247 of file pipeline.cc.
Referenced by swissknife::CommandScrub::FileCallback().
void ScrubbingPipeline::Spawn | ( | ) |
Definition at line 265 of file pipeline.cc.
Referenced by swissknife::CommandScrub::Main().
void ScrubbingPipeline::WaitFor | ( | ) |
Definition at line 274 of file pipeline.cc.
Referenced by swissknife::CommandScrub::Main().
|
private |
Definition at line 149 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
staticprivate |
Definition at line 127 of file pipeline.h.
|
staticprivate |
Definition at line 126 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
staticprivate |
Definition at line 125 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
staticprivate |
Definition at line 130 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
staticprivate |
Definition at line 129 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
staticprivate |
Definition at line 131 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
staticprivate |
Definition at line 128 of file pipeline.h.
Referenced by ScrubbingPipeline().
|
private |
Definition at line 133 of file pipeline.h.
Referenced by Spawn(), and ~ScrubbingPipeline().
|
private |
Definition at line 141 of file pipeline.h.
Referenced by ScrubbingPipeline(), Spawn(), and ~ScrubbingPipeline().
|
private |
Definition at line 144 of file pipeline.h.
Referenced by ScrubbingPipeline(), Spawn(), and ~ScrubbingPipeline().
|
private |
Definition at line 138 of file pipeline.h.
Referenced by ScrubbingPipeline(), Spawn(), and ~ScrubbingPipeline().
|
private |
Definition at line 147 of file pipeline.h.
Referenced by ScrubbingPipeline(), Spawn(), and ~ScrubbingPipeline().
Definition at line 136 of file pipeline.h.
Referenced by Process(), ScrubbingPipeline(), and WaitFor().
Definition at line 134 of file pipeline.h.
Referenced by Process(), and ScrubbingPipeline().
Definition at line 140 of file pipeline.h.
Referenced by ScrubbingPipeline().
Definition at line 143 of file pipeline.h.
Referenced by ScrubbingPipeline().
Definition at line 146 of file pipeline.h.
Referenced by ScrubbingPipeline().