[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [PATCH] tests/qtest/tpm-emu: Avoid hangs using abort handlers closin
From: |
Daniel P . Berrangé |
Subject: |
Re: [PATCH] tests/qtest/tpm-emu: Avoid hangs using abort handlers closing channels |
Date: |
Wed, 11 Jan 2023 13:32:24 +0000 |
User-agent: |
Mutt/2.2.9 (2022-11-12) |
On Wed, Jan 11, 2023 at 08:30:23AM -0500, Stefan Berger wrote:
> Install abort handlers that close the TPM control and data channels in
> case an abort occurs. The purpose of this is to have QEMU terminate
> under abnormal test case failures to resolve intermittent hangs on s390x
> hosts running TPM tests for QEMU/x86_64.
>
> Signed-off-by: Stefan Berger <stefanb@linux.ibm.com>
> ---
> tests/qtest/tpm-emu.c | 15 +++++++++++++++
> 1 file changed, 15 insertions(+)
>
> diff --git a/tests/qtest/tpm-emu.c b/tests/qtest/tpm-emu.c
> index 2994d1cf42..5740cab950 100644
> --- a/tests/qtest/tpm-emu.c
> +++ b/tests/qtest/tpm-emu.c
> @@ -36,11 +36,18 @@ void tpm_emu_test_wait_cond(TPMTestState *s)
> g_mutex_unlock(&s->data_mutex);
> }
>
> +static void tpm_emu_close_data_ioc(void *ioc)
> +{
> + qio_channel_close(ioc, NULL);
> +}
We could actually just call it tpm_emu_close_ioc and
refer to it from both places....
> +
> static void *tpm_emu_tpm_thread(void *data)
> {
> TPMTestState *s = data;
> QIOChannel *ioc = s->tpm_ioc;
>
> + qtest_add_abrt_handler(tpm_emu_close_data_ioc, ioc);
> +
> s->tpm_msg = g_new(struct tpm_hdr, 1);
> while (true) {
> int minhlen = sizeof(s->tpm_msg->tag) + sizeof(s->tpm_msg->len);
> @@ -77,12 +84,18 @@ static void *tpm_emu_tpm_thread(void *data)
> &error_abort);
> }
>
> + qtest_remove_abrt_handler(ioc);
> g_free(s->tpm_msg);
> s->tpm_msg = NULL;
> object_unref(OBJECT(s->tpm_ioc));
> return NULL;
> }
>
> +static void tpm_emu_close_ctrl_ioc(void *ioc)
> +{
> + qio_channel_close(ioc, NULL);
> +}
... as this code is identical.
> +
> void *tpm_emu_ctrl_thread(void *data)
> {
> TPMTestState *s = data;
> @@ -99,6 +112,7 @@ void *tpm_emu_ctrl_thread(void *data)
> qio_channel_wait(QIO_CHANNEL(lioc), G_IO_IN);
> ioc = QIO_CHANNEL(qio_channel_socket_accept(lioc, &error_abort));
> g_assert(ioc);
> + qtest_add_abrt_handler(tpm_emu_close_ctrl_ioc, ioc);
>
> {
> uint32_t cmd = 0;
> @@ -190,6 +204,7 @@ void *tpm_emu_ctrl_thread(void *data)
> }
> }
>
> + qtest_remove_abrt_handler(ioc);
> object_unref(OBJECT(ioc));
> object_unref(OBJECT(lioc));
> return NULL;
> --
> 2.39.0
>
With regards,
Daniel
--
|: https://berrange.com -o- https://www.flickr.com/photos/dberrange :|
|: https://libvirt.org -o- https://fstop138.berrange.com :|
|: https://entangle-photo.org -o- https://www.instagram.com/dberrange :|