moveRequestProvider Class Reference

#include <moveRequestProvider.h>

Inheritance diagram for moveRequestProvider:

Collaboration diagram for moveRequestProvider:

Public Member Functions
	moveRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)
	~moveRequestProvider () override=default
void	processSources (const std::vector< std::string > &sources) override
Public Member Functions inherited from cmdLineRequestProvider
	cmdLineRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)
	~cmdLineRequestProvider () override=default
bool	isFollowMode () const override
void	prepareMappings (std::vector< std::string > &sources, std::string &destination) override
void	printMappings (std::ostream &stream) override
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

Private Member Functions
void	processSource (const std::string &source) override
void	addDirContent (const std::string &srcpath, const std::string &dstpath, const singleMap &mapEntry, const genericStat &dirStat) override

Private Attributes
std::list< copyRequest::base * >	requestList

Static Private Attributes
static factoryTemplate< moveRequestProvider >	factory

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 cmdLineRequestProvider
const singleMap &	getDstPath (const std::string &source, std::string &destination, bool baseNameOnly=false) override
	get detstination papth for a given source path More...
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)
Static Protected Member Functions inherited from requestProvider
static std::map< std::string, factoryClass * > &	getFactoryMap ()
Protected Attributes inherited from cmdLineRequestProvider
bool	processCmdLineDirs
Protected Attributes inherited from requestProvider
copyRequest::simpleQueue &	requests
copyRequest::timedQueue &	delayedRequests
bool	parents
inputHandler::base *	InputHandler
outputHandler::base *	OutputHandler
Static Protected Attributes inherited from cmdLineRequestProvider
static options::single< bool >	recursive
static options::single< bool >	dereferenceCmdLine
static std::string	singleDestination
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 5 of file moveRequestProvider.h.

Constructor & Destructor Documentation

moveRequestProvider()

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

inline

Definition at line 17 of file moveRequestProvider.h.

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

~moveRequestProvider()

moveRequestProvider::~moveRequestProvider ( )

overridedefault

Member Function Documentation

addDirContent()

void moveRequestProvider::addDirContent ( const std::string &  srcpath, const std::string &  dstpath, const singleMap &  mapEntry, const genericStat &  dirStat  )

overrideprivatevirtual

Reimplemented from cmdLineRequestProvider.

Definition at line 56 of file moveRequestProvider.cpp.

                                                                    {
    // with the subdir list we have only one open dir at a time
    class subdirType {
      public:
        std::string srcPath;
        std::string dstPath;
        std::unique_ptr<const genericStat> dirStat;
        subdirType(const std::string& aSrcPath,
                   const std::string& aDstPath,
                   std::unique_ptr<const genericStat>& aDirStat) :
            srcPath(aSrcPath),
            dstPath(aDstPath),
            dirStat(std::move(aDirStat)) {};
    };
    std::list<subdirType> subdirs;
    {
        auto dir = InputHandler->getDirectory(srcpath);
        while (auto entry = dir->getNextEntry(ignoreMissing)) {
            std::string subpath(srcpath);
            subpath += "/";
            subpath += entry->getName();
            std::string destpath(dstpath);
            destpath += "/";
            destpath += entry->getName();
            auto entryStat = entry->getStat();
 
            if (entryStat->isDir() &&
                    entryStat->device == dirStat.device) {
                subdirs.emplace_back(subpath, destpath, entryStat);
            } else if (entryStat->isRegularFile() || entryStat->isLink()) {
                requestList.push_front(new copyRequest::base(InputHandler, subpath, destpath,
                                       subpath, subpath, mapEntry,
                                       copyRequest::clock_type::now()));
            }
        }
    }
 
    for (auto& subdir : subdirs) {
        addDirContent(subdir.srcPath, subdir.dstPath, mapEntry, *(subdir.dirStat));
    }
}

References genericStat::device, inputHandler::base::getDirectory(), noFollowRequestProvider::ignoreMissing, requestProvider::InputHandler, and requestList.

Referenced by processSource().

Here is the call graph for this function:

Here is the caller graph for this function:

processSource()

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

overrideprivatevirtual

Reimplemented from cmdLineRequestProvider.

Definition at line 8 of file moveRequestProvider.cpp.

                                                               {
    auto sourceStat = InputHandler->getStat(source, dereferenceCmdLine);
    if (!sourceStat) {
        if (ignoreMissing) {
            if (! quiet) {
                errMsg::emit(errMsg::level::warning, errMsg::location(),
                             source, "stat", "not found");
            }
            return;
        }
        throw std::runtime_error("can't stat " + source);
    }
    if (sourceStat->isDir()) {
        if (recursive) {
            std::string dstPath;
            auto mapEntry = getDstPath(source, dstPath, true);
            addDirContent(source, dstPath, mapEntry, *sourceStat);
        } else {
            throw std::runtime_error(source + " is a directory");
        }
    } else {
        std::string dst;
        auto mapEntry = getDstPath(source, dst, true);
        requestList.push_front(new copyRequest::base(InputHandler, source, dst,
                               source, source, mapEntry,
                               copyRequest::clock_type::now()));
    }
}

References addDirContent(), cmdLineRequestProvider::dereferenceCmdLine, errMsg::emit(), cmdLineRequestProvider::getDstPath(), pathHandler::getStat(), noFollowRequestProvider::ignoreMissing, requestProvider::InputHandler, quiet, cmdLineRequestProvider::recursive, requestList, and errMsg::warning.

Referenced by processSources().

Here is the call graph for this function:

Here is the caller graph for this function:

processSources()

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

overridevirtual

Implements requestProvider.

Definition at line 37 of file moveRequestProvider.cpp.

                                                                            {
 
    for (auto& source : sources) {
        static auto escaper = escapism::newEscaper(sourceDecodeMethod);
        if (escaper) {
            std::string srcbuf;
            escaper->deEscape(source, srcbuf);
            processSource(srcbuf);
        } else {
            processSource(source);
        }
    }
    for (auto request : requestList) {
        std::unique_ptr<copyRequest::base> item(request);
        requests.enqueue(item);
    }
    requestList.clear();
}

References waitQueues::simple< T >::enqueue(), escapism::newEscaper(), processSource(), requestList, requestProvider::requests, and noFollowRequestProvider::sourceDecodeMethod.

Here is the call graph for this function:

Member Data Documentation

factory

factoryTemplate<moveRequestProvider> moveRequestProvider::factory

staticprivate

Definition at line 7 of file moveRequestProvider.h.

requestList

std::list<copyRequest::base*> moveRequestProvider::requestList

private

Definition at line 9 of file moveRequestProvider.h.

Referenced by addDirContent(), processSource(), and processSources().

---

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

• src/moveRequestProvider.h (v0.19-24-g0617ca1 with changes)
• src/moveRequestProvider.cpp (v0.19-24-g0617ca1 with changes)