Method Lock

tsdb/tsdbutil/dir_locker.go:69–88

Lock obtains the lock on the locker directory.

()

// Lock obtains the lock on the locker directory.
func (l *DirLocker) Lock() error {
	if l.releaser != nil {
		return errors.New("DB lock already obtained")
	}

	if _, err := os.Stat(l.path); err == nil {
		l.logger.Warn("A lockfile from a previous execution already existed. It was replaced", "file", l.path)

		l.createdCleanly.Set(lockfileReplaced)
	} else {
		l.createdCleanly.Set(lockfileCreatedCleanly)
	}

	lockf, _, err := fileutil.Flock(l.path)
	if err != nil {
		return fmt.Errorf("lock DB directory: %w", err)
	}
	l.releaser = lockf
	return nil
}

// Release releases the lock. No-op if the lock is not held.
func (l *DirLocker) Release() error {