MCPcopy Create free account
hub / github.com/XTXMarkets/ternfs / proccessLogReadResponse

Method proccessLogReadResponse

cpp/core/LogsDB.cpp:1316–1339  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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;

Callers 1

Calls 3

cleanupRequestsMethod · 0.80
writeLogEntryMethod · 0.80
sizeMethod · 0.45

Tested by

no test coverage detected