honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-03-09 14:34:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

implement check for in flight now that we have the counter

Browse Source
This commit is contained in:
Britta Weber 2015-05-05 16:15:25 +02:00
parent 87af6491c9
commit fbc26ca49b
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/elasticsearch/indices/SyncedFlushService.java
View File

@ -104,7 +104,7 @@ public class SyncedFlushService extends AbstractComponent {
}
int inflight = getInflightOpsCount(shardId, state, shardRoutingTable);
if (inflight < 0 || inflight > 0) {
if (inflight != 1) {
return new SyncedFlushResult("operation counter on primary is non zero [" + inflight + "]");
}
@ -307,8 +307,7 @@ public class SyncedFlushService extends AbstractComponent {
if (indexShard.routingEntry().primary() == false) {
throw new IndexShardException(request.shardId(), "expected a primary shard");
}
// nocommit - implement :)
int opCount = 0;
int opCount = indexShard.getOperationsCount();
logger.trace("{} in flight operations sampled at [{}]", request.shardId(), opCount);
return new InFlightOpsResponse(opCount);
}