(int leaderId)
| 265 | } |
| 266 | |
| 267 | private void releaseLeader(int leaderId) { |
| 268 | this.leaderId = (byte)leaderId; |
| 269 | if (!appendingLogMap.isEmpty()) { |
| 270 | for (final Long serial : appendingLogMap.values()) // 切换leader时需要把客户端未完成的请求一一回复失败 |
| 271 | env.sendClientEvent(new AddLogRe(serial, -3, leaderId)); |
| 272 | appendingLogMap.clear(); |
| 273 | } |
| 274 | } |
| 275 | |
| 276 | private void onProcess(final @NotNull RequestVote req, final long curTime) { |
| 277 | if (currentTerm < req.term) { |
no test coverage detected