Loading src/client/fuse/fuse_client.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -1424,7 +1424,8 @@ main(int argc, char* argv[]) { #ifdef GKFS_ENABLE_CLIENT_METRICS if(!CTX->init_metrics()) { fprintf(stderr, "FUSE client failed to initialize client metrics. Exit.\n"); fprintf(stderr, "FUSE client failed to initialize client metrics. Exit.\n"); return 1; } #endif Loading src/client/gkfs_metadata.cpp +5 −6 Original line number Diff line number Diff line Loading @@ -610,11 +610,11 @@ gkfs_rename(const string& old_path, const string& new_path) { } return 0; } // Destination exists: remove it first (POSIX rename must atomically replace destination) // Destination exists: remove it first (POSIX rename must atomically // replace destination) auto is_dir_new = S_ISDIR(md_new->mode()); auto rm_err = gkfs::rpc::forward_remove(new_path, is_dir_new, CTX->get_replicas(), md_new->size()); auto rm_err = gkfs::rpc::forward_remove( new_path, is_dir_new, CTX->get_replicas(), md_new->size()); if(rm_err) { errno = rm_err; return -1; Loading @@ -629,8 +629,7 @@ gkfs_rename(const string& old_path, const string& new_path) { md_old = gkfs::utils::get_metadata(original_path, false); if(!md_old) { fprintf(stderr, "GKFS_RENAME: md_old missing intermediate %d\n", fprintf(stderr, "GKFS_RENAME: md_old missing intermediate %d\n", errno); return -1; } Loading Loading
src/client/fuse/fuse_client.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -1424,7 +1424,8 @@ main(int argc, char* argv[]) { #ifdef GKFS_ENABLE_CLIENT_METRICS if(!CTX->init_metrics()) { fprintf(stderr, "FUSE client failed to initialize client metrics. Exit.\n"); fprintf(stderr, "FUSE client failed to initialize client metrics. Exit.\n"); return 1; } #endif Loading
src/client/gkfs_metadata.cpp +5 −6 Original line number Diff line number Diff line Loading @@ -610,11 +610,11 @@ gkfs_rename(const string& old_path, const string& new_path) { } return 0; } // Destination exists: remove it first (POSIX rename must atomically replace destination) // Destination exists: remove it first (POSIX rename must atomically // replace destination) auto is_dir_new = S_ISDIR(md_new->mode()); auto rm_err = gkfs::rpc::forward_remove(new_path, is_dir_new, CTX->get_replicas(), md_new->size()); auto rm_err = gkfs::rpc::forward_remove( new_path, is_dir_new, CTX->get_replicas(), md_new->size()); if(rm_err) { errno = rm_err; return -1; Loading @@ -629,8 +629,7 @@ gkfs_rename(const string& old_path, const string& new_path) { md_old = gkfs::utils::get_metadata(original_path, false); if(!md_old) { fprintf(stderr, "GKFS_RENAME: md_old missing intermediate %d\n", fprintf(stderr, "GKFS_RENAME: md_old missing intermediate %d\n", errno); return -1; } Loading