honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename RETRY stage in recovery to THROTTLE

Browse Source
This commit is contained in:
kimchy 2010-08-21 15:13:34 +03:00
parent 0c72bb2125
commit e12bdd9faf
7 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/status/GatewayRecoveryStatus.java
View File

@ -30,7 +30,7 @@ public class GatewayRecoveryStatus {
public enum Stage { public enum Stage {
INIT((byte) 0), INIT((byte) 0),
RETRY((byte) 1), THROTTLE((byte) 1),
INDEX((byte) 2), INDEX((byte) 2),
TRANSLOG((byte) 3), TRANSLOG((byte) 3),
FINALIZE((byte) 4), FINALIZE((byte) 4),
@ -50,7 +50,7 @@ public class GatewayRecoveryStatus {
if (value == 0) { if (value == 0) {
return INIT; return INIT;
} else if (value == 1) { } else if (value == 1) {
return RETRY; return THROTTLE;
} else if (value == 2) { } else if (value == 2) {
return INDEX; return INDEX;
} else if (value == 3) { } else if (value == 3) {

4
modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/status/PeerRecoveryStatus.java
View File

@ -30,7 +30,7 @@ public class PeerRecoveryStatus {
public enum Stage { public enum Stage {
INIT((byte) 0), INIT((byte) 0),
RETRY((byte) 1), THROTTLE((byte) 1),
INDEX((byte) 2), INDEX((byte) 2),
TRANSLOG((byte) 3), TRANSLOG((byte) 3),
FINALIZE((byte) 4), FINALIZE((byte) 4),
@ -50,7 +50,7 @@ public class PeerRecoveryStatus {
if (value == 0) { if (value == 0) {
return INIT; return INIT;
} else if (value == 1) { } else if (value == 1) {
return RETRY; return THROTTLE;
} else if (value == 2) { } else if (value == 2) {
return INDEX; return INDEX;
} else if (value == 3) { } else if (value == 3) {

8
modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/indices/status/TransportIndicesStatusAction.java
View File

@ -177,8 +177,8 @@ public class TransportIndicesStatusAction extends TransportBroadcastOperationAct
case TRANSLOG: case TRANSLOG:
stage = PeerRecoveryStatus.Stage.TRANSLOG; stage = PeerRecoveryStatus.Stage.TRANSLOG;
break; break;
case RETRY: case THROTTLE:
stage = PeerRecoveryStatus.Stage.RETRY; stage = PeerRecoveryStatus.Stage.THROTTLE;
break; break;
case FINALIZE: case FINALIZE:
stage = PeerRecoveryStatus.Stage.FINALIZE; stage = PeerRecoveryStatus.Stage.FINALIZE;
@ -208,8 +208,8 @@ public class TransportIndicesStatusAction extends TransportBroadcastOperationAct
case TRANSLOG: case TRANSLOG:
stage = GatewayRecoveryStatus.Stage.TRANSLOG; stage = GatewayRecoveryStatus.Stage.TRANSLOG;
break; break;
case RETRY: case THROTTLE:
stage = GatewayRecoveryStatus.Stage.RETRY; stage = GatewayRecoveryStatus.Stage.THROTTLE;
break; break;
case DONE: case DONE:
stage = GatewayRecoveryStatus.Stage.DONE; stage = GatewayRecoveryStatus.Stage.DONE;

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/gateway/IndexShardGatewayService.java
View File

@ -152,7 +152,7 @@ public class IndexShardGatewayService extends AbstractIndexShardComponent implem
listener.onIgnoreRecovery("ignoring recovery while waiting on retry, closed"); listener.onIgnoreRecovery("ignoring recovery while waiting on retry, closed");
return; return;
} }
recoveryStatus.updateStage(RecoveryStatus.Stage.RETRY); recoveryStatus.updateStage(RecoveryStatus.Stage.THROTTLE);
try { try {
Thread.sleep(recoveryThrottler.throttleInterval().millis()); Thread.sleep(recoveryThrottler.throttleInterval().millis());
recoveryStatus.retryTime(System.currentTimeMillis() - recoveryStatus.startTime()); recoveryStatus.retryTime(System.currentTimeMillis() - recoveryStatus.startTime());

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/gateway/RecoveryStatus.java
View File

@ -28,7 +28,7 @@ public class RecoveryStatus {
public static enum Stage { public static enum Stage {
INIT, INIT,
RETRY, THROTTLE,
INDEX, INDEX,
TRANSLOG, TRANSLOG,
DONE DONE

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoveryStatus.java
View File

@ -33,7 +33,7 @@ public class RecoveryStatus {
public static enum Stage { public static enum Stage {
INIT, INIT,
RETRY, THROTTLE,
INDEX, INDEX,
TRANSLOG, TRANSLOG,
FINALIZE, FINALIZE,

6
modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoveryTarget.java
View File

@ -168,7 +168,7 @@ public class RecoveryTarget extends AbstractComponent {
} }
if (!recoveryThrottler.tryRecovery(shard.shardId(), "peer recovery target")) { if (!recoveryThrottler.tryRecovery(shard.shardId(), "peer recovery target")) {
recovery.stage = RecoveryStatus.Stage.RETRY; recovery.stage = RecoveryStatus.Stage.THROTTLE;
recovery.retryTime = System.currentTimeMillis() - recovery.startTime; recovery.retryTime = System.currentTimeMillis() - recovery.startTime;
listener.onRetryRecovery(recoveryThrottler.throttleInterval()); listener.onRetryRecovery(recoveryThrottler.throttleInterval());
return; return;
@ -189,7 +189,7 @@ public class RecoveryTarget extends AbstractComponent {
return; return;
} }
logger.trace("[{}][{}] retrying recovery in [{}], source shard is busy", request.shardId().index().name(), request.shardId().id(), recoveryThrottler.throttleInterval()); logger.trace("[{}][{}] retrying recovery in [{}], source shard is busy", request.shardId().index().name(), request.shardId().id(), recoveryThrottler.throttleInterval());
recovery.stage = RecoveryStatus.Stage.RETRY; recovery.stage = RecoveryStatus.Stage.THROTTLE;
recovery.retryTime = System.currentTimeMillis() - recovery.startTime; recovery.retryTime = System.currentTimeMillis() - recovery.startTime;
listener.onRetryRecovery(recoveryThrottler.throttleInterval()); listener.onRetryRecovery(recoveryThrottler.throttleInterval());
return; return;
@ -231,7 +231,7 @@ public class RecoveryTarget extends AbstractComponent {
} }
if (cause instanceof IndexShardNotStartedException || cause instanceof IndexMissingException || cause instanceof IndexShardMissingException) { if (cause instanceof IndexShardNotStartedException || cause instanceof IndexMissingException || cause instanceof IndexShardMissingException) {
recovery.stage = RecoveryStatus.Stage.RETRY; recovery.stage = RecoveryStatus.Stage.THROTTLE;
recovery.retryTime = System.currentTimeMillis() - recovery.startTime; recovery.retryTime = System.currentTimeMillis() - recovery.startTime;
listener.onRetryRecovery(recoveryThrottler.throttleInterval()); listener.onRetryRecovery(recoveryThrottler.throttleInterval());
return; return;