Skip to content

Commit decc2a9

Browse files
committed
Naming
1 parent 4037ec4 commit decc2a9

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

server/src/main/java/org/elasticsearch/cluster/routing/IndexRouting.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ protected final int rerouteWritesIfResharding(int shardId) {
163163
return rerouteFromSplitTargetShard(shardId, IndexReshardingState.Split.TargetShardState.HANDOFF);
164164
}
165165

166-
protected final int rerouteReadsIfResharding(int shardId) {
166+
protected final int rerouteSearchIfResharding(int shardId) {
167167
return rerouteFromSplitTargetShard(shardId, IndexReshardingState.Split.TargetShardState.SPLIT);
168168
}
169169

@@ -269,7 +269,7 @@ protected int shardId(String id, @Nullable String routing) {
269269

270270
@Override
271271
public void collectSearchShards(String routing, IntConsumer consumer) {
272-
consumer.accept(rerouteReadsIfResharding(hashToShardId(effectiveRoutingToHash(routing))));
272+
consumer.accept(rerouteSearchIfResharding(hashToShardId(effectiveRoutingToHash(routing))));
273273
}
274274
}
275275

@@ -297,7 +297,7 @@ protected int shardId(String id, @Nullable String routing) {
297297
public void collectSearchShards(String routing, IntConsumer consumer) {
298298
int hash = effectiveRoutingToHash(routing);
299299
for (int i = 0; i < routingPartitionSize; i++) {
300-
consumer.accept(rerouteReadsIfResharding(hashToShardId(hash + i)));
300+
consumer.accept(rerouteSearchIfResharding(hashToShardId(hash + i)));
301301
}
302302
}
303303
}

0 commit comments

Comments
 (0)