MCPcopy
hub / github.com/benbjohnson/litestream / applySyncResult

Method applySyncResult

db.go:1724–1737  ·  view source on GitHub ↗
(state *syncState, result syncResult)

Source from the content-addressed store, hash-verified

1722}
1723
1724func (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
1739func (db *DB) newSyncExecutor(ctx context.Context) (*syncExecutor, error) {
1740 db.mu.Lock()

Calls 2

LockMethod · 0.45
UnlockMethod · 0.45