
commit bae7d82c435b33a3484aaab98582a51d217528d4 Author: Illia Volochii <illia.volochii@gmail.com> Date: Wed Apr 15 22:10:09 2020 +0300 Make `Controller.get_pid` and `Controller.get_user` asynchronous --- stem/control.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/stem/control.py b/stem/control.py index 2b99fef5..88778a8e 100644 --- a/stem/control.py +++ b/stem/control.py @@ -1509,7 +1509,7 @@ class Controller(BaseController): return await stem.connection.get_protocolinfo(self) @with_default() - def get_user(self, default: Any = UNDEFINED) -> str: + async def get_user(self, default: Any = UNDEFINED) -> str: """ get_user(default = UNDEFINED) @@ -1529,10 +1529,10 @@ class Controller(BaseController): if user: return user - user = self.get_info('process/user', None) + user = await self.get_info('process/user', None) if not user and self.is_localhost(): - pid = self.get_pid(None) + pid = await self.get_pid(None) if pid: user = stem.util.system.user(pid) @@ -1544,7 +1544,7 @@ class Controller(BaseController): raise ValueError("Unable to resolve tor's user" if self.is_localhost() else "Tor isn't running locally") @with_default() - def get_pid(self, default: Any = UNDEFINED) -> int: + async def get_pid(self, default: Any = UNDEFINED) -> int: """ get_pid(default = UNDEFINED) @@ -1567,13 +1567,13 @@ class Controller(BaseController): if pid: return pid - getinfo_pid = self.get_info('process/pid', None) + getinfo_pid = await self.get_info('process/pid', None) if getinfo_pid and getinfo_pid.isdigit(): pid = int(getinfo_pid) if not pid and self.is_localhost(): - pid_file_path = self._get_conf_single('PidFile', None) + pid_file_path = await self._get_conf_single('PidFile', None) if pid_file_path is not None: with open(pid_file_path) as pid_file: