Commit 328ef992 authored by Ramon Nou's avatar Ramon Nou
Browse files

Updated GekkoFS support with master (pread_ws)

parent 1a9bdb51

src/posix_file/posix_file/fs_plugin/gekko_plugin.cpp

+2 −2
Original line number Diff line number Diff line
@@ -28,13 +28,13 @@ gekko_plugin::open(const std::string& path, int flags, unsigned int mode) { 
// Override the pread function

ssize_t

gekko_plugin::pread(int fd, void* buf, size_t count, off_t offset) {

    return gkfs::syscall::gkfs_pread(fd, buf, count, offset);

    return gkfs::syscall::gkfs_pread_ws(fd, buf, count, offset);

}



// Override the pwrite function

ssize_t

gekko_plugin::pwrite(int fd, const void* buf, size_t count, off_t offset) {

    return gkfs::syscall::gkfs_pwrite(fd, buf, count, offset);

    return gkfs::syscall::gkfs_pwrite_ws(fd, buf, count, offset);

}

src/worker/mpio_read.cpp

+2 −2
Original line number Diff line number Diff line
@@ -152,7 +152,7 @@ mpio_read::operator()() { 
        m_status = make_system_error(e.code().value());

        return make_system_error(e.code().value());

    } catch(const std::exception& e) {

        LOGGER_ERROR("Unexpected exception: {}", e.what());

        LOGGER_ERROR("operator ()() Unexpected exception: {}", e.what());

        m_status = error_code::other;

        return error_code::other;

    }
@@ -231,7 +231,7 @@ mpio_read::progress(int ongoing_index) { 
        m_status = make_system_error(e.code().value());

        return -1;

    } catch(const std::exception& e) {

        LOGGER_ERROR("Unexpected exception: {}", e.what());

        LOGGER_ERROR("Progress: Unexpected exception: {}", e.what());

        m_status = error_code::other;

        return -1;

    }