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

Method writeBatch

cpp/core/LogsDB.cpp:1215–1229  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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
1231private:
1232 Env& _env;

Callers 1

Calls 3

LeaderTokenClass · 0.70
writeLogEntriesMethod · 0.45
clearMethod · 0.45

Tested by

no test coverage detected