Method handle_error

src/borg/remote.py:765–815

(unpacked)

            return msgid

        def handle_error(unpacked):
            if "exception_class" not in unpacked:
                return

            error = unpacked["exception_class"]
            args = unpacked["exception_args"]

            if error == "Error":
                raise Error(args[0])
            elif error == "ErrorWithTraceback":
                raise ErrorWithTraceback(args[0])
            elif error == "InvalidRepository":
                raise Repository.InvalidRepository(self.location.processed)
            elif error == "DoesNotExist":
                raise Repository.DoesNotExist(self.location.processed)
            elif error == "AlreadyExists":
                raise Repository.AlreadyExists(self.location.processed)
            elif error == "CheckNeeded":
                raise Repository.CheckNeeded(self.location.processed)
            elif error == "IntegrityError":
                raise IntegrityError(args[0])
            elif error == "PathNotAllowed":
                raise PathNotAllowed(args[0])
            elif error == "PathPermissionDenied":
                raise Repository.PathPermissionDenied(args[0])
            elif error == "PathAlreadyExists":
                raise Repository.PathAlreadyExists(args[0])
            elif error == "ParentPathDoesNotExist":
                raise Repository.ParentPathDoesNotExist(args[0])
            elif error == "ObjectNotFound":
                raise Repository.ObjectNotFound(args[0], self.location.processed)
            elif error == "StoreObjectNotFound":
                raise StoreObjectNotFound(args[0])
            elif error == "InvalidRPCMethod":
                raise InvalidRPCMethod(args[0])
            elif error == "LockTimeout":
                raise LockTimeout(args[0])
            elif error == "LockFailed":
                raise LockFailed(args[0], args[1])
            elif error == "NotLocked":
                raise NotLocked(args[0])
            elif error == "NotMyLock":
                raise NotMyLock(args[0])
            elif error == "NoManifestError":
                raise NoManifestError
            elif error == "InsufficientFreeSpaceError":
                raise Repository.InsufficientFreeSpaceError(args[0], args[1])
            elif error == "InvalidRepositoryConfig":
                raise Repository.InvalidRepositoryConfig(self.location.processed, args[1])
            else:
                raise self.RPCError(unpacked)

        calls = list(calls)
        waiting_for = []