# HG changeset patch # User Pierre-Yves David # Date 2021-07-04 00:13:53 # Node ID ccbabaee5c3689c825978d85efdb078f6471e0f6 # Parent f5b8f0b9c1291a11003ba9a19bab44233d6299b2 dirstate-entry: add a `need_delay` method This abstract the internal processing need for entry that would have an ambiguous mtime (If I understand things correctly). Differential Revision: https://phab.mercurial-scm.org/D10974 diff --git a/mercurial/cext/parsers.c b/mercurial/cext/parsers.c --- a/mercurial/cext/parsers.c +++ b/mercurial/cext/parsers.c @@ -141,6 +141,20 @@ static PyObject *dirstatetuple_v1_mtime( return PyInt_FromLong(self->mtime); }; +static PyObject *dirstatetuple_need_delay(dirstateTupleObject *self, + PyObject *value) +{ + long now; + if (!pylong_to_long(value, &now)) { + return NULL; + } + if (self->state == 'n' && self->mtime == now) { + Py_RETURN_TRUE; + } else { + Py_RETURN_FALSE; + } +}; + static PyMethodDef dirstatetuple_methods[] = { {"v1_state", (PyCFunction)dirstatetuple_v1_state, METH_NOARGS, "return a \"state\" suitable for v1 serialization"}, @@ -150,6 +164,8 @@ static PyMethodDef dirstatetuple_methods "return a \"size\" suitable for v1 serialization"}, {"v1_mtime", (PyCFunction)dirstatetuple_v1_mtime, METH_NOARGS, "return a \"mtime\" suitable for v1 serialization"}, + {"need_delay", (PyCFunction)dirstatetuple_need_delay, METH_O, + "True if the stored mtime would be ambiguous with the current time"}, {NULL} /* Sentinel */ }; diff --git a/mercurial/dirstate.py b/mercurial/dirstate.py --- a/mercurial/dirstate.py +++ b/mercurial/dirstate.py @@ -754,7 +754,7 @@ class dirstate(object): if delaywrite > 0: # do we have any files to delay for? for f, e in pycompat.iteritems(self._map): - if e.state == b'n' and e[3] == now: + if e.need_delay(now): import time # to avoid useless import # rather than sleep n seconds, sleep until the next diff --git a/mercurial/pure/parsers.py b/mercurial/pure/parsers.py --- a/mercurial/pure/parsers.py +++ b/mercurial/pure/parsers.py @@ -153,6 +153,10 @@ class dirstatetuple(object): """return a "mtime" suitable for v1 serialization""" return self._mtime + def need_delay(self, now): + """True if the stored mtime would be ambiguous with the current time""" + return self._state == b'n' and self._mtime == now + def gettype(q): return int(q & 0xFFFF)