wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-17 11:32:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

No need to send actor died signal from RedisActorInfoAccessor (#7883)

Browse Source
This commit is contained in:
micafan
2020-04-03 17:45:39 -07:00
committed by GitHub
parent b853df7a3b
commit 185d591108
1 changed files with 0 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/redis_accessor.cc
-10
View File
@@ -101,16 +101,6 @@ Status RedisLogBasedActorInfoAccessor::AsyncUpdate(
<< ", actor id: " << actor_id << ", log_length: " << log_length;
auto on_success = [callback](RedisGcsClient *client, const ActorID &actor_id,
const ActorTableData &data) {
// If we successfully appended a record to the GCS table of the actor that
// has died, signal this to anyone receiving signals from this actor.
if (data.state() == ActorTableData::DEAD ||
data.state() == ActorTableData::RECONSTRUCTING) {
std::vector<std::string> args = {"XADD", actor_id.Hex(), "*", "signal",
"ACTOR_DIED_SIGNAL"};
auto redis_context = client->primary_context();
RAY_CHECK_OK(redis_context->RunArgvAsync(args));
}
if (callback != nullptr) {
callback(Status::OK());
}