| 626 | v); // ... and then we erase that previous version and all prior versions |
| 627 | } |
| 628 | void TLogQueue::updateVersionSizes(const TLogQueueEntry& result, TLogData* tLog) { |
| 629 | auto it = tLog->id_data.find(result.id); |
| 630 | if (it != tLog->id_data.end()) { |
| 631 | it->second->versionLocation[result.version] = queue->getNextReadLocation(); |
| 632 | } |
| 633 | } |
| 634 | |
| 635 | ACTOR Future<Void> tLogLock(TLogData* self, ReplyPromise<TLogLockResult> reply, Reference<LogData> logData) { |
| 636 | state Version stopVersion = logData->version.get(); |
no test coverage detected