| quark | |
| durin42 |
| hg-reviewers |
As part of separating the dirstate business logic from the dirstate storage
logic, let's move the serialization code down into dirstatemap.
| Lint Skipped |
| Unit Tests Skipped |
| # multiple of n seconds | # multiple of n seconds | ||||
| clock = time.time() | clock = time.time() | ||||
| start = int(clock) - (int(clock) % delaywrite) | start = int(clock) - (int(clock) % delaywrite) | ||||
| end = start + delaywrite | end = start + delaywrite | ||||
| time.sleep(end - clock) | time.sleep(end - clock) | ||||
| now = end # trust our estimate that the end is near now | now = end # trust our estimate that the end is near now | ||||
| break | break | ||||
| st.write(parsers.pack_dirstate(self._map._map, self._map.copymap, | self._map.write(st, now) | ||||
| self._pl, now)) | |||||
| self._nonnormalset, self._otherparentset = self._map.nonnormalentries() | self._nonnormalset, self._otherparentset = self._map.nonnormalentries() | ||||
| st.close() | |||||
| self._lastnormaltime = 0 | self._lastnormaltime = 0 | ||||
| self._dirty = self._map._dirtyparents = False | self._dirty = False | ||||
| def _dirignore(self, f): | def _dirignore(self, f): | ||||
| if f == '.': | if f == '.': | ||||
| return False | return False | ||||
| if self._ignore(f): | if self._ignore(f): | ||||
| return True | return True | ||||
| for p in util.finddirs(f): | for p in util.finddirs(f): | ||||
| if self._ignore(p): | if self._ignore(p): | ||||
| # this can get very expensive. As a workaround, disable GC while | # this can get very expensive. As a workaround, disable GC while | ||||
| # parsing the dirstate. | # parsing the dirstate. | ||||
| # | # | ||||
| # (we cannot decorate the function directly since it is in a C module) | # (we cannot decorate the function directly since it is in a C module) | ||||
| parse_dirstate = util.nogc(parsers.parse_dirstate) | parse_dirstate = util.nogc(parsers.parse_dirstate) | ||||
| p = parse_dirstate(self._map, self.copymap, st) | p = parse_dirstate(self._map, self.copymap, st) | ||||
| if not self._dirtyparents: | if not self._dirtyparents: | ||||
| self.setparents(*p) | self.setparents(*p) | ||||
| def write(self, st, now): | |||||
| st.write(parsers.pack_dirstate(self._map, self.copymap, | |||||
| self.parents(), now)) | |||||
| st.close() | |||||
| self._dirtyparents = False | |||||