move marking recovering before creating a status
This commit is contained in:
parent
4c00e89f5e
commit
4e74001bde
|
@ -143,10 +143,10 @@ public class IndexShardGatewayService extends AbstractIndexShardComponent implem
|
||||||
|
|
||||||
threadPool.cached().execute(new Runnable() {
|
threadPool.cached().execute(new Runnable() {
|
||||||
@Override public void run() {
|
@Override public void run() {
|
||||||
|
indexShard.recovering();
|
||||||
|
|
||||||
recoveryStatus = new RecoveryStatus();
|
recoveryStatus = new RecoveryStatus();
|
||||||
recoveryStatus.updateStage(RecoveryStatus.Stage.INIT);
|
recoveryStatus.updateStage(RecoveryStatus.Stage.INIT);
|
||||||
indexShard.recovering();
|
|
||||||
|
|
||||||
// we know we are on a thread, we can spin till we can engage in recovery
|
// we know we are on a thread, we can spin till we can engage in recovery
|
||||||
while (!recoveryThrottler.tryRecovery(shardId, "gateway")) {
|
while (!recoveryThrottler.tryRecovery(shardId, "gateway")) {
|
||||||
|
|
Loading…
Reference in New Issue