| indygreg | |
| Alphare |
| hg-reviewers |
The part of the code is huge, keeping it separated will keep the _loadindex
method simpler and help keeping logic well insulated.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/revlog.py (26 lines) |
| # 2-tuple of file handles being used for active writing. | # 2-tuple of file handles being used for active writing. | ||||
| self._writinghandles = None | self._writinghandles = None | ||||
| self._loadindex() | self._loadindex() | ||||
| self._concurrencychecker = concurrencychecker | self._concurrencychecker = concurrencychecker | ||||
| def _loadindex(self): | def _init_opts(self): | ||||
| """process options (from above/config) to setup associated default revlog mode | |||||
| These values might be affected when actually reading on disk information. | |||||
| The relevant values are returned for use in _loadindex(). | |||||
| * newversionflags: | |||||
| version header to use if we need to create a new revlog | |||||
| * mmapindexthreshold: | |||||
| minimal index size for start to use mmap | |||||
| * force_nodemap: | |||||
| force the usage of a "development" version of the nodemap code | |||||
| """ | |||||
| mmapindexthreshold = None | mmapindexthreshold = None | ||||
| opts = self.opener.options | opts = self.opener.options | ||||
| if b'revlogv2' in opts: | if b'revlogv2' in opts: | ||||
| newversionflags = REVLOGV2 | FLAG_INLINE_DATA | newversionflags = REVLOGV2 | FLAG_INLINE_DATA | ||||
| elif b'revlogv1' in opts: | elif b'revlogv1' in opts: | ||||
| newversionflags = REVLOGV1 | FLAG_INLINE_DATA | newversionflags = REVLOGV1 | FLAG_INLINE_DATA | ||||
| if b'generaldelta' in opts: | if b'generaldelta' in opts: | ||||
| _(b'revlog chunk cache size %r is not greater than 0') | _(b'revlog chunk cache size %r is not greater than 0') | ||||
| % self._chunkcachesize | % self._chunkcachesize | ||||
| ) | ) | ||||
| elif self._chunkcachesize & (self._chunkcachesize - 1): | elif self._chunkcachesize & (self._chunkcachesize - 1): | ||||
| raise error.RevlogError( | raise error.RevlogError( | ||||
| _(b'revlog chunk cache size %r is not a power of 2') | _(b'revlog chunk cache size %r is not a power of 2') | ||||
| % self._chunkcachesize | % self._chunkcachesize | ||||
| ) | ) | ||||
| force_nodemap = opts.get(b'devel-force-nodemap', False) | |||||
| return newversionflags, mmapindexthreshold, force_nodemap | |||||
| def _loadindex(self): | |||||
| newversionflags, mmapindexthreshold, force_nodemap = self._init_opts() | |||||
| indexdata = b'' | indexdata = b'' | ||||
| self._initempty = True | self._initempty = True | ||||
| try: | try: | ||||
| with self._indexfp() as f: | with self._indexfp() as f: | ||||
| if ( | if ( | ||||
| mmapindexthreshold is not None | mmapindexthreshold is not None | ||||
| and self.opener.fstat(f).st_size >= mmapindexthreshold | and self.opener.fstat(f).st_size >= mmapindexthreshold | ||||
| ): | ): | ||||
| # sparse-revlog can't be on without general-delta (issue6056) | # sparse-revlog can't be on without general-delta (issue6056) | ||||
| if not self._generaldelta: | if not self._generaldelta: | ||||
| self._sparserevlog = False | self._sparserevlog = False | ||||
| self._storedeltachains = True | self._storedeltachains = True | ||||
| devel_nodemap = ( | devel_nodemap = ( | ||||
| self.nodemap_file | self.nodemap_file | ||||
| and opts.get(b'devel-force-nodemap', False) | and force_nodemap | ||||
| and parse_index_v1_nodemap is not None | and parse_index_v1_nodemap is not None | ||||
| ) | ) | ||||
| use_rust_index = False | use_rust_index = False | ||||
| if rustrevlog is not None: | if rustrevlog is not None: | ||||
| if self.nodemap_file is not None: | if self.nodemap_file is not None: | ||||
| use_rust_index = True | use_rust_index = True | ||||
| else: | else: | ||||