Permalink
Browse files

Generated version update

  • Loading branch information...
nitsanw committed Jun 14, 2018
1 parent 2e38415 commit 6ce23ada59e12c5bc93aeb5207d895a2647227c6
Showing with 3 additions and 3 deletions.
  1. +3 −3 jctools-core/src/main/java/org/jctools/queues/atomic/MpmcAtomicArrayQueue.java
@@ -363,7 +363,7 @@ public int drain(Consumer<E> c, int limit) {
consumed += lookAheadStep;
} else {
if (lookAheadSeq < expectedLookAheadSeq) {
if (notAvailableYet(cIndex, mask, sBuffer, cIndex + 1)) {
if (notAvailable(cIndex, mask, sBuffer, cIndex + 1)) {
return consumed;
}
}
@@ -430,7 +430,7 @@ public int fill(Supplier<E> s, int limit) {
produced += lookAheadStep;
} else {
if (lookAheadSeq < expectedLookAheadSeq) {
if (notAvailableYet(pIndex, mask, sBuffer, pIndex)) {
if (notAvailable(pIndex, mask, sBuffer, pIndex)) {
return produced;
}
}
@@ -440,7 +440,7 @@ public int fill(Supplier<E> s, int limit) {
return limit;
}
private boolean notAvailableYet(long index, int mask, AtomicLongArray sBuffer, long expectedSeq) {
private boolean notAvailable(long index, int mask, AtomicLongArray sBuffer, long expectedSeq) {
final int seqOffset = calcSequenceOffset(index, mask);
final long seq = lvSequence(sBuffer, seqOffset);
if (seq < expectedSeq) {

0 comments on commit 6ce23ad

Please sign in to comment.