#include <policyRunRequestProvider.h>

Inheritance diagram for policyRunRequestProvider:

Collaboration diagram for policyRunRequestProvider:

Public Member Functions
	policyRunRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)

	~policyRunRequestProvider () override=default

Public Member Functions inherited from noFollowRequestProvider
	noFollowRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)

	~noFollowRequestProvider () override=default

bool	isFollowMode () const override

void	processSources (const std::vector< std::string > &sources) override

Public Member Functions inherited from requestProvider
	requestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)
	! use only the file name part in the destination More...

virtual	~requestProvider ()=default

virtual void	prepareMappings (std::vector< std::string > &sources, std::string &destination)

virtual void	printMappings (std::ostream &stream)

Private Member Functions
void	processSource (const std::string &source) override

Static Private Attributes
static factoryTemplate< policyRunRequestProvider >	factory

static options::single< std::string > &	escaperOption

Additional Inherited Members
Static Public Member Functions inherited from requestProvider
static requestProvider *	newProvider (const std::string &choice, decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)

static void	addAllowedNamesToOption (options::single< std::string > &option)

Protected Member Functions inherited from noFollowRequestProvider
virtual copyRequest::base *	newRequest (inputHandler::base *InputHandler, const std::string &aSource, const std::string &aDestination, std::unique_ptr< const genericStat > &aStat, const singleMap &aMapEntry, bool remove, copyRequest::clock_type::time_point timestamp)

Protected Member Functions inherited from requestProvider
virtual const singleMap &	getDstPath (const std::string &source, std::string &destination, bool baseNameOnly=false)
	get detstination papth for a given source path More...

Static Protected Member Functions inherited from requestProvider
static std::map< std::string, factoryClass * > &	getFactoryMap ()

Protected Attributes inherited from requestProvider
copyRequest::simpleQueue &	requests

copyRequest::timedQueue &	delayedRequests

bool	parents

inputHandler::base *	InputHandler

outputHandler::base *	OutputHandler

Static Protected Attributes inherited from noFollowRequestProvider
static options::single< std::string > &	sourceDecodeMethod

static options::single< bool >	ignoreMissing

static std::multiset< copyRequest::base *, copyRequest::base::pointerCompare >	requestSet

Static Protected Attributes inherited from requestProvider
static options::map< std::string, pathMapType >	pathMap

static singleMap	badMapEntry

Detailed Description

Definition at line 8 of file policyRunRequestProvider.h.

Constructor & Destructor Documentation

◆ policyRunRequestProvider()

policyRunRequestProvider::policyRunRequestProvider	(	decltype(requests)	aRequests,
		decltype(delayedRequests)	aDelayedRequests,
		decltype(parents)	aParents,
		decltype(InputHandler)	aInputHandler,
		decltype(OutputHandler)	aOutputHandler
	)

inline

Definition at line 16 of file policyRunRequestProvider.h.

                                                                     :
         noFollowRequestProvider(aRequests, aDelayedRequests, aParents,
                                 aInputHandler, aOutputHandler) {
     };

◆ ~policyRunRequestProvider()

policyRunRequestProvider::~policyRunRequestProvider ( )

overridedefault

Member Function Documentation

◆ processSource()

void policyRunRequestProvider::processSource ( const std::string & source )

overrideprivatevirtual

Implements noFollowRequestProvider.

Definition at line 16 of file policyRunRequestProvider.cpp.

                                                                     {
     static auto escaper = escapism::newEscaper(escaperOption);
     std::ifstream srcList(source);
     std::string line;
     while (std::getline(srcList, line)) {
         auto separatorStart = line.find(" -- ");
         if (separatorStart == std::string::npos) {
             continue;
         }
         auto pathStart = separatorStart + 4; // length of " -- "
         std::string src;
         escaper->deEscape(line.substr(pathStart), src);
         auto sourceStat = InputHandler->getStat(src, false); // never follow links
         if (!sourceStat) {
             if (ignoreMissing) {
                 if (! quiet) {
                     errMsg::emit(errMsg::level::warning, errMsg::location(),
                                  src, "stat", "not found");
                 }
                 continue;
             }
             throw std::runtime_error("can't stat " + src);
         }
         if (sourceStat->isDir()) { // directories are created on the fly, ignore here
             continue;
         }
         std::string dst;
         auto mapEntry =  getDstPath(src, dst);
         timerInst(emplace);
         requestSet.emplace(new copyRequest::base(InputHandler, src, dst, sourceStat,
                            mapEntry,
                            false, copyRequest::clock_type::now()));
     }
     copyRequest::base::setStatPrinter(quietStatPrinter);
 }

References errMsg::emit(), escaperOption, requestProvider::getDstPath(), pathHandler::getStat(), noFollowRequestProvider::ignoreMissing, requestProvider::InputHandler, escapism::newEscaper(), quiet, quietStatPrinter(), noFollowRequestProvider::requestSet, copyRequest::base::setStatPrinter(), timerInst, and errMsg::warning.

Here is the call graph for this function:

Member Data Documentation

◆ escaperOption

options::single<std::string>& policyRunRequestProvider::escaperOption

staticprivate

Definition at line 12 of file policyRunRequestProvider.h.

Referenced by processSource().

◆ factory

factoryTemplate<policyRunRequestProvider> policyRunRequestProvider::factory

staticprivate

Definition at line 10 of file policyRunRequestProvider.h.

The documentation for this class was generated from the following files:

Public Member Functions

Private Member Functions

Static Private Attributes

Additional Inherited Members