| pulkit |
| hg-reviewers |
It will superseed the full parameters (and its post-clone variant from
stable). Various caller will be updated in the rest of this series.
| No Linters Available |
| No Unit Test Coverage |
| def updater(tr): | def updater(tr): | ||||
| repo = reporef() | repo = reporef() | ||||
| assert repo is not None # help pytype | assert repo is not None # help pytype | ||||
| repo.updatecaches(tr) | repo.updatecaches(tr) | ||||
| return updater | return updater | ||||
| @unfilteredmethod | @unfilteredmethod | ||||
| def updatecaches(self, tr=None, full=False): | def updatecaches(self, tr=None, full=False, caches=None): | ||||
| """warm appropriate caches | """warm appropriate caches | ||||
| If this function is called after a transaction closed. The transaction | If this function is called after a transaction closed. The transaction | ||||
| will be available in the 'tr' argument. This can be used to selectively | will be available in the 'tr' argument. This can be used to selectively | ||||
| update caches relevant to the changes in that transaction. | update caches relevant to the changes in that transaction. | ||||
| If 'full' is set, make sure all caches the function knows about have | If 'full' is set, make sure all caches the function knows about have | ||||
| up-to-date data. Even the ones usually loaded more lazily. | up-to-date data. Even the ones usually loaded more lazily. | ||||
| The `full` argument can take a special "post-clone" value. In this case | The `full` argument can take a special "post-clone" value. In this case | ||||
| the cache warming is made after a clone and of the slower cache might | the cache warming is made after a clone and of the slower cache might | ||||
| be skipped, namely the `.fnodetags` one. This argument is 5.8 specific | be skipped, namely the `.fnodetags` one. This argument is 5.8 specific | ||||
| as we plan for a cleaner way to deal with this for 5.9. | as we plan for a cleaner way to deal with this for 5.9. | ||||
| """ | """ | ||||
| if tr is not None and tr.hookargs.get(b'source') == b'strip': | if tr is not None and tr.hookargs.get(b'source') == b'strip': | ||||
| # During strip, many caches are invalid but | # During strip, many caches are invalid but | ||||
| # later call to `destroyed` will refresh them. | # later call to `destroyed` will refresh them. | ||||
| return | return | ||||
| unfi = self.unfiltered() | unfi = self.unfiltered() | ||||
| if caches is None: | |||||
| if full: | if full: | ||||
| caches = repository.CACHES_ALL | caches = repository.CACHES_ALL | ||||
| if full == b"post-clone": | if full == b"post-clone": | ||||
| caches = caches.copy() | caches = caches.copy() | ||||
| caches.discard(repository.CACHE_FILE_NODE_TAGS) | caches.discard(repository.CACHE_FILE_NODE_TAGS) | ||||
| else: | else: | ||||
| caches = repository.CACHES_DEFAULT | caches = repository.CACHES_DEFAULT | ||||
| if repository.CACHE_BRANCHMAP_SERVED in caches: | if repository.CACHE_BRANCHMAP_SERVED in caches: | ||||
| if tr is None or tr.changes[b'origrepolen'] < len(self): | if tr is None or tr.changes[b'origrepolen'] < len(self): | ||||
| # accessing the 'served' branchmap should refresh all the others, | # accessing the 'served' branchmap should refresh all the others, | ||||
| self.ui.debug(b'updating the branch cache\n') | self.ui.debug(b'updating the branch cache\n') | ||||
| self.filtered(b'served').branchmap() | self.filtered(b'served').branchmap() | ||||
| self.filtered(b'served.hidden').branchmap() | self.filtered(b'served.hidden').branchmap() | ||||