mirror of
https://github.com/trapexit/mergerfs.git
synced 2026-10-19 16:16:48 +00:00
Antonio S. Musumeci
364f8c4407
The create policy can legitimately return success with an empty destination list (e.g. every candidate rejected). Previously we then dereferenced dst_branch[0] and faulted. Return -ENOSPC so the original write that triggered the move propagates a sensible errno to userspace.
149 lines
3.8 KiB
C++
149 lines
3.8 KiB
C++
/*
|
|
ISC License
|
|
|
|
Copyright (c) 2026, Antonio SJ Musumeci <trapexit@spawn.link>
|
|
|
|
Permission to use, copy, modify, and/or distribute this software for any
|
|
purpose with or without fee is hereby granted, provided that the above
|
|
copyright notice and this permission notice appear in all copies.
|
|
|
|
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
|
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
|
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
*/
|
|
|
|
#include "fs_movefile_and_open.hpp"
|
|
|
|
#include "base_types.h"
|
|
#include "errno.hpp"
|
|
#include "fs_clonepath.hpp"
|
|
#include "fs_close.hpp"
|
|
#include "fs_copyfile.hpp"
|
|
#include "fs_file_size.hpp"
|
|
#include "fs_findonfs.hpp"
|
|
#include "fs_getfl.hpp"
|
|
#include "fs_has_space.hpp"
|
|
#include "fs_mktemp.hpp"
|
|
#include "fs_open.hpp"
|
|
#include "fs_path.hpp"
|
|
#include "fs_rename.hpp"
|
|
#include "fs_stat.hpp"
|
|
#include "fs_unlink.hpp"
|
|
#include "policy.hpp"
|
|
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
#include <fcntl.h>
|
|
#include <stdlib.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/types.h>
|
|
#include <unistd.h>
|
|
|
|
|
|
static
|
|
int
|
|
_cleanup_flags(const int flags_)
|
|
{
|
|
int rv;
|
|
|
|
rv = flags_;
|
|
rv = (rv & ~O_TRUNC);
|
|
rv = (rv & ~O_CREAT);
|
|
rv = (rv & ~O_EXCL);
|
|
|
|
return rv;
|
|
}
|
|
|
|
static
|
|
int
|
|
_movefile_and_open(const Policy::Create &createFunc_,
|
|
const Branches::Ptr &branches_,
|
|
const fs::path &branchpath_,
|
|
const fs::path &fusepath_,
|
|
int origfd_)
|
|
{
|
|
int rv;
|
|
int dstfd_flags;
|
|
int origfd_flags;
|
|
s64 src_size;
|
|
fs::path fusedir;
|
|
fs::path src_branch;
|
|
fs::path src_filepath;
|
|
fs::path dst_filepath;
|
|
std::vector<Branch*> dst_branch;
|
|
|
|
src_branch = branchpath_;
|
|
|
|
rv = createFunc_(branches_,fusepath_,dst_branch);
|
|
if(rv < 0)
|
|
return rv;
|
|
if(dst_branch.empty())
|
|
return -ENOSPC;
|
|
|
|
origfd_flags = fs::getfl(origfd_);
|
|
if(origfd_flags < 0)
|
|
return origfd_flags;
|
|
|
|
src_size = fs::file_size(origfd_);
|
|
if(src_size < 0)
|
|
return src_size;
|
|
|
|
if(fs::has_space(dst_branch[0]->path,src_size) == false)
|
|
return -ENOSPC;
|
|
|
|
fusedir = fusepath_.parent_path();
|
|
|
|
rv = fs::clonepath(src_branch,dst_branch[0]->path,fusedir);
|
|
if(rv < 0)
|
|
return -ENOSPC;
|
|
|
|
src_filepath = src_branch / fusepath_;
|
|
dst_filepath = dst_branch[0]->path / fusepath_;
|
|
|
|
rv = fs::copyfile(src_filepath,dst_filepath,{.cleanup_failure = true});
|
|
if(rv < 0)
|
|
return -ENOSPC;
|
|
|
|
dstfd_flags = ::_cleanup_flags(origfd_flags);
|
|
rv = fs::open(dst_filepath,dstfd_flags);
|
|
if(rv < 0)
|
|
return -ENOSPC;
|
|
|
|
fs::unlink(src_filepath);
|
|
|
|
return rv;
|
|
}
|
|
|
|
int
|
|
fs::movefile_and_open(const Policy::Create &policy_,
|
|
const Branches::Ptr &branches_,
|
|
const fs::path &branchpath_,
|
|
const fs::path &fusepath_,
|
|
const int origfd_)
|
|
{
|
|
return ::_movefile_and_open(policy_,
|
|
branches_,
|
|
branchpath_,
|
|
fusepath_,
|
|
origfd_);
|
|
}
|
|
|
|
int
|
|
fs::movefile_and_open_as_root(const Policy::Create &policy_,
|
|
const Branches::Ptr &branches_,
|
|
const fs::path &branchpath_,
|
|
const fs::path &fusepath_,
|
|
const int origfd_)
|
|
{
|
|
return fs::movefile_and_open(policy_,
|
|
branches_,
|
|
branchpath_,
|
|
fusepath_,
|
|
origfd_);
|
|
}
|