forked from platypush/platypush
Made get_plugin lock reentrant
This commit is contained in:
parent
19eab381ae
commit
35292968ed
1 changed files with 2 additions and 2 deletions
|
@ -2,7 +2,7 @@ import asyncio
|
||||||
import importlib
|
import importlib
|
||||||
import logging
|
import logging
|
||||||
|
|
||||||
from threading import Lock
|
from threading import RLock
|
||||||
|
|
||||||
from ..config import Config
|
from ..config import Config
|
||||||
|
|
||||||
|
@ -73,7 +73,7 @@ def get_plugin(plugin_name, reload=False):
|
||||||
global plugins_init_locks
|
global plugins_init_locks
|
||||||
|
|
||||||
if plugin_name not in plugins_init_locks:
|
if plugin_name not in plugins_init_locks:
|
||||||
plugins_init_locks[plugin_name] = Lock()
|
plugins_init_locks[plugin_name] = RLock()
|
||||||
|
|
||||||
if plugin_name in plugins and not reload:
|
if plugin_name in plugins and not reload:
|
||||||
return plugins[plugin_name]
|
return plugins[plugin_name]
|
||||||
|
|
Loading…
Reference in a new issue