private boolean isTxAvailableToCommitOnOwnNode()

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

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

    private boolean isTxAvailableToCommitOnOwnNode(TxInfo txInfo, Lazy<UUID, JointTxScope> ownedScopePerNode) {
        JointTxScope sameNodeScope = ownedScopePerNode.get(txInfo.consumerId());

        if (sameNodeScope.containsAll(txInfo.scopeIterator())) {
            return true;
        }
        for (Map.Entry<UUID, JointTxScope> entry : ownedScopePerNode) {
            UUID nodeId = entry.getKey();
            JointTxScope nodeScope = entry.getValue();

            if (!nodeId.equals(txInfo.consumerId()) && nodeScope.intersects(txInfo.scopeIterator())) {
                return false;
            }
        }
        return true;
    }