comparison mercurial/lock.py @ 26383:0fceb34806e1

lock: add a wrapper to os.getpid() to make testing easier

This will allow us to fake locks across processes more easily.

26382:b673e89affc9

        self.desc = desc
        self.parentlock = parentlock
        self._parentheld = False
        self._inherited = False
        self.postrelease  = []
        self.pid = os.getpid()
        self.delay = self.lock()
        if self.acquirefn:
            self.acquirefn()

    def __del__(self):

            # ensure the lock will be removed
            # even if recursive locking did occur
            self.held = 1

        self.release()

    def lock(self):
        timeout = self.timeout
        while True:
            try:

        delayed to the last release call."""
        if self.held > 1:
            self.held -= 1
        elif self.held == 1:
            self.held = 0
            if os.getpid() != self.pid:
                # we forked, and are not the parent
                return
            try:
                if self.releasefn:
                    self.releasefn()

26383:0fceb34806e1

        self.desc = desc
        self.parentlock = parentlock
        self._parentheld = False
        self._inherited = False
        self.postrelease  = []
        self.pid = self._getpid()
        self.delay = self.lock()
        if self.acquirefn:
            self.acquirefn()

    def __del__(self):

            # ensure the lock will be removed
            # even if recursive locking did occur
            self.held = 1

        self.release()

    def _getpid(self):
        # wrapper around os.getpid() to make testing easier
        return os.getpid()

    def lock(self):
        timeout = self.timeout
        while True:
            try:

        delayed to the last release call."""
        if self.held > 1:
            self.held -= 1
        elif self.held == 1:
            self.held = 0
            if self._getpid() != self.pid:
                # we forked, and are not the parent
                return
            try:
                if self.releasefn:
                    self.releasefn()