localrepo: add hook point to invalidate everything on each command-server run
authorYuya Nishihara <yuya@tcha.org>
Mon, 03 Mar 2014 19:41:23 +0900
changeset 20627 a42ea6d209e6
parent 20625 7cbc6e228999
child 20628 e3d1df48fcc6
localrepo: add hook point to invalidate everything on each command-server run MQ extension will wrap this function to invalidate its state. repo.invalidate cannot be wrapped for this purpose because qpush obtains repo.lock in the middle of the operation, triggering repo.invalidate. Also, it seems wrong to obtain lock earlier because mq data is non-store parts.
mercurial/commandserver.py
mercurial/localrepo.py
--- a/mercurial/commandserver.py	Sat Mar 01 20:08:41 2014 -0600
+++ b/mercurial/commandserver.py	Mon Mar 03 19:41:23 2014 +0900
@@ -188,8 +188,7 @@
         repoui = self.repoui.__class__(self.repoui)
         repoui.copy = copiedui.copy # redo copy protection
         self.repo.ui = self.repo.dirstate._ui = repoui
-        self.repo.invalidate()
-        self.repo.invalidatedirstate()
+        self.repo.invalidateall()
 
         req = dispatch.request(args[:], copiedui, self.repo, self.cin,
                                self.cout, self.cerr)
--- a/mercurial/localrepo.py	Sat Mar 01 20:08:41 2014 -0600
+++ b/mercurial/localrepo.py	Mon Mar 03 19:41:23 2014 +0900
@@ -993,6 +993,13 @@
                 pass
         self.invalidatecaches()
 
+    def invalidateall(self):
+        '''Fully invalidates both store and non-store parts, causing the
+        subsequent operation to reread any outside changes.'''
+        # extension should hook this to invalidate its caches
+        self.invalidate()
+        self.invalidatedirstate()
+
     def _lock(self, vfs, lockname, wait, releasefn, acquirefn, desc):
         try:
             l = lockmod.lock(vfs, lockname, 0, releasefn, desc=desc)