Merge "Do not rely on ps to check the daemon"

This commit is contained in:
Zuul 2018-09-18 08:59:35 +00:00 committed by Gerrit Code Review
commit 8d837f04d2
2 changed files with 13 additions and 9 deletions

View File

@ -207,20 +207,22 @@ class BaseKuryrScenarioTest(manager.NetworkScenarioTest):
return kuryr_if['versioned_object.data']['id']
def exec_command_in_pod(self, pod_name, command, namespace="default",
stderr=False):
stderr=False, container=None):
api = self.k8s_client.CoreV1Api()
kwargs = dict(command=command, stdin=False, stdout=True, tty=False,
stderr=stderr)
if container is not None:
kwargs['container'] = container
if stderr:
kwargs['_preload_content'] = False
resp = stream(api.connect_get_namespaced_pod_exec, pod_name,
namespace, command=command, stderr=True,
stdin=False, stdout=True, tty=False,
_preload_content=False)
namespace, **kwargs)
# Run until completion
resp.run_forever()
return resp.read_stdout(), resp.read_stderr()
else:
return stream(api.connect_get_namespaced_pod_exec, pod_name,
namespace, command=command, stderr=False,
stdin=False, stdout=True, tty=False)
namespace, **kwargs)
def assign_fip_to_pod(self, pod_name, namespace="default"):
ext_net_id = CONF.network.public_network_id

View File

@ -36,9 +36,11 @@ class TestKuryrDaemon(base.BaseKuryrScenarioTest):
namespace = CONF.kuryr_kubernetes.kube_system_namespace
kube_system_pods = self.get_pod_name_list(
namespace=namespace)
cmd = ["ps", "aux"]
cmd = ['cat', '/proc/1/cmdline']
for kuryr_pod_name in kube_system_pods:
if kuryr_pod_name.startswith('kuryr-cni'):
self.assertIn('kuryr-daemon', self.exec_command_in_pod(
kuryr_pod_name, cmd, namespace))
self.assertIn(
'kuryr-daemon --config-file',
self.exec_command_in_pod(kuryr_pod_name, cmd, namespace,
container='kuryr-cni'))