comparison mercurial/dirstate.py @ 31050:206532700213

txnutil: factor out the logic to read file in according to HG_PENDING

This patch adds new file txnutil.py, because:

  - transaction.py is too large to import small utility logic
  - scmutil.py or so causes cyclic importing in phases.py

mayhavepending() is defined separately for convenience in subsequent
patch.

31049:20027be9f23d

    osutil,
    parsers,
    pathutil,
    pycompat,
    scmutil,
    util,
)

propertycache = util.propertycache
filecache = scmutil.filecache

    try:
        return parsers.nonnormalentries(dmap)
    except AttributeError:
        return set(fname for fname, e in dmap.iteritems()
                   if e[0] != 'n' or e[3] == -1)

def _trypending(root, vfs, filename):
    '''Open  file to be read according to HG_PENDING environment variable

    This opens '.pending' of specified 'filename' only when HG_PENDING
    is equal to 'root'.

    This returns '(fp, is_pending_opened)' tuple.
    '''
    if root == encoding.environ.get('HG_PENDING'):
        try:
            return (vfs('%s.pending' % filename), True)
        except IOError as inst:
            if inst.errno != errno.ENOENT:
                raise
    return (vfs(filename), False)

class dirstate(object):

    def __init__(self, opener, ui, root, validate):
        '''Create a new dirstate object.

        except: # re-raises
            f.discard()
            raise

    def _opendirstatefile(self):
        fp, mode = _trypending(self._root, self._opener, self._filename)
        if self._pendingmode is not None and self._pendingmode != mode:
            fp.close()
            raise error.Abort(_('working directory state may be '
                                'changed parallelly'))
        self._pendingmode = mode

31050:206532700213

    osutil,
    parsers,
    pathutil,
    pycompat,
    scmutil,
    txnutil,
    util,
)

propertycache = util.propertycache
filecache = scmutil.filecache

    try:
        return parsers.nonnormalentries(dmap)
    except AttributeError:
        return set(fname for fname, e in dmap.iteritems()
                   if e[0] != 'n' or e[3] == -1)

class dirstate(object):

    def __init__(self, opener, ui, root, validate):
        '''Create a new dirstate object.

        except: # re-raises
            f.discard()
            raise

    def _opendirstatefile(self):
        fp, mode = txnutil.trypending(self._root, self._opener, self._filename)
        if self._pendingmode is not None and self._pendingmode != mode:
            fp.close()
            raise error.Abort(_('working directory state may be '
                                'changed parallelly'))
        self._pendingmode = mode