| 1722 | } |
| 1723 | |
| 1724 | func (db *DB) applySyncResult(state *syncState, result syncResult) { |
| 1725 | state.lastSyncedWALOffset = result.newWALSize |
| 1726 | state.syncedToWALEnd = result.syncedToWALEnd |
| 1727 | if result.pos != nil { |
| 1728 | db.pos.Lock() |
| 1729 | db.pos.value = result.pos |
| 1730 | db.pos.Unlock() |
| 1731 | } |
| 1732 | if result.l0FileInfo != nil { |
| 1733 | db.maxLTXFileInfos.Lock() |
| 1734 | db.maxLTXFileInfos.m[0] = result.l0FileInfo |
| 1735 | db.maxLTXFileInfos.Unlock() |
| 1736 | } |
| 1737 | } |
| 1738 | |
| 1739 | func (db *DB) newSyncExecutor(ctx context.Context) (*syncExecutor, error) { |
| 1740 | db.mu.Lock() |