Commits on Source (2)
......@@ -1347,7 +1347,11 @@ gkfs_rmdir(const std::string& path) {
errno = ENOTEMPTY;
return -1;
}
err = gkfs::rpc::forward_remove(path, CTX->get_replicas());
if(gkfs::config::proxy::fwd_remove && CTX->use_proxy()) {
err = gkfs::rpc::forward_remove_proxy(path);
} else {
err = gkfs::rpc::forward_remove(path, CTX->get_replicas());
}
if(err) {
errno = err;
return -1;
......
......@@ -145,7 +145,7 @@ void
RocksDBBackend::remove_impl(const std::string& key) {
auto s = db_->Delete(write_opts_, key);
if(!s.ok() && !s.IsNotFound()) {
if(!s.ok()) {
throw_status_excpt(s);
}
}
......
......@@ -253,6 +253,11 @@ rpc_srv_remove_metadata(hg_handle_t handle) {
GKFS_DATA->storage()->destroy_chunk_space(in.path);
}
} catch(const gkfs::metadata::NotFoundException& e) {
GKFS_DATA->spdlogger()->warn(
"{}(): path '{}' message '{}'. Continuing, setting out.err 0.",
__func__, in.path, e.what());
out.err = 0;
} catch(const gkfs::metadata::DBException& e) {
GKFS_DATA->spdlogger()->error("{}(): path '{}' message '{}'", __func__,
in.path, e.what());
......