resource_manager.py 文件源码

def session_remove_global_resources(self, scannable_id, resources):
        # Must be run in a transaction to avoid leaving invalid things in the DB on failure.
        assert transaction.is_managed()

        with self._instance_lock:
            session = self._sessions[scannable_id]
            resources = session._plugin_instance._index._local_id_to_resource.values()

            self._cull_lost_resources(session, resources)
            self._persist_lun_updates(scannable_id)