commitTransaction method

Future<int> commitTransaction(
  1. int txnId,
  2. int tableId
)

Implementation

Future<int> commitTransaction(int txnId, int tableId) async {
  final lsn = await append((lsn, prev) => WalBinRecord(
    lsn: lsn, txnId: txnId, prevLsn: prev,
    op: WalBinOp.commit, flags: 0, tableId: tableId, rowId: 0,
  ));
  _txnLastLsn.remove(txnId);
  _currentTxnId = 0;
  return lsn;
}