AtomicReferenceArray shardResults = responsesByItemAndShard.get(slot);
if (shardResults == null) {
continue;
}
shardResults.set(shardId.id(), new BroadcastShardOperationFailedException(shardId, e));
<BUG>assert expectedOperationsPerItem[slot].get() >= 1 : "slot[" + slot + "] can't be lower than one. Caused by: " + e.getMessage();

if (expectedOperationsPerItem[slot].decrementAndGet() == 0) {
</BUG>
reduce(slot, percolateRequests, expectedOperations, reducedResponses, listener, responsesByItemAndShard);

AtomicReferenceArray shardResults = responsesByItemAndShard.get(slot);
if (shardResults == null) {
continue;
