|
@@ -54,31 +54,31 @@ public class TransactionEngineImpl implements TransactionEngine { |
|
|
|
|
|
|
|
|
private class InnerTransactionBatchProcessor extends TransactionBatchProcessor { |
|
|
private class InnerTransactionBatchProcessor extends TransactionBatchProcessor { |
|
|
|
|
|
|
|
|
private HashDigest ledgerHash; |
|
|
|
|
|
|
|
|
// private HashDigest ledgerHash; |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* 创建交易批处理器; |
|
|
* 创建交易批处理器; |
|
|
* |
|
|
* |
|
|
* @param ledgerRepo 账本; |
|
|
* @param ledgerRepo 账本; |
|
|
* @param handlesRegisteration 操作处理对象注册表; |
|
|
* @param handlesRegisteration 操作处理对象注册表; |
|
|
* @param blockHeight |
|
|
|
|
|
|
|
|
* |
|
|
*/ |
|
|
*/ |
|
|
public InnerTransactionBatchProcessor(LedgerRepository ledgerRepo, |
|
|
public InnerTransactionBatchProcessor(LedgerRepository ledgerRepo, |
|
|
OperationHandleRegisteration handlesRegisteration) { |
|
|
OperationHandleRegisteration handlesRegisteration) { |
|
|
super(ledgerRepo, handlesRegisteration); |
|
|
super(ledgerRepo, handlesRegisteration); |
|
|
ledgerHash = ledgerRepo.getHash(); |
|
|
|
|
|
|
|
|
// ledgerHash = ledgerRepo.getHash(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
protected void onCommitted() { |
|
|
protected void onCommitted() { |
|
|
super.onCommitted(); |
|
|
super.onCommitted(); |
|
|
finishBatch(ledgerHash); |
|
|
|
|
|
|
|
|
finishBatch(getLedgerHash()); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
protected void onCanceled() { |
|
|
protected void onCanceled() { |
|
|
super.onCanceled(); |
|
|
super.onCanceled(); |
|
|
finishBatch(ledgerHash); |
|
|
|
|
|
|
|
|
finishBatch(getLedgerHash()); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|