| 804 | } |
| 805 | |
| 806 | void TLogQueue::updateVersionSizes(const TLogQueueEntry& result, |
| 807 | TLogData* tLog, |
| 808 | IDiskQueue::location start, |
| 809 | IDiskQueue::location end) { |
| 810 | auto it = tLog->id_data.find(result.id); |
| 811 | if (it != tLog->id_data.end()) { |
| 812 | it->second->versionLocation[result.version] = std::make_pair(start, end); |
| 813 | } |
| 814 | } |
| 815 | |
| 816 | ACTOR Future<Void> tLogLock(TLogData* self, ReplyPromise<TLogLockResult> reply, Reference<LogData> logData) { |
| 817 | state Version stopVersion = logData->version.get(); |