follow mode for Beegfs

Collaboration diagram for follow mode for Beegfs:

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

Detailed Description

The BeeGfsRequestProvider uses the BeeGFS FileEventReceiver to get file events from a BeeGFS mete data server.

Function Documentation

processSources()

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

overridevirtual

Implements requestProvider.

Definition at line 14 of file followBeeGfsRequestProvider.cpp.

                                                                                    {
    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 {
            }
        }
    }
}

References followBeeGfsRequestProvider::beegfsroot, requestProvider::getDstPath(), followRequestProvider::handleMove(), and followRequestProvider::handleOther().

Here is the call graph for this function: