| pulkit |
| hg-reviewers |
After a clone we want to update most cachem, but not exactly all of them. We
can now cleanly express this.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/hg.py (3 lines) | |||
| M | mercurial/interfaces/repository.py (5 lines) | |||
| M | mercurial/localrepo.py (3 lines) |
| statichttprepo, | statichttprepo, | ||||
| ui as uimod, | ui as uimod, | ||||
| unionrepo, | unionrepo, | ||||
| url, | url, | ||||
| util, | util, | ||||
| verify as verifymod, | verify as verifymod, | ||||
| vfs as vfsmod, | vfs as vfsmod, | ||||
| ) | ) | ||||
| from .interfaces import repository as repositorymod | |||||
| from .utils import ( | from .utils import ( | ||||
| hashutil, | hashutil, | ||||
| stringutil, | stringutil, | ||||
| urlutil, | urlutil, | ||||
| ) | ) | ||||
| release = lock.release | release = lock.release | ||||
| bookmarks.activate(destrepo, update) | bookmarks.activate(destrepo, update) | ||||
| if destlock is not None: | if destlock is not None: | ||||
| release(destlock) | release(destlock) | ||||
| # here is a tiny windows were someone could end up writing the | # here is a tiny windows were someone could end up writing the | ||||
| # repository before the cache are sure to be warm. This is "fine" | # repository before the cache are sure to be warm. This is "fine" | ||||
| # as the only "bad" outcome would be some slowness. That potential | # as the only "bad" outcome would be some slowness. That potential | ||||
| # slowness already affect reader. | # slowness already affect reader. | ||||
| with destrepo.lock(): | with destrepo.lock(): | ||||
| destrepo.updatecaches(full=b"post-clone") | destrepo.updatecaches(caches=repositorymod.CACHES_POST_CLONE) | ||||
| finally: | finally: | ||||
| release(srclock, destlock) | release(srclock, destlock) | ||||
| if cleandir is not None: | if cleandir is not None: | ||||
| shutil.rmtree(cleandir, True) | shutil.rmtree(cleandir, True) | ||||
| if srcpeer is not None: | if srcpeer is not None: | ||||
| srcpeer.close() | srcpeer.close() | ||||
| if destpeer and destpeer.local() is None: | if destpeer and destpeer.local() is None: | ||||
| destpeer.close() | destpeer.close() | ||||
| CACHE_CHANGELOG_CACHE, | CACHE_CHANGELOG_CACHE, | ||||
| CACHE_FILE_NODE_TAGS, | CACHE_FILE_NODE_TAGS, | ||||
| CACHE_FULL_MANIFEST, | CACHE_FULL_MANIFEST, | ||||
| CACHE_MANIFESTLOG_CACHE, | CACHE_MANIFESTLOG_CACHE, | ||||
| CACHE_TAGS_DEFAULT, | CACHE_TAGS_DEFAULT, | ||||
| CACHE_TAGS_SERVED, | CACHE_TAGS_SERVED, | ||||
| } | } | ||||
| # the cache to warm by default on simple call | |||||
| # (this is a mutable set to let extension update it) | |||||
| CACHES_POST_CLONE = CACHES_ALL.copy() | |||||
| CACHES_POST_CLONE.discard(CACHE_FILE_NODE_TAGS) | |||||
| class ipeerconnection(interfaceutil.Interface): | class ipeerconnection(interfaceutil.Interface): | ||||
| """Represents a "connection" to a repository. | """Represents a "connection" to a repository. | ||||
| This is the base interface for representing a connection to a repository. | This is the base interface for representing a connection to a repository. | ||||
| It holds basic properties and methods applicable to all peer types. | It holds basic properties and methods applicable to all peer types. | ||||
| This is not a complete interface definition and should not be used | This is not a complete interface definition and should not be used | ||||
| return | return | ||||
| unfi = self.unfiltered() | unfi = self.unfiltered() | ||||
| if caches is None: | 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 = repository.CACHES_POST_CLONE | ||||
| 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() | ||||