outputHandler::Gpfs Class Reference

#include <outputHandlerGpfs.h>

Inheritance diagram for outputHandler::Gpfs:

Collaboration diagram for outputHandler::Gpfs:

Classes
class	writerGpfs

Public Member Functions
	Gpfs ()=default
	~Gpfs () override=default
std::unique_ptr< writer >	newWriter (const std::string &path, bool mightAppend, size_t sourceSize, size_t readBlockSize, copyRequest::stateType &state, bool noWrite, std::unique_ptr< ioHandle::attrDataType >, std::unique_ptr< acl::list > aclData) override
std::unique_ptr< writer >	newTmpWriter (std::string &path, size_t, bool noWrite, std::unique_ptr< ioHandle::attrDataType > attrData, std::unique_ptr< acl::list > aclData) override
base::renameRetvalType	rename (const std::string &fromPath, const std::unique_ptr< const genericStat > &readInitialStat, const std::string &toPath, copyRequest::stateType &state) override
Public Member Functions inherited from outputHandler::posixFile
	posixFile ()=default
	~posixFile () override=default
std::unique_ptr< writer >	newWriter (const std::string &path, bool mightAppend, size_t sourceSize, size_t readBlockSize, copyRequest::stateType &state, bool noWrite, std::unique_ptr< ioHandle::attrDataType > attrData, std::unique_ptr< acl::list > aclData) override
std::unique_ptr< writer >	newTmpWriter (std::string &path, size_t sourceSize, bool noWrite, std::unique_ptr< ioHandle::attrDataType > attrData, std::unique_ptr< acl::list > aclData) override
void	ensureParentDirs (const std::string &path, const std::string &srcPath, inputHandler::base *InputHandler) override
void	remove (const std::string &path, copyRequest::stateType &state) override
bool	renameSimple (const std::string &fromPath, const std::string &toPath) override
base::renameRetvalType	rename (const std::string &fromPath, const std::unique_ptr< const genericStat > &readInitialStat, const std::string &toPath, copyRequest::stateType &state) override
void	createSymlink (const std::vector< char > &target, const std::string &path, uid_t uid, gid_t gid) override
void	doAttributePreservations (const std::string &path, const genericStat &stat) override
size_t	getMaxNameLength (const std::string &dirPath) override
Public Member Functions inherited from outputHandler::base
	~base () override=default
template<class C >
void	shortenNameToMax (const std::string &path, C &pathBuf, const std::string &suffix)
Public Member Functions inherited from pathHandler
virtual	~pathHandler ()=default
Public Member Functions inherited from posixFileCommon
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

Static Private Attributes
static factoryTemplate< Gpfs >	factory

Additional Inherited Members
Public Types inherited from outputHandler::base
enum	renameRetvalType { renameRetvalType::ok, renameRetvalType::fileChanged, renameRetvalType::fileVanished, renameRetvalType::cantHappen }
Static Public Member Functions inherited from outputHandler::base
static base *	newHandler (const std::string &name)
template<class T >
static void	addAllowedNamesToOption (T &option)
Protected Member Functions inherited from outputHandler::base
	base ()=default
Static Protected Member Functions inherited from outputHandler::base
static std::map< std::string, factoryClass * > &	getFactoryMap ()

Detailed Description

Definition at line 9 of file outputHandlerGpfs.h.

Constructor & Destructor Documentation

Gpfs()

outputHandler::Gpfs::Gpfs ( )

default

~Gpfs()

outputHandler::Gpfs::~Gpfs ( )

overridedefault

Member Function Documentation

newTmpWriter()

std::unique_ptr< base::writer > outputHandler::Gpfs::newTmpWriter ( std::string &  path, size_t  sourceSize, bool  noWrite, std::unique_ptr< ioHandle::attrDataType >  attrData, std::unique_ptr< acl::list >  aclData  )

overridevirtual

Reimplemented from outputHandler::base.

Definition at line 34 of file outputHandlerGpfs.cpp.

                                            {
        return std::unique_ptr<base::writer>(new writerGpfs(path,
                                             sourceSize,
                                             noWrite,
                                             std::move(attrData),
                                                            std::move(aclData),
                                             *this));
    }

newWriter()

std::unique_ptr< base::writer > outputHandler::Gpfs::newWriter ( const std::string &  path, bool  mightAppend, size_t  sourceSize, size_t  readBlockSize, copyRequest::stateType &  state, bool  noWrite, std::unique_ptr< ioHandle::attrDataType >  attrData, std::unique_ptr< acl::list >  aclData  )

overridevirtual

Implements outputHandler::base.

Definition at line 20 of file outputHandlerGpfs.cpp.

                                                           {
        return std::unique_ptr<base::writer>(new writerGpfs(path, mightAppend,
                                             sourceSize, readBlockSize,
                                             state, noWrite,
                                             std::move(attrData),
                                             std::move(aclData)));
    }

rename()

base::renameRetvalType outputHandler::Gpfs::rename ( const std::string &  fromPath, const std::unique_ptr< const genericStat > &  readInitialStat, const std::string &  toPath, copyRequest::stateType &  state  )

overridevirtual

Implements outputHandler::base.

Definition at line 171 of file outputHandlerGpfs.cpp.

                                                                     {
        auto retval = posixFile::rename(fromPath, readInitialStat, toPath, state);
        if (retval == base::renameRetvalType::ok && state & copyRequest::stateBitType::done) {
            auto lastSlash = fromPath.find_last_of('/');
            auto fromDir = lastSlash == std::string::npos ? "." : fromPath.substr(0, lastSlash);
            lastSlash =  toPath.find_last_of('/');
            auto toDir = lastSlash == std::string::npos ? "." : toPath.substr(0, lastSlash);
            if (fromDir != toDir) { // we move from one dir to another with possibly different acls
                char aclBufferSpace[0x10000];
                auto aclBuffer = reinterpret_cast<gpfs_opaque_acl_t*>(aclBufferSpace);
                aclBuffer->acl_buffer_len = sizeof(aclBufferSpace);
                aclBuffer->acl_version = 0;
                aclBuffer->acl_type = GPFS_ACL_TYPE_ACCESS;
                static const std::string pattern("/.aclgetXXXXXX");
                std::vector<char> tmpName;
                tmpName.reserve(toDir.size() + pattern.size());
                tmpName.insert(tmpName.end(), toDir.cbegin(), toDir.cend());
                tmpName.insert(tmpName.end(), pattern.cbegin(), pattern.cend());
                tmpName.push_back('\0');
                if (readInitialStat->isDir()) {
                    timerInst(mkdtemp);
                    throwcall::badval(mkdtemp(tmpName.data()), nullptr, "can't create tmp dir '", tmpName.data(), "'");
                } else {
                    static timer::anchor a("mkstemp");
                    timer::instanceUnscoped i(a);
                    auto fd = throwcall::badval(mkstemp(tmpName.data()), -1, "can't create tmp file '", tmpName.data(), "'");
                    i.stop();
                    timerInst(close);
                    throwcall::good0(close(fd), "can't close ", tmpName.data());
                }
                {
                    timerInst(gpfs_getacl);
                    throwcall::good0(gpfs_getacl(tmpName.data(), 0, aclBuffer), "can't get acl for '", tmpName.data(), "'");
                }
                if (readInitialStat->isDir()) {
                    timerInst(rmdir);
                    throwcall::good0(rmdir(tmpName.data()), "can't remove '", tmpName.data(), "'");
                } else {
                    timerInst(unlink);
                    throwcall::good0(unlink(tmpName.data()), "can't remove '", tmpName.data(), "'");
                }
                if (aclBuffer->acl_buffer_len > 0) {
                    timerInst(gpfs_putacl);
                    throwcall::good0(gpfs_putacl(toPath.c_str(), 0, aclBuffer), "can't set acl for '", toPath, "'");
                }
            }
        }
        return retval;
    }

References throwcall::badval(), copyRequest::done, throwcall::good0(), genericStat::isDir(), outputHandler::base::ok, outputHandler::posixFile::rename(), timer::instanceUnscoped::stop(), and timerInst.

Here is the call graph for this function:

Member Data Documentation

factory

factoryTemplate<Gpfs> outputHandler::Gpfs::factory

staticprivate

Definition at line 10 of file outputHandlerGpfs.h.

---

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

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