wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-08-02 13:01:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Always replace DEL with UNLINK (#13832)

Browse Source
This commit is contained in:
Tao Wang
2021-02-04 10:30:00 +08:00
committed by GitHub
parent 1187d1dd3e
commit e0d9c8f0a8
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/store_client/redis_store_client.cc
+5 -3
View File
@@ -104,7 +104,8 @@ Status RedisStoreClient::AsyncDelete(const std::string &table_name,
}
std::string redis_key = GenRedisKey(table_name, key);
std::vector<std::string> args = {"DEL", redis_key};
// We always replace `DEL` with `UNLINK`.
std::vector<std::string> args = {"UNLINK", redis_key};
auto shard_context = redis_client_->GetShardContext(redis_key);
return shard_context->RunArgvAsync(args, delete_callback);
@@ -218,10 +219,11 @@ Status RedisStoreClient::DoPut(const std::string &key, const std::string &data,
Status RedisStoreClient::DeleteByKeys(const std::vector<std::string> &keys,
const StatusCallback &callback) {
// The `DEL` command for each shard.
// Delete for each shard.
// We always replace `DEL` with `UNLINK`.
int total_count = 0;
auto del_commands_by_shards =
GenCommandsByShards(redis_client_, "DEL", keys, &total_count);
GenCommandsByShards(redis_client_, "UNLINK", keys, &total_count);
auto finished_count = std::make_shared<int>(0);