followBeeGfsRequestProvider.cpp

Go to the documentation of this file.

#include "followBeeGfsRequestProvider.h"
#include <beegfs/beegfs_file_event_log.hpp>
 
defineStatic(followBeeGfsRequestProvider::factory, "BeeGFS");
defineStatic(followBeeGfsRequestProvider::beegfsroot, '\0', "beegfsroot", "root dir (mount point) of beegfs");
 
void followBeeGfsRequestProvider::processSources(const std::vector<std::string>& sources) {
    for (auto& source : sources) {
        BeeGFS::FileEventReceiver receiver(source);
        while (true) {
            const auto data = receiver.read();
            if (data.first == BeeGFS::FileEventReceiver::ReadErrorCode::Success) {
                auto& event = data.second;
                if (event.type == BeeGFS::FileEventType::CLOSE_WRITE) {
                    std::string path(beegfsroot);
                    path += "/";
                    path += event.path;
                    std::string dstPath;
                    auto mapEntry = getDstPath(path, dstPath);
                    handleOther(path, dstPath, mapEntry, copyRequest::clock_type::now(), false);
                } else if (event.type == BeeGFS::FileEventType::RENAME) {
                    std::string path(beegfsroot);
                    path += "/";
                    path += event.path;
                    std::string fromPath;
                    auto mapEntryF = getDstPath(path, fromPath);
                    std::string target(beegfsroot);
                    target += "/";
                    target += event.targetPath;
                    std::string dstPath;
                    auto mapEntryD = getDstPath(target, dstPath);
                    handleMove(target, dstPath, fromPath, path, mapEntryD, copyRequest::clock_type::now());
                } else if (event.type == BeeGFS::FileEventType::UNLINK ||
                           event.type == BeeGFS::FileEventType::RMDIR) {
                    std::string path(beegfsroot);
                    path += "/";
                    path += event.path;
                    std::string dstPath;
                    auto mapEntry = getDstPath(path, dstPath);
                    handleOther(path, dstPath, mapEntry,  copyRequest::clock_type::now(), true);
                } else if (event.type == BeeGFS::FileEventType::SYMLINK) {
                    std::string path(beegfsroot);
                    path += "/";
                    path += event.targetPath;
                    std::string dstPath;
                    auto mapEntry = getDstPath(path, dstPath);
                    handleOther(path, dstPath, mapEntry, copyRequest::clock_type::now(), false);
                }
            } else {
            }
        }
    }
}