outputHandler::davix::writerDavix Class Reference

#include <outputHandlerDavix.h>

Inheritance diagram for outputHandler::davix::writerDavix:

Collaboration diagram for outputHandler::davix::writerDavix:

Public Member Functions
	writerDavix (davix &aHandler, const std::string &aPath, copyRequest::stateType &state, bool noWrite)
void	closeAndRemoveBadCopy () override
	~writerDavix () noexcept(false) override
void	writeBlock (const block &b) override
void	doAttributePreservations (const genericStat &readInitialStat) override
void	sync () override
Public Member Functions inherited from davixIoCommon
	davixIoCommon (const std::string &aPath, davixCommon &aHandler)
std::unique_ptr< const genericStat >	getStat () override
Public Member Functions inherited from ioHandle
	ioHandle ()
virtual	~ioHandle () noexcept(false)
virtual bool	parallelizable () const
	tell if this handler is capable of parallel IO. Unsually not the case More...
virtual void	setXattr (const std::string &, const std::string &)
virtual std::string	getXattr (const std::string &)
	get one extended attribute value More...
virtual void	removeXattr (const std::string &)
virtual size_t	getBlockSize () const
virtual void	setBlockSize (size_t newSize)
virtual std::unique_ptr< attrDataType >	getAttrData (const outputHandler::base *)
	get attributes in the optimal way for setting with aOutputHandler More...
virtual std::unique_ptr< acl::list >	getAclData ()
	get acls More...

Additional Inherited Members
Protected Attributes inherited from davixIoCommon
const std::string &	path
davixCommon &	handler
DAVIX_FD *	fd
Protected Attributes inherited from ioHandle
size_t	blockSize
	in bytes, block size to be used when reading or writing More...

Detailed Description

Definition at line 13 of file outputHandlerDavix.h.

Constructor & Destructor Documentation

writerDavix()

outputHandler::davix::writerDavix::writerDavix	(	davix &	aHandler,
		const std::string &	aPath,
		copyRequest::stateType &	state,
		bool	noWrite
	)

Definition at line 137 of file outputHandlerDavix.cpp.

                                                 :
        davixIoCommon(aPath, aHandler) {
        if (noWrite) {
            fd = nullptr;
        } else {
            auto openMode = O_CREAT | O_WRONLY;
            state.clear(copyRequest::stateBitType::append); // clear any old append sets, may be left over from former attempts
            errorReport report(__func__, "open", path);
            fd = handler.posix.open(&handler.params, path.c_str(), openMode, report);
            if (fd == nullptr) {
                report.throwUp();
            }
        }
    };

References copyRequest::append, enumAsBitmask< T >::clear(), davixIoCommon::fd, davixIoCommon::handler, davixCommon::params, davixIoCommon::path, davixCommon::posix, and errorReport::throwUp().

Here is the call graph for this function:

~writerDavix()

outputHandler::davix::writerDavix::~writerDavix ( )

overridenoexcept

Definition at line 168 of file outputHandlerDavix.cpp.

                                                   {
        if (fd != nullptr) {
            if (isUnwinding()) {
                closeAndRemoveBadCopy();
                return;
            }
            errorReport report(__func__, "close", path);
            if (handler.posix.close(fd, report) != 0) {
                report.throwUp();
            }
        }
    };

References errorReport::throwUp().

Here is the call graph for this function:

Member Function Documentation

closeAndRemoveBadCopy()

void outputHandler::davix::writerDavix::closeAndRemoveBadCopy ( )

override

Definition at line 154 of file outputHandlerDavix.cpp.

                                                 {
        errorReport report(__func__, "close", path);
        if (handler.posix.close(fd, report) != 0) {
            errMsg::emit(errMsg::level::debug, errMsg::location(),
                         path, "close during unwind ",
                         report.getMessage());
        }
        errorReport report2(__func__, "unlink", path);
        errMsg::emit(errMsg::level::debug, errMsg::location(),
                     path, "unlink failed copy", "due to exception");
        if (handler.posix.unlink(&handler.params, path, report) != 0) {
            report2.throwUp();
        }
    };

References errMsg::debug, errMsg::emit(), errorReport::getMessage(), and errorReport::throwUp().

Here is the call graph for this function:

doAttributePreservations()

void outputHandler::davix::writerDavix::doAttributePreservations ( const genericStat &  readInitialStat )

override

Definition at line 207 of file outputHandlerDavix.cpp.

                                                                        {
        // not supportted
    }

sync()

void outputHandler::davix::writerDavix::sync ( )

override

Definition at line 211 of file outputHandlerDavix.cpp.

                                {
        throw std::runtime_error("sync not supported");
    }

writeBlock()

void outputHandler::davix::writerDavix::writeBlock ( const block &  b )

override

Definition at line 182 of file outputHandlerDavix.cpp.

                                                    {
        size_t bytes_writen_so_far = 0;
 
        while (bytes_writen_so_far < b.size()) {
            writeRateLimit.wait();
            auto count = b.size() - bytes_writen_so_far;
 
            if (b.isHole()) { // just write zeroes
                count = std::min({count, blockSize, block::nullBufferSize()});
            } else {
                count = std::min(count, blockSize);
            }
            errorReport report(__func__, "write", path);
            auto bytes_writen = handler.posix.write(fd, b.bufferAt(bytes_writen_so_far), count, report);
            if (bytes_writen < 0) {
                report.throwUp();
            }
 
            writeRateLimit.update(bytes_writen);
            bytes_writen_so_far += bytes_writen;
        }
    }

References block::bufferAt(), block::isHole(), block::nullBufferSize(), block::size(), errorReport::throwUp(), throttle::watch::update(), throttle::watch::wait(), and writeRateLimit.

Here is the call graph for this function:

---

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

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