| 1299 | |
| 1300 | |
| 1301 | void proccessLogReadRequest(ReplicaId fromReplicaId, uint64_t requestId, const LogReadReq& request) { |
| 1302 | auto& response = _reqResp.newResponse(fromReplicaId, requestId); |
| 1303 | auto& readResponse = response.msg.body.setLogRead(); |
| 1304 | if (_metadata.getLastReleased() < request.idx) { |
| 1305 | readResponse.result = TernError::LOG_ENTRY_UNRELEASED; |
| 1306 | return; |
| 1307 | } |
| 1308 | LogsDBLogEntry entry; |
| 1309 | auto err =_data.readLogEntry(request.idx, entry); |
| 1310 | readResponse.result = err; |
| 1311 | if (err == TernError::NO_ERROR) { |
| 1312 | readResponse.value.els = entry.value; |
| 1313 | } |
| 1314 | } |
| 1315 | |
| 1316 | void proccessLogReadResponse(ReplicaId fromReplicaId, LogsDBRequest& request, const LogReadResp& response) { |
| 1317 | if (response.result != TernError::NO_ERROR) { |
no test coverage detected