noFollowRequestProvider.cpp

Go to the documentation of this file.

#include "noFollowRequestProvider.h"
#include "scoped.h"
#include "throwcall.h"
#include "escapism.h"
#include "timer.h"
 
defineStaticNoArg(noFollowRequestProvider::requestSet);
defineStatic(noFollowRequestProvider::sourceDecodeMethod, *escapism::newEscaperOption("sourceDecodeMethod",
             "method to decode source file names", "None"));
defineStatic(noFollowRequestProvider::ignoreMissing, '\0', "ignore-missing",
             "ignore missing files in source file list");
 
 
 
copyRequest::base* noFollowRequestProvider::newRequest(inputHandler::base* aInputHandler,
        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) {
    return new copyRequest::base(aInputHandler, aSource, aDestination, aStat, aMapEntry, remove, timestamp);
}
void noFollowRequestProvider::processSources(const std::vector<std::string>& sources) {
 
    for (auto& source : sources) {
        static auto escaper = escapism::newEscaper(sourceDecodeMethod);
        if (escaper) {
            std::string srcbuf;
            escaper->deEscape(source, srcbuf);
            processSource(srcbuf);
        } else {
            processSource(source);
        }
    }
    timerInst(requestEnqueue);
    for (auto request : requestSet) {
        std::unique_ptr<copyRequest::base> item(request);
        requests.enqueue(item);
    }
    requestSet.clear();
}