From 7fcaca56bdcdda4bcab8516e0952a21bb2634cec Mon Sep 17 00:00:00 2001 From: Asias He Date: Mon, 10 Aug 2015 10:26:27 +0800 Subject: [PATCH] storage_service: Wait for schedule_schema_pull It returns a future, we should not ignore it. --- service/storage_service.cc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/service/storage_service.cc b/service/storage_service.cc index b949f4b9f0..edb66d14dc 100644 --- a/service/storage_service.cc +++ b/service/storage_service.cc @@ -650,12 +650,12 @@ void storage_service::on_join(gms::inet_address endpoint, gms::endpoint_state ep for (auto e : ep_state.get_application_state_map()) { on_change(endpoint, e.first, e.second); } - get_local_migration_manager().schedule_schema_pull(endpoint, ep_state); + get_local_migration_manager().schedule_schema_pull(endpoint, ep_state).get(); } void storage_service::on_alive(gms::inet_address endpoint, gms::endpoint_state state) { logger.debug("on_alive endpoint={}", endpoint); - get_local_migration_manager().schedule_schema_pull(endpoint, state); + get_local_migration_manager().schedule_schema_pull(endpoint, state).get(); if (_token_metadata.is_member(endpoint)) { #if 0 HintedHandOffManager.instance.scheduleHintDelivery(endpoint, true); @@ -702,7 +702,7 @@ void storage_service::on_change(inet_address endpoint, application_state state, } do_update_system_peers_table(endpoint, state, value); if (state == application_state::SCHEMA) { - get_local_migration_manager().schedule_schema_pull(endpoint, *ep_state); + get_local_migration_manager().schedule_schema_pull(endpoint, *ep_state).get(); } } replicate_to_all_cores().get();