34c4e47c9b
- Allow NamedLoaderContexts to be returned from loader - Revert the change making reactor less blocking (bsc#1230322) - Use --cachedir for extension_modules in salt-call (bsc#1226141) - Prevent using SyncWrapper with no reason - Added: * avoid-explicit-reading-of-etc-salt-minion-bsc-122035.patch * allow-namedloadercontexts-to-be-returned-from-loader.patch * revert-the-change-making-reactor-less-blocking-bsc-1.patch * use-cachedir-for-extension_modules-in-salt-call-bsc-.patch * prevent-using-syncwrapper-with-no-reason.patch OBS-URL: https://build.opensuse.org/package/show/systemsmanagement:saltstack/salt?expand=0&rev=259
54 lines
1.8 KiB
Diff
54 lines
1.8 KiB
Diff
From 42cfb51fa01e13fe043a62536ba37fd472bc2688 Mon Sep 17 00:00:00 2001
|
|
From: Victor Zhestkov <vzhestkov@suse.com>
|
|
Date: Tue, 12 Apr 2022 10:08:17 +0300
|
|
Subject: [PATCH] Fix regression with depending client.ssh on psutil
|
|
(bsc#1197533)
|
|
|
|
---
|
|
salt/client/ssh/__init__.py | 14 ++++++++++++--
|
|
1 file changed, 12 insertions(+), 2 deletions(-)
|
|
|
|
diff --git a/salt/client/ssh/__init__.py b/salt/client/ssh/__init__.py
|
|
index d5a679821e..b120e0002e 100644
|
|
--- a/salt/client/ssh/__init__.py
|
|
+++ b/salt/client/ssh/__init__.py
|
|
@@ -12,7 +12,6 @@ import hashlib
|
|
import logging
|
|
import multiprocessing
|
|
import os
|
|
-import psutil
|
|
import queue
|
|
import re
|
|
import shlex
|
|
@@ -420,6 +419,16 @@ class SSH(MultiprocessingStateMixin):
|
|
self.__parsed_rosters[self.ROSTER_UPDATE_FLAG] = False
|
|
return
|
|
|
|
+ def _pid_exists(self, pid):
|
|
+ """
|
|
+ Check if specified pid is alive
|
|
+ """
|
|
+ try:
|
|
+ os.kill(pid, 0)
|
|
+ except OSError:
|
|
+ return False
|
|
+ return True
|
|
+
|
|
def _update_roster(self, hostname=None, user=None):
|
|
"""
|
|
Update default flat roster with the passed in information.
|
|
@@ -639,7 +648,8 @@ class SSH(MultiprocessingStateMixin):
|
|
pid_running = (
|
|
False
|
|
if cached_session["pid"] == 0
|
|
- else cached_session.get("running", False) or psutil.pid_exists(cached_session["pid"])
|
|
+ else cached_session.get("running", False)
|
|
+ or self._pid_exists(cached_session["pid"])
|
|
)
|
|
if (
|
|
pid_running and prev_session_running < self.max_pid_wait
|
|
--
|
|
2.39.2
|
|
|
|
|