private void transferComplete ( ShardFiles shardFiles ) { _log . debug ( "Transfer complete: id={}, file={}" , _taskId , shardFiles . getFirstFile ( ) ) ; closeShardFiles ( shardFiles ) ; _openTransfers . dec ( ) ; }
Called when a shard file has been transferred successfully or otherwise . This also closes the ShardFiles .