<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40"> <head> <meta http-equiv="Content-Type" content="text/html; charset=us-ascii"> <meta name="Generator" content="Microsoft Word 15 (filtered medium)"> <style></style> </head> <body lang="EN-US" link="#0563C1" vlink="#954F72"> <div class="WordSection1"> Hello<o:p></o:p> <o:p> </o:p> I find an issue when use dmsetup in the situation udev event timeout.<o:p></o:p> <o:p> </o:p> Dmsetup use the dm_udev_wait function sync with udev event.When use the dmsetup generate a new dm-disk, if the raw disk is abnormal(for example ,a ipsan disk hung IO request), the udevd daemon handle the dm-disk udev event maybe timeout, and will not notify the dmsetup by semaphore. And because the dm_udev_wait use the semop to sync with udevd, if udevd event timeout, the dmsetup will hung forever even when the raw disk be recovery.<o:p></o:p> <o:p> </o:p> I wonder if we could use the semtimedop instead semop to add the timeout in function dm_udev_wait. If the udevd daemon timeout when handle the dm event, the dm_udev_wait could timeout too, and the dmsetup could return error.<o:p></o:p> <o:p> </o:p> This is my patch base lvm2-2.02.115-3:<o:p></o:p> <o:p> </o:p> From 6961f824abe8eb15f8328f2f4bd39f4cdbf65d4f Mon Sep 17 00:00:00 2001<o:p></o:p> From: fengtiantian <<a href="mailto:fengtiantian@huawei.com">fengtiantian@huawei.com</a>><o:p></o:p> Date: Mon, 23 Oct 2017 19:29:55 +0800<o:p></o:p> Subject: [PATCH] add timeout when fail to wait udev<o:p></o:p> <o:p> </o:p> ---<o:p></o:p> libdm/libdm-common.c | 7 ++++++-<o:p></o:p> tools/dmsetup.c | 20 ++++++++++++++++----<o:p></o:p> 2 files changed, 22 insertions(+), 5 deletions(-)<o:p></o:p> <o:p> </o:p> diff --git a/libdm/libdm-common.c b/libdm/libdm-common.c<o:p></o:p> index bd51645..ede2fea 100644<o:p></o:p> --- a/libdm/libdm-common.c<o:p></o:p> +++ b/libdm/libdm-common.c<o:p></o:p> @@ -59,6 +59,8 @@ union semun<o:p></o:p> #endif<o:p></o:p> #endif<o:p></o:p> <o:p> </o:p> +#define UDEV_SEM_TIMEOUT 300<o:p></o:p> +<o:p></o:p> static char _dm_dir[PATH_MAX] = DEV_DIR DM_DIR;<o:p></o:p> static char _sysfs_dir[PATH_MAX] = "/sys/";<o:p></o:p> static char _path0[PATH_MAX]; /* path buffer, safe 4kB on stack */<o:p></o:p> @@ -2476,6 +2478,9 @@ static int _udev_wait(uint32_t cookie)<o:p></o:p> {<o:p></o:p> int semid;<o:p></o:p> struct sembuf sb = {0, 0, 0};<o:p></o:p> + struct timespec timeout;<o:p></o:p> + timeout.tv_sec = UDEV_SEM_TIMEOUT;<o:p></o:p> + timeout.tv_nsec = 0;<o:p></o:p> <o:p> </o:p> if (!cookie || !dm_udev_get_sync_support())<o:p></o:p> return 1;<o:p></o:p> @@ -2496,7 +2501,7 @@ static int _udev_wait(uint32_t cookie)<o:p></o:p> cookie, semid);<o:p></o:p> <o:p> </o:p> repeat_wait:<o:p></o:p> - if (semop(semid, &sb, 1) < 0) {<o:p></o:p> + if (semtimedop(semid, &sb, 1,&timeout) < 0) {<o:p></o:p> if (errno == EINTR)<o:p></o:p> goto repeat_wait;<o:p></o:p> else if (errno == EIDRM)<o:p></o:p> diff --git a/tools/dmsetup.c b/tools/dmsetup.c<o:p></o:p> index 4202dbb..0840031 100644<o:p></o:p> --- a/tools/dmsetup.c<o:p></o:p> +++ b/tools/dmsetup.c<o:p></o:p> @@ -619,6 +619,7 @@ static int _load(CMD_ARGS)<o:p></o:p> static int _create(CMD_ARGS)<o:p></o:p> {<o:p></o:p> int r = 0;<o:p></o:p> + int udev_wait_r = 1;<o:p></o:p> struct dm_task *dmt;<o:p></o:p> const char *file = NULL;<o:p></o:p> uint32_t cookie = 0;<o:p></o:p> @@ -695,18 +696,22 @@ static int _create(CMD_ARGS)<o:p></o:p> <o:p> </o:p> out:<o:p></o:p> if (!_udev_cookie)<o:p></o:p> - (void) dm_udev_wait(cookie);<o:p></o:p> + udev_wait_r = dm_udev_wait(cookie);<o:p></o:p> <o:p> </o:p> if (r && _switches[VERBOSE_ARG])<o:p></o:p> r = _display_info(dmt);<o:p></o:p> <o:p> </o:p> dm_task_destroy(dmt);<o:p></o:p> <o:p> </o:p> + if(!udev_wait_r)<o:p></o:p> + return 0;<o:p></o:p> +<o:p></o:p> return r;<o:p></o:p> }<o:p></o:p> static int _do_rename(const char *name, const char *new_name, const char *new_uuid) {<o:p></o:p> int r = 0;<o:p></o:p> + int udev_wait_r = 1;<o:p></o:p> struct dm_task *dmt;<o:p></o:p> uint32_t cookie = 0;<o:p></o:p> uint16_t udev_flags = 0;<o:p></o:p> @@ -751,10 +756,13 @@ static int _do_rename(const char *name, const char *new_name, const char *new_uu<o:p></o:p> <o:p> </o:p> out:<o:p></o:p> if (!_udev_cookie)<o:p></o:p> - (void) dm_udev_wait(cookie);<o:p></o:p> + udev_wait_r = dm_udev_wait(cookie);<o:p></o:p> <o:p> </o:p> dm_task_destroy(dmt);<o:p></o:p> <o:p> </o:p> + if (!udev_wait_r)<o:p></o:p> + return 0;<o:p></o:p> +<o:p></o:p> return r;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> @@ -1267,7 +1275,8 @@ static int _simple(int task, const char *name, uint32_t event_nr, int display)<o:p></o:p> int udev_wait_flag = task == DM_DEVICE_RESUME ||<o:p></o:p> task == DM_DEVICE_REMOVE;<o:p></o:p> int r = 0;<o:p></o:p> -<o:p></o:p> + int udev_wait_r = 1;<o:p></o:p> +<o:p></o:p> struct dm_task *dmt;<o:p></o:p> <o:p> </o:p> if (!(dmt = dm_task_create(task)))<o:p></o:p> @@ -1326,13 +1335,16 @@ static int _simple(int task, const char *name, uint32_t event_nr, int display)<o:p></o:p> <o:p> </o:p> out:<o:p></o:p> if (!_udev_cookie && udev_wait_flag)<o:p></o:p> - (void) dm_udev_wait(cookie);<o:p></o:p> + udev_wait_r = dm_udev_wait(cookie);<o:p></o:p> <o:p> </o:p> if (r && display && _switches[VERBOSE_ARG])<o:p></o:p> r = _display_info(dmt);<o:p></o:p> <o:p> </o:p> dm_task_destroy(dmt);<o:p></o:p> <o:p> </o:p> + if(!udev_wait_r)<o:p></o:p> + return 0;<o:p></o:p> +<o:p></o:p> return r;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> --<o:p></o:p> 1.8.3.1<o:p></o:p> <o:p> </o:p> </div> </body> </html>