(long id)
| 147 | } |
| 148 | |
| 149 | public void tryRollback(long id) { |
| 150 | var hotManager = connector.TryGetReadySocket(); |
| 151 | var r = new TryRollback(); |
| 152 | r.Argument.setDistributeId(id); |
| 153 | r.SendForWait(hotManager).await(); |
| 154 | if (r.getResultCode() != 0) { |
| 155 | throw new RuntimeException("tryRollback=" + IModule.getErrorCode(r.getResultCode())); |
| 156 | } |
| 157 | } |
| 158 | |
| 159 | public void distribute(File distributeDir) throws Exception { |
| 160 | var files = distributeDir.listFiles(); |
no test coverage detected