public void registerNew()

in core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanner.java [62:83]

• 20 lines of code
• 5 McCabe index (conditional complexity)

    public void registerNew(List<TxInfo> newTxInfos) {
        filterCommitted(newTxInfos);
        MergeHelper.mergeTo(newTxInfos, state.txInfos());
        for (TxInfo newTxInfo : newTxInfos) {
            long id = newTxInfo.id();

            state.orphanTransactions().remove(id);
            state.inProgressTransactions().remove(id);
        }
        // Update last dense read.
        long next = state.lastDenseRead() + 1;
        for (TxInfo txInfo : state.txInfos()) {
            long id = txInfo.id();
            if (id == next) {
                next++;
            }
            else if (id > next) {
                break;
            }
        }
        state.setLastDenseRead(next - 1);
    }