import java.util.Iterator;
import java.util.List;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
-import javax.annotation.Nonnull;
-import javax.annotation.concurrent.GuardedBy;
+import org.checkerframework.checker.lock.qual.GuardedBy;
+import org.checkerframework.checker.lock.qual.Holding;
+import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.openflowjava.protocol.api.connection.OutboundQueue;
import org.opendaylight.openflowjava.protocol.api.connection.OutboundQueueException;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
commitEntry(xid, message, callback, OutboundQueueEntry.DEFAULT_IS_COMPLETE);
}
- @GuardedBy("unflushedSegments")
+ @Holding("unflushedSegments")
protected void ensureSegment(final StackedSegment first, final int offset) {
final int segmentOffset = offset / StackedSegment.SEGMENT_SIZE;
LOG.debug("Queue {} slow offset {} maps to {} segments {}", this, offset, segmentOffset,
* @param now time stamp
* @return Number of entries written out
*/
- int writeEntries(@Nonnull final Channel channel, final long now) {
+ int writeEntries(@NonNull final Channel channel, final long now) {
// Local cache
StackedSegment segment = firstSegment;
int entries = 0;