public boolean put()

in mbp-only/src/main/java/com/epam/cme/mdp3/core/control/IncrementalRefreshHolder.java [37:58]

• 21 lines of code
• 4 McCabe index (conditional complexity)

    public boolean put(final IncrementalRefreshQueueEntry queueEntry, final long rptSeqNum) {
        if (rptSeqNumHolder < rptSeqNum) {
            rptSeqNumHolder = rptSeqNum;
            final MdpGroupEntry incrEntry = queueEntry.groupEntry;
            this.entrySize = incrEntry.getBlockLength();
            this.matchEventIndicator = queueEntry.matchEventIndicator;
            this.incrPcktSeqNum = queueEntry.incrPcktSeqNum;

            if (store.capacity() < entrySize) {
                store.release();
                store = NativeBytesStore.nativeStoreWithFixedCapacity(entrySize);
            }
            incrEntry.buffer().copyTo(incrEntry.getAbsoluteEntryOffset(), this.store, entrySize);
            this.sbeGroupType = incrEntry.getSbeGroupType();
            return true;
        } else {
            if(logger.isTraceEnabled()) {
                logger.trace("Incremental Refresh Entry #{} data was not stored because too old", rptSeqNum);
            }
            return false;
        }
    }