| Alphare |
| hg-reviewers |
With share-safe, we will also write file in the store, so we take the store
lock before writing requirements.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | hgext/lfs/__init__.py (39 lines) |
| repo.svfs.options[b'lfstrack'] = _trackedmatcher(self) | repo.svfs.options[b'lfstrack'] = _trackedmatcher(self) | ||||
| return super(lfsrepo, self).commitctx(ctx, error, origctx=origctx) | return super(lfsrepo, self).commitctx(ctx, error, origctx=origctx) | ||||
| repo.__class__ = lfsrepo | repo.__class__ = lfsrepo | ||||
| if b'lfs' not in repo.requirements: | if b'lfs' not in repo.requirements: | ||||
| def checkrequireslfs(ui, repo, **kwargs): | def checkrequireslfs(ui, repo, **kwargs): | ||||
| with repo.lock(): | |||||
| if b'lfs' in repo.requirements: | if b'lfs' in repo.requirements: | ||||
| return 0 | return 0 | ||||
| last = kwargs.get('node_last') | last = kwargs.get('node_last') | ||||
| if last: | if last: | ||||
| s = repo.set(b'%n:%n', bin(kwargs['node']), bin(last)) | s = repo.set(b'%n:%n', bin(kwargs['node']), bin(last)) | ||||
| else: | else: | ||||
| s = repo.set(b'%n', bin(kwargs['node'])) | s = repo.set(b'%n', bin(kwargs['node'])) | ||||
| match = repo._storenarrowmatch | match = repo._storenarrowmatch | ||||
| for ctx in s: | for ctx in s: | ||||
| # TODO: is there a way to just walk the files in the commit? | # TODO: is there a way to just walk the files in the commit? | ||||
| if any( | if any( | ||||
| ctx[f].islfs() for f in ctx.files() if f in ctx and match(f) | ctx[f].islfs() | ||||
| for f in ctx.files() | |||||
| if f in ctx and match(f) | |||||
| ): | ): | ||||
| repo.requirements.add(b'lfs') | repo.requirements.add(b'lfs') | ||||
| repo.features.add(repository.REPO_FEATURE_LFS) | repo.features.add(repository.REPO_FEATURE_LFS) | ||||
| scmutil.writereporequirements(repo) | scmutil.writereporequirements(repo) | ||||
| repo.prepushoutgoinghooks.add(b'lfs', wrapper.prepush) | repo.prepushoutgoinghooks.add(b'lfs', wrapper.prepush) | ||||
| break | break | ||||
| ui.setconfig(b'hooks', b'commit.lfs', checkrequireslfs, b'lfs') | ui.setconfig(b'hooks', b'commit.lfs', checkrequireslfs, b'lfs') | ||||
| ui.setconfig( | ui.setconfig( | ||||
| b'hooks', b'pretxnchangegroup.lfs', checkrequireslfs, b'lfs' | b'hooks', b'pretxnchangegroup.lfs', checkrequireslfs, b'lfs' | ||||
| ) | ) | ||||
| else: | else: | ||||
| repo.prepushoutgoinghooks.add(b'lfs', wrapper.prepush) | repo.prepushoutgoinghooks.add(b'lfs', wrapper.prepush) | ||||