| 726 | } |
| 727 | |
| 728 | void TLogQueue::updateVersionSizes(const TLogQueueEntry& result, |
| 729 | TLogData* tLog, |
| 730 | IDiskQueue::location start, |
| 731 | IDiskQueue::location end) { |
| 732 | auto it = tLog->id_data.find(result.id); |
| 733 | if (it != tLog->id_data.end()) { |
| 734 | it->second->versionLocation[result.version] = std::make_pair(start, end); |
| 735 | } |
| 736 | } |
| 737 | |
| 738 | ACTOR Future<Void> tLogLock(TLogData* self, ReplyPromise<TLogLockResult> reply, Reference<LogData> logData) { |
| 739 | state Version stopVersion = logData->version.get(); |