From 428fb79b270568b82df074fc0d38d8aaa9d7605e Mon Sep 17 00:00:00 2001 From: fangfengbin <869218239a@zju.edu.cn> Date: Thu, 12 Mar 2020 17:26:45 +0800 Subject: [PATCH] Fix streaming compile bug (#7577) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 灵洵 --- streaming/src/test/mock_actor.cc | 2 +- streaming/src/test/queue_tests_base.h | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/streaming/src/test/mock_actor.cc b/streaming/src/test/mock_actor.cc index c97860b6d..84d2b20b1 100644 --- a/streaming/src/test/mock_actor.cc +++ b/streaming/src/test/mock_actor.cc @@ -405,7 +405,7 @@ class StreamingWorker { STREAMING_LOG(INFO) << "Init message: " << message->ToString(); std::string actor_handle_serialized = message->ActorHandleSerialized(); - worker_->DeserializeAndRegisterActorHandle(actor_handle_serialized); + worker_->DeserializeAndRegisterActorHandle(actor_handle_serialized, ObjectID::Nil()); std::shared_ptr actor_handle(new ActorHandle(actor_handle_serialized)); STREAMING_CHECK(actor_handle != nullptr); STREAMING_LOG(INFO) << " actor id from handle: " << actor_handle->GetActorID(); diff --git a/streaming/src/test/queue_tests_base.h b/streaming/src/test/queue_tests_base.h index 7d62f2c52..6932b5bf7 100644 --- a/streaming/src/test/queue_tests_base.h +++ b/streaming/src/test/queue_tests_base.h @@ -154,7 +154,9 @@ class StreamingQueueTestBase : public ::testing::TestWithParam { const std::vector &rescale_queue_ids, std::string suite_name, std::string test_name, uint64_t param) { std::string forked_serialized_str; - Status st = driver.SerializeActorHandle(peer_actor_id, &forked_serialized_str); + ObjectID actor_handle_id; + Status st = driver.SerializeActorHandle(peer_actor_id, &forked_serialized_str, + &actor_handle_id); STREAMING_CHECK(st.ok()); STREAMING_LOG(INFO) << "forked_serialized_str: " << forked_serialized_str; TestInitMessage msg(role, self_actor_id, peer_actor_id, forked_serialized_str,