mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

storage_service: Wait for schedule_schema_pull

Browse Source 
It returns a future, we should not ignore it.
This commit is contained in:
Asias He
2015-08-10 10:26:27 +08:00
parent 1291344e68
commit 7fcaca56bd
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
service/storage_service.cc
View File

@@ -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();