private final List<StackedSegment> unflushedSegments = new ArrayList<>(2);
@GuardedBy("unflushedSegments")
private final List<StackedSegment> uncompletedSegments = new ArrayList<>(2);
- private final OutboundQueueManager<?> manager;
+ private final AbstractOutboundQueueManager<?> manager;
private volatile long allocatedXid = -1;
private volatile long barrierXid = -1;
// Accessed from Netty only
private int flushOffset;
- StackedOutboundQueue(final OutboundQueueManager<?> manager) {
+ StackedOutboundQueue(final AbstractOutboundQueueManager<?> manager) {
this.manager = Preconditions.checkNotNull(manager);
firstSegment = StackedSegment.create(0L);
uncompletedSegments.add(firstSegment);
if (bXid >= fXid) {
LOG.debug("Barrier found at XID {} (currently at {})", bXid, fXid);
return null;
- } else {
- return reserveEntry();
}
+ return reserveEntry();
}
boolean pairRequest(final OfHeader message) {