src/java/org/apache/cassandra/service/StorageService.java
/**
     * Handle node moving inside the ring.
     *
     * @param endpoint moving endpoint address
     * @param pieces STATE_MOVING, token
     */
Handle node moving inside the ring.
@param endpoint moving endpoint address
@param pieces STATE_MOVING, token
Handle node moving inside the ring . @param endpoint moving endpoint address @param pieces STATE_MOVING token
private void handleStateMoving(InetAddress endpoint, String[] pieces)
    {
        assert pieces.length >= 2;
        Token token = getPartitioner().getTokenFactory().fromString(pieces[1]);
        if (logger_.isDebugEnabled())
            logger_.debug("Node " + endpoint + " state moving, new token " + token);
        tokenMetadata_.addMovingEndpoint(token, endpoint);
        calculatePendingRanges();
    }
private void handleStateMoving ( InetAddress endpoint , String [ ] pieces ) { assert pieces . length >= 2 ; Token token = getPartitioner ( ) . getTokenFactory ( ) . fromString ( pieces [ 1 ] ) ; if ( logger_ . isDebugEnabled ( ) ) logger_ . debug ( "Node " + endpoint + " state moving, new token " + token ) ; tokenMetadata_ . addMovingEndpoint ( token , endpoint ) ; calculatePendingRanges ( ) ; }
Handle node moving inside the ring.
Handle node moving inside the ring .