| pulkit |
| hg-reviewers |
| Lint Skipped |
| Unit Tests Skipped |
| Path | Packages | |||
|---|---|---|---|---|
| M | hgext/remotefilelog/shallowrepo.py (9 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| 2c0d313b0b66 | abd4783db5a7 | Augie Fackler | Jun 18 2019, 9:58 AM |
| fileserverclient, | fileserverclient, | ||||
| historypack, | historypack, | ||||
| metadatastore, | metadatastore, | ||||
| remotefilectx, | remotefilectx, | ||||
| remotefilelog, | remotefilelog, | ||||
| shallowutil, | shallowutil, | ||||
| ) | ) | ||||
| if util.safehasattr(util, '_hgexecutable'): | |||||
| # Before 5be286db | |||||
| _hgexecutable = util.hgexecutable | |||||
| else: | |||||
| from mercurial.utils import procutil | |||||
| _hgexecutable = procutil.hgexecutable | |||||
| # These make*stores functions are global so that other extensions can replace | # These make*stores functions are global so that other extensions can replace | ||||
| # them. | # them. | ||||
| def makelocalstores(repo): | def makelocalstores(repo): | ||||
| """In-repo stores, like .hg/store/data; can not be discarded.""" | """In-repo stores, like .hg/store/data; can not be discarded.""" | ||||
| localpath = os.path.join(repo.svfs.vfs.base, 'data') | localpath = os.path.join(repo.svfs.vfs.base, 'data') | ||||
| if not os.path.exists(localpath): | if not os.path.exists(localpath): | ||||
| os.makedirs(localpath) | os.makedirs(localpath) | ||||
| self.fileservice.prefetch(files) | self.fileservice.prefetch(files) | ||||
| return super(shallowrepository, self).commitctx(ctx, | return super(shallowrepository, self).commitctx(ctx, | ||||
| error=error) | error=error) | ||||
| def backgroundprefetch(self, revs, base=None, repack=False, pats=None, | def backgroundprefetch(self, revs, base=None, repack=False, pats=None, | ||||
| opts=None): | opts=None): | ||||
| """Runs prefetch in background with optional repack | """Runs prefetch in background with optional repack | ||||
| """ | """ | ||||
| cmd = [_hgexecutable(), '-R', repo.origroot, 'prefetch'] | cmd = [procutil.hgexecutable(), '-R', repo.origroot, 'prefetch'] | ||||
| if repack: | if repack: | ||||
| cmd.append('--repack') | cmd.append('--repack') | ||||
| if revs: | if revs: | ||||
| cmd += ['-r', revs] | cmd += ['-r', revs] | ||||
| procutil.runbgcommand(cmd, encoding.environ) | procutil.runbgcommand(cmd, encoding.environ) | ||||
| def prefetch(self, revs, base=None, pats=None, opts=None): | def prefetch(self, revs, base=None, pats=None, opts=None): | ||||
| """Prefetches all the necessary file revisions for the given revs | """Prefetches all the necessary file revisions for the given revs | ||||