( lockDir: string, purpose: string, leaseMs: number, now: number, )
| 125 | } |
| 126 | |
| 127 | function tryAcquireGuard( |
| 128 | lockDir: string, |
| 129 | purpose: string, |
| 130 | leaseMs: number, |
| 131 | now: number, |
| 132 | ): AcquiredFsLockSync | null { |
| 133 | const guardDir = guardDirForLockDir(lockDir); |
| 134 | const guardOwner: FsLockOwner = { |
| 135 | token: randomUUID(), |
| 136 | pid: process.pid, |
| 137 | purpose: `${purpose}:guard`, |
| 138 | acquiredAtMs: now, |
| 139 | expiresAtMs: now + leaseMs, |
| 140 | }; |
| 141 | |
| 142 | try { |
| 143 | return createLock(guardDir, guardOwner); |
| 144 | } catch (error) { |
| 145 | if ((error as NodeJS.ErrnoException).code !== 'EEXIST') { |
| 146 | return null; |
| 147 | } |
| 148 | if (!tryRecoverExpiredLockDir(guardDir, guardOwner.purpose, now, leaseMs)) { |
| 149 | return null; |
| 150 | } |
| 151 | try { |
| 152 | return createLock(guardDir, guardOwner); |
| 153 | } catch { |
| 154 | return null; |
| 155 | } |
| 156 | } |
| 157 | } |
| 158 | |
| 159 | export function tryAcquireFsLockSync( |
| 160 | options: TryAcquireFsLockSyncOptions, |
no test coverage detected