| 1213 | } |
| 1214 | |
| 1215 | void writeBatch() { |
| 1216 | if (_token == LeaderToken(0,0)) { |
| 1217 | return; |
| 1218 | } |
| 1219 | auto response = _leaderElection.writeLogEntries(_token, _lastReleased, _entries); |
| 1220 | for (auto req : _requests) { |
| 1221 | auto& resp = _reqResp.newResponse(req->replicaId, req->msg.id); |
| 1222 | auto& writeResponse = resp.msg.body.setLogWrite(); |
| 1223 | writeResponse.result = response; |
| 1224 | } |
| 1225 | _requests.clear(); |
| 1226 | _entries.clear(); |
| 1227 | _lastReleased = 0; |
| 1228 | _token = LeaderToken(0,0); |
| 1229 | } |
| 1230 | |
| 1231 | private: |
| 1232 | Env& _env; |
no test coverage detected