Skip to content

Commit 84a96b8

Browse files
committed
change variable names
1 parent 5c496d0 commit 84a96b8

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

server/src/main/java/org/elasticsearch/action/bulk/BulkShardRequest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,8 @@ public BulkShardRequest(StreamInput in) throws IOException {
5050
}
5151
}
5252

53-
public BulkShardRequest(ShardId shardId, int shardCount, RefreshPolicy refreshPolicy, BulkItemRequest[] items) {
54-
this(shardId, shardCount, refreshPolicy, items, false);
53+
public BulkShardRequest(ShardId shardId, int reshardSplitShardCount, RefreshPolicy refreshPolicy, BulkItemRequest[] items) {
54+
this(shardId, reshardSplitShardCount, refreshPolicy, items, false);
5555
}
5656

5757
public BulkShardRequest(ShardId shardId, RefreshPolicy refreshPolicy, BulkItemRequest[] items) {
@@ -62,8 +62,8 @@ public BulkShardRequest(ShardId shardId, RefreshPolicy refreshPolicy, BulkItemRe
6262
this(shardId, 0, refreshPolicy, items, isSimulated);
6363
}
6464

65-
public BulkShardRequest(ShardId shardId, int shardCount, RefreshPolicy refreshPolicy, BulkItemRequest[] items, boolean isSimulated) {
66-
super(shardId, shardCount);
65+
public BulkShardRequest(ShardId shardId, int reshardSplitShardCount, RefreshPolicy refreshPolicy, BulkItemRequest[] items, boolean isSimulated) {
66+
super(shardId, reshardSplitShardCount);
6767
this.items = items;
6868
setRefreshPolicy(refreshPolicy);
6969
this.isSimulated = isSimulated;

server/src/main/java/org/elasticsearch/cluster/metadata/IndexReshardingState.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -375,8 +375,8 @@ public boolean targetStateAtLeast(int shardNum, TargetShardState targetShardStat
375375
return getTargetShardState(shardNum).ordinal() >= targetShardState.ordinal();
376376
}
377377

378-
public boolean allTargetStatesAtLeast(int shardNum, TargetShardState targetShardState) {
379-
var targets = getTargetStatesFor(shardNum);
378+
public boolean allTargetStatesAtLeast(int sourceShardId, TargetShardState targetShardState) {
379+
var targets = getTargetStatesFor(sourceShardId);
380380
for (TargetShardState state : targets) {
381381
if (state.ordinal() < targetShardState.ordinal()) {
382382
return false;

0 commit comments

Comments
 (0)