diff --git a/src/fuse_create.cpp b/src/fuse_create.cpp index c58c85de..dfc12793 100644 --- a/src/fuse_create.cpp +++ b/src/fuse_create.cpp @@ -31,106 +31,6 @@ namespace l { - /* - The kernel expects being able to issue read requests when running - with writeback caching enabled so we must change O_WRONLY to - O_RDWR. - - With writeback caching enabled the kernel handles O_APPEND. Could - be an issue if the underlying file changes out of band but that is - true of any caching. - */ - static - void - tweak_flags_writeback_cache(int *flags_) - { - if((*flags_ & O_ACCMODE) == O_WRONLY) - *flags_ = ((*flags_ & ~O_ACCMODE) | O_RDWR); - if(*flags_ & O_APPEND) - *flags_ &= ~O_APPEND; - } - - static - bool - rdonly(const int flags_) - { - return ((flags_ & O_ACCMODE) == O_RDONLY); - } - - static - bool - calculate_flush(FlushOnClose const flushonclose_, - int const flags_) - { - switch(flushonclose_) - { - case FlushOnCloseEnum::NEVER: - return false; - case FlushOnCloseEnum::OPENED_FOR_WRITE: - return !l::rdonly(flags_); - case FlushOnCloseEnum::ALWAYS: - return true; - } - - return true; - } - - static - void - config_to_ffi_flags(Config::Read &cfg_, - const int tid_, - fuse_file_info_t *ffi_) - { - switch(cfg_->cache_files) - { - case CacheFiles::ENUM::LIBFUSE: - ffi_->direct_io = cfg_->direct_io; - ffi_->keep_cache = cfg_->kernel_cache; - ffi_->auto_cache = cfg_->auto_cache; - break; - case CacheFiles::ENUM::OFF: - ffi_->direct_io = 1; - ffi_->keep_cache = 0; - ffi_->auto_cache = 0; - break; - case CacheFiles::ENUM::PARTIAL: - ffi_->direct_io = 0; - ffi_->keep_cache = 0; - ffi_->auto_cache = 0; - break; - case CacheFiles::ENUM::FULL: - ffi_->direct_io = 0; - ffi_->keep_cache = 1; - ffi_->auto_cache = 0; - break; - case CacheFiles::ENUM::AUTO_FULL: - ffi_->direct_io = 0; - ffi_->keep_cache = 0; - ffi_->auto_cache = 1; - break; - case CacheFiles::ENUM::PER_PROCESS: - std::string proc_name; - - proc_name = procfs::get_name(tid_); - if(cfg_->cache_files_process_names.count(proc_name) == 0) - { - ffi_->direct_io = 1; - ffi_->keep_cache = 0; - ffi_->auto_cache = 0; - } - else - { - ffi_->direct_io = 0; - ffi_->keep_cache = 0; - ffi_->auto_cache = 0; - } - break; - } - - if(cfg_->parallel_direct_writes == true) - ffi_->parallel_direct_writes = ffi_->direct_io; - } - static int create_core(const std::string &fullpath_,