diff --git a/src/ray/gcs/redis_gcs_client.cc b/src/ray/gcs/redis_gcs_client.cc index 0fcf9dad7..4df428f1c 100644 --- a/src/ray/gcs/redis_gcs_client.cc +++ b/src/ray/gcs/redis_gcs_client.cc @@ -120,7 +120,6 @@ Status RedisGcsClient::Connect(boost::asio::io_service &io_service) { Attach(io_service); actor_table_.reset(new ActorTable({primary_context_}, this)); - direct_actor_table_.reset(new DirectActorTable({primary_context_}, this)); // TODO(micafan) Modify ClientTable' Constructor(remove ClientID) in future. // We will use NodeID instead of ClientID. @@ -198,8 +197,6 @@ raylet::TaskTable &RedisGcsClient::raylet_task_table() { return *raylet_task_tab ActorTable &RedisGcsClient::actor_table() { return *actor_table_; } -DirectActorTable &RedisGcsClient::direct_actor_table() { return *direct_actor_table_; } - TaskReconstructionLog &RedisGcsClient::task_reconstruction_log() { return *task_reconstruction_log_; } diff --git a/src/ray/gcs/redis_gcs_client.h b/src/ray/gcs/redis_gcs_client.h index 8e76f7804..c0a135350 100644 --- a/src/ray/gcs/redis_gcs_client.h +++ b/src/ray/gcs/redis_gcs_client.h @@ -66,10 +66,6 @@ class RAY_EXPORT RedisGcsClient : public GcsClient { TaskLeaseTable &task_lease_table(); ErrorTable &error_table(); ProfileTable &profile_table(); - /// Used only for direct calls. Tasks submitted through the raylet transport - /// should use Actors(), which has a requirement on the order in which - /// entries can be appended to the log. - DirectActorTable &direct_actor_table(); // We also need something to export generic code to run on workers from the // driver (to set the PYTHONPATH) @@ -115,7 +111,6 @@ class RAY_EXPORT RedisGcsClient : public GcsClient { std::unique_ptr object_table_; std::unique_ptr raylet_task_table_; std::unique_ptr actor_table_; - std::unique_ptr direct_actor_table_; std::unique_ptr task_reconstruction_log_; std::unique_ptr task_lease_table_; std::unique_ptr heartbeat_table_; diff --git a/src/ray/gcs/subscription_executor.cc b/src/ray/gcs/subscription_executor.cc index 775acf854..c6e0f4e4e 100644 --- a/src/ray/gcs/subscription_executor.cc +++ b/src/ray/gcs/subscription_executor.cc @@ -185,7 +185,6 @@ Status SubscriptionExecutor::AsyncUnsubscribe( } template class SubscriptionExecutor; -template class SubscriptionExecutor; template class SubscriptionExecutor; template class SubscriptionExecutor; template class SubscriptionExecutor; diff --git a/src/ray/gcs/tables.h b/src/ray/gcs/tables.h index 99388b316..b9d9fdac7 100644 --- a/src/ray/gcs/tables.h +++ b/src/ray/gcs/tables.h @@ -716,16 +716,6 @@ class ActorTable : public Log { } }; -class DirectActorTable : public Log { - public: - DirectActorTable(const std::vector> &contexts, - RedisGcsClient *client) - : Log(contexts, client) { - pubsub_channel_ = TablePubsub::DIRECT_ACTOR_PUBSUB; - prefix_ = TablePrefix::DIRECT_ACTOR; - } -}; - class TaskReconstructionLog : public Log { public: TaskReconstructionLog(const std::vector> &contexts,