amorfo77/restic
1
0
Fork 0
mirror of https://github.com/restic/restic.git synced 2026-06-19 23:24:18 +00:00
Code Issues Projects Releases Wiki Activity

repository: comment cleanups

Browse Source
This commit is contained in:
Michael Eischer
2026-06-08 21:47:56 +02:00
parent 151903d4d4
commit 1a6d43286a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/repository/lock.go
+3 -3
View File
@@ -48,12 +48,12 @@ var lockerInst = &locker{
refreshabilityTimeout: staleLockTimeout - defaultRefreshInterval*3/2,
}
// LockRepo acquires a repository lock. The returned context is cancelled when
// Unlock is called; cancelling the original context stops lock refresh.
func LockRepo(ctx context.Context, repo *Repository, exclusive bool, retryLock time.Duration, printRetry func(msg string), logger func(format string, args ...interface{})) (Unlocker, context.Context, error) {
return lockerInst.Lock(ctx, repo, exclusive, retryLock, printRetry, logger)
}
// Lock wraps the ctx such that it is cancelled when the repository is unlocked
// cancelling the original context also stops the lock refresh
func (l *locker) Lock(ctx context.Context, r *Repository, exclusive bool, retryLock time.Duration, printRetry func(msg string), logger func(format string, args ...interface{})) (*unlocker, context.Context, error) {
var lock *lockHandle
var err error
@@ -158,7 +158,7 @@ func (l *locker) refreshLocks(ctx context.Context, backend backend.Backend, unlo
debug.Log("trying to refresh stale lock")
// keep on going if our current lock still exists
success := tryRefreshStaleLock(ctx, backend, lock, unlocker.cancel, logger)
// inform refresh goroutine about forced refresh
// inform monitor goroutine about forced refresh
select {
case <-ctx.Done():
case req.result <- success: