(GetLeader r)
| 870 | } |
| 871 | |
| 872 | private long processGetLeader(GetLeader r) { |
| 873 | // see Server::trySendLeaderIs |
| 874 | String leaderId = getLeaderId(); |
| 875 | if (leaderId == null || leaderId.isEmpty()) |
| 876 | return Procedure.Unknown; |
| 877 | |
| 878 | if (getName().equals(leaderId) && !isLeader()) |
| 879 | return Procedure.Unknown; |
| 880 | |
| 881 | // redirect |
| 882 | r.Result.setTerm(getLogSequence().getTerm()); |
| 883 | r.Result.setLeaderId(leaderId); // maybe empty |
| 884 | r.Result.setLeader(isLeader()); |
| 885 | r.trySendResultCode(Procedure.Success); |
| 886 | return 0; |
| 887 | } |
| 888 | |
| 889 | private long processStartServer(StartServerConnector r) { |
| 890 | server.getConfig().forEachConnector(Connector::stop); |
nothing calls this directly
no test coverage detected