| mbthomas | |
| krbullock |
| hg-reviewers |
We might as well get this out of the way.
| Lint Skipped |
| Unit Tests Skipped |
| Path | Packages | |||
|---|---|---|---|---|
| M | hgext/fsmonitor/__init__.py (17 lines) | |||
| M | hgext/fsmonitor/state.py (7 lines) |
| context, | context, | ||||
| encoding, | encoding, | ||||
| error, | error, | ||||
| extensions, | extensions, | ||||
| localrepo, | localrepo, | ||||
| merge, | merge, | ||||
| pathutil, | pathutil, | ||||
| pycompat, | pycompat, | ||||
| registrar, | |||||
| scmutil, | scmutil, | ||||
| util, | util, | ||||
| ) | ) | ||||
| from mercurial import match as matchmod | from mercurial import match as matchmod | ||||
| from . import ( | from . import ( | ||||
| pywatchman, | pywatchman, | ||||
| state, | state, | ||||
| watchmanclient, | watchmanclient, | ||||
| ) | ) | ||||
| # Note for extension authors: ONLY specify testedwith = 'ships-with-hg-core' for | # Note for extension authors: ONLY specify testedwith = 'ships-with-hg-core' for | ||||
| # extensions which SHIP WITH MERCURIAL. Non-mainline extensions should | # extensions which SHIP WITH MERCURIAL. Non-mainline extensions should | ||||
| # be specifying the version(s) of Mercurial they are tested with, or | # be specifying the version(s) of Mercurial they are tested with, or | ||||
| # leave the attribute unspecified. | # leave the attribute unspecified. | ||||
| testedwith = 'ships-with-hg-core' | testedwith = 'ships-with-hg-core' | ||||
| configtable = {} | |||||
| configitem = registrar.configitem(configtable) | |||||
| configitem('fsmonitor', 'mode', | |||||
| default='on', | |||||
| ) | |||||
| configitem('fsmonitor', 'walk_on_invalidate', | |||||
| default=False, | |||||
| ) | |||||
| configitem('fsmonitor', 'timeout', | |||||
| default='2', | |||||
| ) | |||||
| configitem('fsmonitor', 'blacklistusers', | |||||
| default=list, | |||||
| ) | |||||
| # This extension is incompatible with the following blacklisted extensions | # This extension is incompatible with the following blacklisted extensions | ||||
| # and will disable itself when encountering one of these: | # and will disable itself when encountering one of these: | ||||
| _blacklist = ['largefiles', 'eol'] | _blacklist = ['largefiles', 'eol'] | ||||
| def _handleunavailable(ui, state, ex): | def _handleunavailable(ui, state, ex): | ||||
| """Exception handler for Watchman interaction exceptions""" | """Exception handler for Watchman interaction exceptions""" | ||||
| if isinstance(ex, watchmanclient.Unavailable): | if isinstance(ex, watchmanclient.Unavailable): | ||||
| if ex.warn: | if ex.warn: | ||||
| class state(object): | class state(object): | ||||
| def __init__(self, repo): | def __init__(self, repo): | ||||
| self._vfs = repo.vfs | self._vfs = repo.vfs | ||||
| self._ui = repo.ui | self._ui = repo.ui | ||||
| self._rootdir = pathutil.normasprefix(repo.root) | self._rootdir = pathutil.normasprefix(repo.root) | ||||
| self._lastclock = None | self._lastclock = None | ||||
| self._identity = util.filestat(None) | self._identity = util.filestat(None) | ||||
| self.mode = self._ui.config('fsmonitor', 'mode', default='on') | self.mode = self._ui.config('fsmonitor', 'mode') | ||||
| self.walk_on_invalidate = self._ui.configbool( | self.walk_on_invalidate = self._ui.configbool( | ||||
| 'fsmonitor', 'walk_on_invalidate', False) | 'fsmonitor', 'walk_on_invalidate') | ||||
| self.timeout = float(self._ui.config( | self.timeout = float(self._ui.config('fsmonitor', 'timeout')) | ||||
| 'fsmonitor', 'timeout', default='2')) | |||||
| def get(self): | def get(self): | ||||
| try: | try: | ||||
| file = self._vfs('fsmonitor.state', 'rb') | file = self._vfs('fsmonitor.state', 'rb') | ||||
| except IOError as inst: | except IOError as inst: | ||||
| self._identity = util.filestat(None) | self._identity = util.filestat(None) | ||||
| if inst.errno != errno.ENOENT: | if inst.errno != errno.ENOENT: | ||||
| raise | raise | ||||