(String host, int port, long tid, int rpcTimeout)
| 55 | } |
| 56 | |
| 57 | public BTransactionState.Data query(String host, int port, long tid, int rpcTimeout) { |
| 58 | var r = new Query(); |
| 59 | r.Argument.setTid(tid); |
| 60 | r.SendForWait(connect(host, port), rpcTimeout).await(); |
| 61 | if (r.getResultCode() != 0) |
| 62 | throw new RuntimeException("query state error=" + IModule.getErrorCode(r.getResultCode())); |
| 63 | return r.Result; |
| 64 | } |
| 65 | |
| 66 | public void commit(String host, int port, BPrepareBatches.Data batches, int rpcTimeout) { |
| 67 | var r = new Commit(); |
no test coverage detected