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

storage_service: Implement handle_state_moving

Browse Source
This commit is contained in:
Asias He
2015-08-18 15:38:18 +08:00
parent 8a7f7d5d8b
commit 0f2e4003ce
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
service/storage_service.cc
View File

@@ -556,15 +556,11 @@ void storage_service::handle_state_left(inet_address endpoint, std::vector<sstri
void storage_service::handle_state_moving(inet_address endpoint, std::vector<sstring> 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
}