followInotifyWatchRequestProvider.cpp

Go to the documentation of this file.

#include "followInotifyWatchRequestProvider.h"
#include "errMsgQueue.h"
#include <string.h>
 
 
defineStatic(followInotifyWatchRequestProvider::factory, "InotifyWatch");
 
 
void followInotifyWatchRequestProvider::followStream(std::istream& stream) {
    char delimiter = nullDelimiter ? '\0' : '\n';
    std::string line;
 
    while (stream) {
        if (stopRequest::Requested()) {
            errMsg::emit(errMsg::level::info, errMsg::location(),
                         "request provider", "stop request received"
                         , "ignoring further requests");
            break;
        }
        char cmdbuff[4] = {0, 0, 0, 0};
        stream.read(cmdbuff, 3);
        auto readTime = copyRequest::clock_type::now();
        if (stream.eof()) {
            break;
        }
 
        double timestampAsDouble;
        stream >> timestampAsDouble;
        auto timestamp = copyRequest::clock_type::time_point(std::chrono::duration_cast<copyRequest::clock_type::duration>(std::chrono::duration<double>(timestampAsDouble)));
        stream.ignore(); // skip one character after timestamp
        std::getline(stream, line, delimiter);
 
        if (strcmp(cmdbuff, "ig ") == 0) { // ignore this line, to be used as keepalive
            continue;
        }
 
        if (strcmp(cmdbuff, "mv ") == 0) { // special case move...
            std::string target;
            std::getline(stream, target, delimiter);
            std::string fromPath;
            auto mapEntryD = getDstPath(line, fromPath);
            std::string dstPath;
            auto mapEntryS = getDstPath(target, dstPath);
            handleMove(target, dstPath, fromPath, line, mapEntryD, timestamp);
        } else {
            auto requestForRemoval = strcmp(cmdbuff, "rm ") == 0;
            std::string dstPath;
            auto mapEntry = getDstPath(line, dstPath);
 
            handleOther(line, dstPath, mapEntry, timestamp, requestForRemoval);
        }
        auto enqueueDoneTime = copyRequest::clock_type::now();
        copyRequest::base::tEnqueueStat.addValue(enqueueDoneTime - readTime);
 
    }
}