If segments are re-assigned to another node due to rehashing and these segments happen to be in-progress on current node then these transfers should be cancelled. This is handled in method StateConsumerImpl.cancelTransfers(..).

The code contains an error: the currently iterated segment is not included into the cancelled set and this means it does not get cancelled, possibly causing the rehashing to never complete.