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

[GCS]Fix TestActorTableResubscribe bug (#11463)

Browse Source 
Co-authored-by: 灵洵 <fengbin.ffb@antfin.com>
This commit is contained in:
fangfengbin
2020-10-20 22:32:41 -07:00
committed by GitHub
co-authored by 灵洵
parent 2fc3237045
commit a075e37695
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/gcs_client/test/service_based_gcs_client_test.cc
+7 -4
View File
@@ -1043,10 +1043,13 @@ TEST_F(ServiceBasedGcsClientTest, TestActorTableResubscribe) {
// notification of DEAD state.
WaitForExpectedCount(num_subscribe_all_notifications, 3);
WaitForExpectedCount(num_subscribe_one_notifications, 3);
CheckActorData(subscribe_all_notifications[1], rpc::ActorTableData::DEAD);
CheckActorData(subscribe_one_notifications[1], rpc::ActorTableData::DEAD);
CheckActorData(subscribe_all_notifications[2], rpc::ActorTableData::DEAD);
CheckActorData(subscribe_one_notifications[2], rpc::ActorTableData::DEAD);
/// NOTE: GCS will not reply when actor registration fails, so when GCS restarts, gcs
/// client will register the actor again. When an actor is registered, the status in GCS
/// is `DEPENDENCIES_UNREADY`. When GCS finds that the owner of an actor is nil, it will
/// destroy the actor and the status of the actor will change to `DEAD`. The GCS client
/// fetch actor info from the GCS server, and the status of the actor may be
/// `DEPENDENCIES_UNREADY` or `DEAD`, so we do not assert the actor status here any
/// more.
}
TEST_F(ServiceBasedGcsClientTest, TestObjectTableResubscribe) {