Loading include/config.hpp +3 −3 Original line number Diff line number Diff line Loading @@ -100,11 +100,11 @@ constexpr auto dirents_buff_size = (8 * 1024 * 1024); // 8 mega * files to and from local file systems The value is directly mapped to created * Argobots xstreams, controlled in a single pool with ABT_snoozer scheduler */ constexpr auto daemon_io_xstreams = 8; constexpr auto daemon_io_xstreams = 4; // Number of threads used for RPC handlers at the daemon constexpr auto daemon_handler_xstreams = 8; constexpr auto daemon_handler_xstreams = 2; // Number of threads used for RPC handlers at the proxy constexpr auto proxy_handler_xstreams = 8; constexpr auto proxy_handler_xstreams = 2; } // namespace rpc namespace rocksdb { Loading src/client/gkfs_functions.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -255,9 +255,9 @@ gkfs_create(const std::string& path, mode_t mode) { return -1; } if(check_parent_dir(path)) { return -1; } //if(check_parent_dir(path)) { // return -1; //} if(gkfs::config::proxy::fwd_create && CTX->use_proxy()) { return gkfs::rpc::forward_create_proxy(path, mode); } else { Loading Loading
include/config.hpp +3 −3 Original line number Diff line number Diff line Loading @@ -100,11 +100,11 @@ constexpr auto dirents_buff_size = (8 * 1024 * 1024); // 8 mega * files to and from local file systems The value is directly mapped to created * Argobots xstreams, controlled in a single pool with ABT_snoozer scheduler */ constexpr auto daemon_io_xstreams = 8; constexpr auto daemon_io_xstreams = 4; // Number of threads used for RPC handlers at the daemon constexpr auto daemon_handler_xstreams = 8; constexpr auto daemon_handler_xstreams = 2; // Number of threads used for RPC handlers at the proxy constexpr auto proxy_handler_xstreams = 8; constexpr auto proxy_handler_xstreams = 2; } // namespace rpc namespace rocksdb { Loading
src/client/gkfs_functions.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -255,9 +255,9 @@ gkfs_create(const std::string& path, mode_t mode) { return -1; } if(check_parent_dir(path)) { return -1; } //if(check_parent_dir(path)) { // return -1; //} if(gkfs::config::proxy::fwd_create && CTX->use_proxy()) { return gkfs::rpc::forward_create_proxy(path, mode); } else { Loading