提交 4787226f 编写于 作者: Z zhangshuang

add more debug info

上级 46168b36
......@@ -441,6 +441,7 @@ public final class Acceptor {
epoch.deserializedPrecomputeValue.add(epoch.deserializedPropValue[i]);
}
LOGGER.info("I am proc {}, start pre compute , cid = {}, epoch = {}", this.topology.getStaticConf().getProcessId(), cid, epoch.getTimestamp());
BatchAppResult appHashResult = defaultExecutor.preComputeHash(cid,
commands.toArray(new byte[commands.size()][]), epoch.getProposeTimestamp());
......
......@@ -576,6 +576,7 @@ public final class ExecutionManager {
DefaultRecoverable defaultRecoverable = getAcceptor().getDefaultExecutor();
if (e != null) {
LOGGER.info("I am proc {}, pre compute rollback occur!, cid = {}, epoch = {}", topology.getStaticConf().getProcessId(), cons.getId(), e.getTimestamp());
defaultRecoverable.preComputeRollback(cons.getId(), e.getBatchId());
cons.setPrecomputed(false);
}
......
......@@ -374,6 +374,8 @@ public abstract class DefaultRecoverable implements Recoverable, PreComputeBatch
if (commands == null || msgCtx == null || msgCtx[0].isNoOp()) {
continue;
}
LOGGER.info("I am proc {}, will do appExecuteBatch, cid = {}", controller.getStaticConf().getProcessId(), cid);
appExecuteBatch(commands, msgCtx, false);
// add replay message batch to disk file
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册