()
| 180 | } |
| 181 | |
| 182 | private void trySendAddLog() { |
| 183 | while (leftSendAddLogCount > 0 && sendingSerials.size() < concurrentSendCount) { |
| 184 | int leaderId = getLeaderId(); |
| 185 | if (leaderId < 0) |
| 186 | return; |
| 187 | leftSendAddLogCount--; |
| 188 | sendingSerials.add(++serialCounter); |
| 189 | envs[leaderId].sendEvent(leaderId, new Raft.AddLog(serialCounter, new Raft.Log(serialCounter))); |
| 190 | } |
| 191 | } |
| 192 | |
| 193 | private void runRaftServer(int time) { |
| 194 | for (long endTime = curTime + time; curTime < endTime; curTime += 1) { |
no test coverage detected