#include <daosFsCommon.h>

Inheritance diagram for daosFsCommon:

Collaboration diagram for daosFsCommon:

Classes
class	attrDataType

class	daosOptions

Public Member Functions
dfs_obj_t *	getDirObj (const std::string &path)

	daosFsCommon (daosOptions &aOpt, bool isWriter)

	~daosFsCommon () override

bool	pathExists (const std::string &path) override

std::unique_ptr< const genericStat >	getStat (const std::string &path, bool followLink) override

std::string	getXattr (const std::string &path, const std::string &name) override

Public Member Functions inherited from pathHandler
virtual	~pathHandler ()=default

Public Attributes
daos_handle_t	poh

daos_handle_t	coh

dfs_t *	dfs

int	flags

std::map< std::string, dfs_obj_t * >	pathMap

Protected Attributes
daosOptions &	opt

Detailed Description

Definition at line 11 of file daosFsCommon.h.

Constructor & Destructor Documentation

◆ daosFsCommon()

daosFsCommon::daosFsCommon	(	daosOptions &	aOpt,
		bool	isWriter
	)

Definition at line 34 of file daosFsCommon.cpp.

                                                           : flags(isWriter ? O_RDWR : O_RDONLY), opt(aOpt) {
     throwcall::good0(daos_pool_connect(opt.poolName.c_str(), opt.sysName.empty() ? nullptr : opt.sysName.c_str(), 0,
                                        &poh, nullptr, nullptr),
                      "can't connect to pool ", opt.poolName, " on sys ", opt.sysName);
     throwcall::good0(daos_cont_open(poh, opt.containerName.c_str(), 0,
                                     &coh, nullptr, nullptr),
                      "can't open container ", opt.containerName, " in pool ", opt.poolName, " on sys ", opt.sysName);
     throwcall::good0(dfs_mount(poh, coh, flags, &dfs),
                      "can't mount daos fs in containr ", opt.containerName, " in pool ", opt.poolName, " on sys ", opt.sysName);
 }

References coh, daosFsCommon::daosOptions::containerName, dfs, flags, throwcall::good0(), opt, poh, daosFsCommon::daosOptions::poolName, and daosFsCommon::daosOptions::sysName.

Here is the call graph for this function:

◆ ~daosFsCommon()

daosFsCommon::~daosFsCommon ( )

override

Definition at line 44 of file daosFsCommon.cpp.

                             {
     for (auto& item: pathMap) {
         throwcall::good0(dfs_release(item.second),
                          "can't release dir object for ", item.first);
     }
     throwcall::good0(dfs_umount(dfs),
                      "can't umount daos fs in containr ", opt.containerName, " in pool ", opt.poolName, " on sys ", opt.sysName);
     throwcall::good0(daos_cont_close(coh, nullptr),
                      "can't close container ", opt.containerName, " in pool ", opt.poolName, " on sys ", opt.sysName);
     throwcall::good0(daos_pool_disconnect(poh, nullptr),
                      "can't disconnect pool ", opt.poolName, " on sys ", opt.sysName);
 }

References coh, daosFsCommon::daosOptions::containerName, dfs, throwcall::good0(), opt, pathMap, poh, daosFsCommon::daosOptions::poolName, and daosFsCommon::daosOptions::sysName.

Here is the call graph for this function:

Member Function Documentation

◆ getDirObj()

dfs_obj_t * daosFsCommon::getDirObj ( const std::string & path )

Definition at line 21 of file daosFsCommon.cpp.

                                                         {
     auto stripped = path.substr(0,path.find_last_of('/'));
     auto it = pathMap.find(path);
     if (it == pathMap.end()) {
         dfs_obj_t* obj;
         timerInst(dfs_lookup);
         throwcall::good0(dfs_lookup(dfs, path.c_str(), flags, &obj, nullptr, nullptr),"can't lookup path", path); 
         auto result = pathMap.emplace(path, obj);
         it = result.first;
     }
     return it->second;
 }

References dfs, flags, throwcall::good0(), pathMap, and timerInst.

Referenced by inputHandler::daosFs::DaosFsDirectory::DaosFsDirectory(), getStat(), pathExists(), and inputHandler::daosFs::readerDaosFs::readerDaosFs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getStat()

std::unique_ptr< const genericStat > daosFsCommon::getStat	(	const std::string &	path,
		bool	followLink
	)

overridevirtual

Implements pathHandler.

Definition at line 68 of file daosFsCommon.cpp.

                          {
     struct stat statBuf;
     timerInst(stat);
     auto result = dfs_stat(dfs, getDirObj(path), path.c_str(), &statBuf);
     if (result && errno == ENOENT) {
         return nullptr;
     }
     throwcall::good0(result, "can't stat", path);
     if (followLink && S_ISLNK(statBuf.st_mode)) {
         char buf[4096];
         daos_size_t size = sizeof(buf);
         dfs_obj_t* obj;
         throwcall::good0(dfs_open(dfs, getDirObj(path), path.c_str(), 0x666, O_RDONLY, 0, 0, nullptr, &obj),
                          "can't open link", path);
         throwcall::good0(dfs_get_symlink_value(obj, buf, &size),
                          "can't get symlink of link ", path);
         throwcall::good0(dfs_release(obj), "can't  relaese ",path);
         return getStat(buf, true);
     }
     return std::unique_ptr<const genericStat>(new genericStat(statBuf, std::chrono::nanoseconds(1)));
 };

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

Here is the call graph for this function:

◆ getXattr()

std::string daosFsCommon::getXattr	(	const std::string &	path,
		const std::string &	name
	)

overridevirtual

Reimplemented from pathHandler.

Definition at line 92 of file daosFsCommon.cpp.

                                                              {
     char buffer[512];
  
     dfs_obj_t* obj;
     throwcall::good0(dfs_lookup(dfs, path.c_str(), flags,
                                 &obj, nullptr, nullptr),
                      "can't lookup ", path);
     timerInst(getxattr);
     daos_size_t size = sizeof(buffer);
     auto retval = dfs_getxattr(dfs, obj, name.c_str(), buffer, &size);
     throwcall::good0(dfs_release(obj),"can't release ", path);
     if (retval == -1) {
         if (errno == ENOENT || errno == ENOATTR) {
             return "";
         }
         throwcall::badval(retval, -1, "can't get xattr on ", path);
     }
     buffer[size] = '\0';
     return buffer;
 };

References throwcall::badval(), dfs, ENOATTR, flags, throwcall::good0(), and timerInst.

Here is the call graph for this function:

◆ pathExists()

bool daosFsCommon::pathExists ( const std::string & path )

overridevirtual

Implements pathHandler.

Definition at line 58 of file daosFsCommon.cpp.

                                                    {
     struct stat statBuf;
     timerInst(stat);
     auto result = dfs_stat(dfs, getDirObj(path), path.c_str(), &statBuf);
     if (result && (errno == ENOENT || errno == ENOTDIR)) {
         return false;
     }
     throwcall::good0(result, "can't stat ", path);
     return true;
 };