MCPcopy Create free account
hub / github.com/e2wugui/zeze / releaseLeader

Method releaseLeader

ZezeJava/ZezeJavaTest/src/SimpleRaft/Raft.java:267–274  ·  view source on GitHub ↗
(int leaderId)

Source from the content-addressed store, hash-verified

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) {

Callers 1

onProcessMethod · 0.95

Calls 4

isEmptyMethod · 0.65
valuesMethod · 0.65
sendClientEventMethod · 0.65
clearMethod · 0.65

Tested by

no test coverage detected