The 2pc from lianbian

2pc's People

Contributors

Stargazers

Watchers

2pc's Issues

疑问：该项目是否属于2pc范畴？投票阶段，直接提交了事务，冻结金额，使资源得到另一个中间状态，但这不属于2pc了吧？

    @Override
    public VoteResult vote(final DistributedTransaction transaction) {
        try {
// 这里直接提交了事务，冻结金额，使资源得到另一个中间状态
            transactionTemplate.execute(new TransactionCallbackWithoutResult() {
                @Override
                protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
                    getParticipantLogKeeper().saveOrUpdate(transaction);
                    check(transaction);
                    freezeAccountsOrCheckAccounts(transaction);
                    getParticipantLogKeeper().recordMsg(transaction, net.lianbian.tpc.protocol.domian.TransactionStatus.Yes);
                }
            });
            return new VoteResultImpl(transaction.id(), name(), System.currentTimeMillis(), Vote.Yes, "ok");
        } catch (Exception e) {
            logger.error("{} votes No for {}", name(), transaction.id(), e);
            final VoteResultImpl voteResult = new VoteResultImpl(transaction.id(), name(), System.currentTimeMillis(), Vote.No, e.getMessage());
            try {
                getParticipantLogKeeper().recordMsg(transaction, net.lianbian.tpc.protocol.domian.TransactionStatus.Abort);
            } catch (Exception e2) {
                logger.error("Fail to record Abort status for transaction {}", transaction.id(), e2);
            }
            return voteResult;
        }
    }

Recommend Projects