From 0f2e4003ce48408e19745cd48b347f034abe562c Mon Sep 17 00:00:00 2001 From: Asias He Date: Tue, 18 Aug 2015 15:38:18 +0800 Subject: [PATCH] storage_service: Implement handle_state_moving --- service/storage_service.cc | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/service/storage_service.cc b/service/storage_service.cc index ba74d1fea2..1286abd44f 100644 --- a/service/storage_service.cc +++ b/service/storage_service.cc @@ -556,15 +556,11 @@ void storage_service::handle_state_left(inet_address endpoint, std::vector pieces) { logger.debug("handle_state_moving endpoint={}", endpoint); + assert(pieces.size() >= 2); + auto token = dht::global_partitioner().from_sstring(pieces[1]); + logger.debug("Node {} state moving, new token {}", endpoint, token); #if 0 - assert pieces.length >= 2; - Token token = getPartitioner().getTokenFactory().fromString(pieces[1]); - - if (logger.isDebugEnabled()) - logger.debug("Node {} state moving, new token {}", endpoint, token); - _token_metadata.addMovingEndpoint(token, endpoint); - PendingRangeCalculatorService.instance.update(); #endif }