inputHandler::daosFs::DaosFsDirectory Class Reference

#include <inputHandlerDaosFs.h>

Inheritance diagram for inputHandler::daosFs::DaosFsDirectory:

Collaboration diagram for inputHandler::daosFs::DaosFsDirectory:

Public Member Functions
	DaosFsDirectory (daosFs &aHandler, const std::string &path)
	~DaosFsDirectory () noexcept(false) override
std::unique_ptr< Entry >	getNextEntry (bool ignoreMissing) override

Private Attributes
daosFs &	handler
dfs_obj_t *	dir
daos_anchor_t	anchor

Detailed Description

Definition at line 40 of file inputHandlerDaosFs.h.

Constructor & Destructor Documentation

DaosFsDirectory()

inputHandler::daosFs::DaosFsDirectory::DaosFsDirectory	(	daosFs &	aHandler,
		const std::string &	path
	)

Definition at line 192 of file inputHandlerDaosFs.cpp.

                                                                                  : Directory(aPath), handler(aHandler) {
        timerInst(opendir);
        throwcall::good0(dfs_open(handler.dfs, handler.getDirObj(path), path.c_str(), 0666, O_RDONLY, 0, 0, nullptr, &dir),
                         "can't open direcory ", path);
    }

References daosFsCommon::dfs, dir, daosFsCommon::getDirObj(), throwcall::good0(), handler, and timerInst.

Here is the call graph for this function:

~DaosFsDirectory()

inputHandler::daosFs::DaosFsDirectory::~DaosFsDirectory ( )

overridenoexcept

Definition at line 197 of file inputHandlerDaosFs.cpp.

                                                            {
        if (isUnwinding()) {
            if (dfs_release(dir) != 0) {
                errMsg::emit(errMsg::level::debug, errMsg::location(),
                             "", "close directory during unwind ",
                             std::system_category().default_error_condition(errno).message());
            }
        } else {
            timerInst(closedir);
            throwcall::good0(dfs_release(dir), "can't close directory ", path);
        }
    }

References errMsg::debug, errMsg::emit(), throwcall::good0(), and timerInst.

Here is the call graph for this function:

Member Function Documentation

getNextEntry()

std::unique_ptr< base::Directory::Entry > inputHandler::daosFs::DaosFsDirectory::getNextEntry ( bool  ignoreMissing )

override

Definition at line 209 of file inputHandlerDaosFs.cpp.

                                                                                            {
        while (true) {
            struct dirent entry;
            uint32_t n=1;
            throwcall::good0(dfs_readdir(handler.dfs, dir, &anchor, &n, &entry),"can't read dir enry");
            if (n==1) {
                if (entry.d_name[entry.d_name[0] != '.' ? 0 : entry.d_name[1] != '.' ? 1 : 2] == '\0') {
                    continue; // skip . .. and empty strings
                }
                struct stat statbuf;
                {
                    timerInst(fstatat);
                    auto result = dfs_stat(handler.dfs, dir, entry.d_name, &statbuf);
                    if (result != 0 && errno == ENOENT && ignoreMissing) {
                        continue;
                    }
                    throwcall::good0(result, "can't stat ", entry.d_name);
                }
                auto genStat = std::unique_ptr<const genericStat>(new genericStat(statbuf, std::chrono::nanoseconds(1)));
                return std::unique_ptr<Entry>(new Entry(entry.d_name, genStat));
            } else {
                break;
            }
        }
        return nullptr;
    }

References throwcall::good0(), and timerInst.

Here is the call graph for this function:

Member Data Documentation

anchor

daos_anchor_t inputHandler::daosFs::DaosFsDirectory::anchor

private

Definition at line 43 of file inputHandlerDaosFs.h.

dir

dfs_obj_t* inputHandler::daosFs::DaosFsDirectory::dir

private

Definition at line 42 of file inputHandlerDaosFs.h.

Referenced by DaosFsDirectory().

handler

daosFs& inputHandler::daosFs::DaosFsDirectory::handler

private

Definition at line 41 of file inputHandlerDaosFs.h.

Referenced by DaosFsDirectory().

---

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

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