| 1314 | } |
| 1315 | |
| 1316 | void proccessLogReadResponse(ReplicaId fromReplicaId, LogsDBRequest& request, const LogReadResp& response) { |
| 1317 | if (response.result != TernError::NO_ERROR) { |
| 1318 | return; |
| 1319 | } |
| 1320 | |
| 1321 | auto idx = request.msg.body.getLogRead().idx; |
| 1322 | |
| 1323 | size_t i = 0; |
| 1324 | for (; i < _missingEntries.size(); ++i) { |
| 1325 | if (_missingEntries[i] == idx) { |
| 1326 | _missingEntries[i] = 0; |
| 1327 | break; |
| 1328 | } |
| 1329 | } |
| 1330 | |
| 1331 | if (i == _missingEntries.size()) { |
| 1332 | return; |
| 1333 | } |
| 1334 | _reqResp.cleanupRequests(_requestIds[i]); |
| 1335 | LogsDBLogEntry entry; |
| 1336 | entry.idx = idx; |
| 1337 | entry.value = response.value.els; |
| 1338 | _data.writeLogEntry(entry); |
| 1339 | } |
| 1340 | |
| 1341 | LogIdx lastRead() const { |
| 1342 | return _lastRead; |
no test coverage detected