upstream/mercurial-mirror Files · contrib/lock-checker.py

revsetbenchmark: automatically finds the perf extension...

revsetbenchmark: automatically finds the perf extension Before this changeset, you had to stand in the root of the mercurial repo to run the `revsetbenchmark.py` script. Otherwise, the perf extension would not be found a `./contrib/perf.py` and the script would crash in panic. We now figure out the contrib directory from the location of this script. This makes it possible to run the script from other location that the mercurial repo root (but you still need to be in the core mercurial repository)

Mads Kiilerich - - Load All Authors

File last commit:

r20244:47d08436 default


                r21548:651d7548

default

Download file

             lock-checker.py
        
                    39 lines
            
             | 1.3 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / contrib / lock-checker.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      """Extension to verify locks are obtained in the required places.

      This works by wrapping functions that should be surrounded by a lock

      and asserting the lock is held. Missing locks are called out with a

      traceback printed to stderr.

      This currently only checks store locks, not working copy locks.

      """

      import os

      from mercurial import util

      def _checklock(repo):

          l = repo._lockref and repo._lockref()

          if l is None or not l.held:

              util.debugstacktrace('missing lock', skip=1)

      def reposetup(ui, repo):

          orig = repo.__class__

          class lockcheckrepo(repo.__class__):

              def _writejournal(self, *args, **kwargs):

                  _checklock(self)

                  return orig._writejournal(self, *args, **kwargs)

              def transaction(self, *args, **kwargs):

                  _checklock(self)

                  return orig.transaction(self, *args, **kwargs)

              # TODO(durin42): kiilerix had a commented-out lock check in

              # _writebranchcache and _writerequirements

              def _tag(self, *args, **kwargs):

                  _checklock(self)

                  return orig._tag(self, *args, **kwargs)

              def write(self, *args, **kwargs):

                  assert os.path.lexists(self._join('.hg/wlock'))

                  return orig.write(self, *args, **kwargs)

          repo.__class__ = lockcheckrepo

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				"""Extension to verify locks are obtained in the required places.

				This works by wrapping functions that should be surrounded by a lock
				and asserting the lock is held. Missing locks are called out with a
				traceback printed to stderr.

				This currently only checks store locks, not working copy locks.
				"""
				import os
				from mercurial import util

				def _checklock(repo):
				l = repo._lockref and repo._lockref()
				if l is None or not l.held:
				util.debugstacktrace('missing lock', skip=1)

				def reposetup(ui, repo):
				orig = repo.__class__
				class lockcheckrepo(repo.__class__):
				def _writejournal(self, args, *kwargs):
				_checklock(self)
				return orig._writejournal(self, args, *kwargs)

				def transaction(self, args, *kwargs):
				_checklock(self)
				return orig.transaction(self, args, *kwargs)

				# TODO(durin42): kiilerix had a commented-out lock check in
				# _writebranchcache and _writerequirements

				def _tag(self, args, *kwargs):
				_checklock(self)
				return orig._tag(self, args, *kwargs)

				def write(self, args, *kwargs):
				assert os.path.lexists(self._join('.hg/wlock'))
				return orig.write(self, args, *kwargs)

				repo.__class__ = lockcheckrepo