(long id)
| 138 | } |
| 139 | |
| 140 | public void commit2(long id) { |
| 141 | var hotManager = connector.TryGetReadySocket(); |
| 142 | var r = new Commit2(); |
| 143 | r.Argument.setDistributeId(id); |
| 144 | r.SendForWait(hotManager).await(); |
| 145 | if (r.getResultCode() != 0) |
| 146 | throw new RuntimeException("commit2=" + IModule.getErrorCode(r.getResultCode())); |
| 147 | } |
| 148 | |
| 149 | public void tryRollback(long id) { |
| 150 | var hotManager = connector.TryGetReadySocket(); |
no test coverage detected