From patchwork Fri May 5 03:28:07 2023 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Ziyang Zhang X-Patchwork-Id: 13232107 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id AFDEFC7EE21 for ; Fri, 5 May 2023 03:28:38 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S230015AbjEED2h (ORCPT ); Thu, 4 May 2023 23:28:37 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:52132 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S229871AbjEED2e (ORCPT ); Thu, 4 May 2023 23:28:34 -0400 Received: from out30-110.freemail.mail.aliyun.com (out30-110.freemail.mail.aliyun.com [115.124.30.110]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id B172583CF for ; Thu, 4 May 2023 20:28:32 -0700 (PDT) X-Alimail-AntiSpam: AC=PASS;BC=-1|-1;BR=01201311R351e4;CH=green;DM=||false|;DS=||;FP=0|-1|-1|-1|0|-1|-1|-1;HT=ay29a033018045176;MF=ziyangzhang@linux.alibaba.com;NM=1;PH=DS;RN=4;SR=0;TI=SMTPD_---0VhnGAYA_1683257300; Received: from localhost.localdomain(mailfrom:ZiyangZhang@linux.alibaba.com fp:SMTPD_---0VhnGAYA_1683257300) by smtp.aliyun-inc.com; Fri, 05 May 2023 11:28:29 +0800 From: Ziyang Zhang To: shinichiro.kawasaki@wdc.com, ming.lei@redhat.com Cc: linux-block@vger.kernel.org, Ziyang Zhang Subject: [PATCH V2 blktests 1/2] src/miniublk: add user recovery Date: Fri, 5 May 2023 11:28:07 +0800 Message-Id: <20230505032808.356768-2-ZiyangZhang@linux.alibaba.com> X-Mailer: git-send-email 2.31.1 In-Reply-To: <20230505032808.356768-1-ZiyangZhang@linux.alibaba.com> References: <20230505032808.356768-1-ZiyangZhang@linux.alibaba.com> MIME-Version: 1.0 Precedence: bulk List-ID: X-Mailing-List: linux-block@vger.kernel.org We are going to test ublk's user recovery feature so add support in miniublk. Signed-off-by: Ziyang Zhang Reviewed-by: Ming Lei --- src/miniublk.c | 269 ++++++++++++++++++++++++++++++++++++++++++++++--- 1 file changed, 254 insertions(+), 15 deletions(-) diff --git a/src/miniublk.c b/src/miniublk.c index fe10291..a3d6fce 100644 --- a/src/miniublk.c +++ b/src/miniublk.c @@ -17,6 +17,8 @@ #include #include #include +#include +#include #include #include #include @@ -74,6 +76,7 @@ struct ublk_tgt_ops { int (*queue_io)(struct ublk_queue *, int tag); void (*tgt_io_done)(struct ublk_queue *, int tag, const struct io_uring_cqe *); + int (*recover_tgt)(struct ublk_dev *); }; struct ublk_tgt { @@ -372,6 +375,29 @@ static int ublk_ctrl_get_params(struct ublk_dev *dev, return __ublk_ctrl_cmd(dev, &data); } +static int ublk_ctrl_start_user_recover(struct ublk_dev *dev) +{ + struct ublk_ctrl_cmd_data data = { + .cmd_op = UBLK_CMD_START_USER_RECOVERY, + .flags = 0, + }; + + return __ublk_ctrl_cmd(dev, &data); +} + +static int ublk_ctrl_end_user_recover(struct ublk_dev *dev, + int daemon_pid) +{ + struct ublk_ctrl_cmd_data data = { + .cmd_op = UBLK_CMD_END_USER_RECOVERY, + .flags = CTRL_CMD_HAS_DATA, + }; + + dev->dev_info.ublksrv_pid = data.data[0] = daemon_pid; + + return __ublk_ctrl_cmd(dev, &data); +} + static const char *ublk_dev_state_desc(struct ublk_dev *dev) { switch (dev->dev_info.state) { @@ -379,6 +405,8 @@ static const char *ublk_dev_state_desc(struct ublk_dev *dev) return "DEAD"; case UBLK_S_DEV_LIVE: return "LIVE"; + case UBLK_S_DEV_QUIESCED: + return "QUIESCED"; default: return "UNKNOWN"; }; @@ -550,9 +578,12 @@ static int ublk_dev_prep(struct ublk_dev *dev) goto fail; } - if (dev->tgt.ops->init_tgt) + if (dev->dev_info.state != UBLK_S_DEV_QUIESCED && dev->tgt.ops->init_tgt) ret = dev->tgt.ops->init_tgt(dev); + else if (dev->dev_info.state == UBLK_S_DEV_QUIESCED && dev->tgt.ops->recover_tgt) + ret = dev->tgt.ops->recover_tgt(dev); + return ret; fail: close(dev->fds[0]); @@ -831,7 +862,7 @@ static void ublk_set_parameters(struct ublk_dev *dev) dev->dev_info.dev_id, ret); } -static int ublk_start_daemon(struct ublk_dev *dev) +static int ublk_start_daemon(struct ublk_dev *dev, bool recovery) { int ret, i; void *thread_ret; @@ -853,12 +884,22 @@ static int ublk_start_daemon(struct ublk_dev *dev) &dev->q[i]); } - ublk_set_parameters(dev); /* everything is fine now, start us */ - ret = ublk_ctrl_start_dev(dev, getpid()); - if (ret < 0) - goto fail; + if (recovery) { + ret = ublk_ctrl_end_user_recover(dev, getpid()); + if (ret < 0) { + ublk_err("%s: ublk_ctrl_end_user_recover failed: %d\n", __func__, ret); + goto fail; + } + } else { + ublk_set_parameters(dev); + ret = ublk_ctrl_start_dev(dev, getpid()); + if (ret < 0) { + ublk_err("%s: ublk_ctrl_start_dev failed: %d\n", __func__, ret); + goto fail; + } + } ublk_ctrl_get_info(dev); ublk_ctrl_dump(dev, true); @@ -880,6 +921,7 @@ static int cmd_dev_add(int argc, char *argv[]) { "number", 1, NULL, 'n' }, { "queues", 1, NULL, 'q' }, { "depth", 1, NULL, 'd' }, + { "recovery", 0, NULL, 'r' }, { "debug_mask", 1, NULL, 0}, { "quiet", 0, NULL, 0}, { NULL } @@ -891,8 +933,9 @@ static int cmd_dev_add(int argc, char *argv[]) const char *tgt_type = NULL; int dev_id = -1; unsigned nr_queues = 2, depth = UBLK_QUEUE_DEPTH; + int user_recovery = 0; - while ((opt = getopt_long(argc, argv, "-:t:n:d:q:", + while ((opt = getopt_long(argc, argv, "-:t:n:d:q:r", longopts, &option_idx)) != -1) { switch (opt) { case 'n': @@ -907,6 +950,9 @@ static int cmd_dev_add(int argc, char *argv[]) case 'd': depth = strtol(optarg, NULL, 10); break; + case 'r': + user_recovery = 1; + break; case 0: if (!strcmp(longopts[option_idx].name, "debug_mask")) ublk_dbg_mask = strtol(optarg, NULL, 16); @@ -942,6 +988,8 @@ static int cmd_dev_add(int argc, char *argv[]) info->dev_id = dev_id; info->nr_hw_queues = nr_queues; info->queue_depth = depth; + if (user_recovery) + info->flags |= UBLK_F_USER_RECOVERY; dev->tgt.ops = ops; dev->tgt.argc = argc; dev->tgt.argv = argv; @@ -953,7 +1001,95 @@ static int cmd_dev_add(int argc, char *argv[]) goto fail; } - ret = ublk_start_daemon(dev); + ret = ublk_start_daemon(dev, false); + if (ret < 0) { + ublk_err("%s: can't start daemon id %d, type %s\n", + __func__, dev_id, tgt_type); + goto fail_del; + } + +fail_del: + ublk_ctrl_del_dev(dev); +fail: + ublk_ctrl_deinit(dev); + return ret; +} + +static int cmd_dev_recover(int argc, char *argv[]) +{ + static const struct option longopts[] = { + { "type", 1, NULL, 't' }, + { "number", 1, NULL, 'n' }, + { "debug_mask", 1, NULL, 0}, + { "quiet", 0, NULL, 0}, + { NULL } + }; + const struct ublk_tgt_ops *ops; + struct ublksrv_ctrl_dev_info *info; + struct ublk_dev *dev; + int ret, option_idx, opt; + const char *tgt_type = NULL; + int dev_id = -1; + + while ((opt = getopt_long(argc, argv, "-:t:n:d:q:", + longopts, &option_idx)) != -1) { + switch (opt) { + case 'n': + dev_id = strtol(optarg, NULL, 10); + break; + case 't': + tgt_type = optarg; + break; + case 0: + if (!strcmp(longopts[option_idx].name, "debug_mask")) + ublk_dbg_mask = strtol(optarg, NULL, 16); + if (!strcmp(longopts[option_idx].name, "quiet")) + ublk_dbg_mask = 0; + break; + } + } + + optind = 0; + + ops = ublk_find_tgt(tgt_type); + if (!ops) { + ublk_err("%s: no such tgt type, type %s\n", + __func__, tgt_type); + return -ENODEV; + } + + dev = ublk_ctrl_init(); + if (!dev) { + ublk_err("%s: can't alloc dev id %d, type %s\n", + __func__, dev_id, tgt_type); + return -ENOMEM; + } + + info = &dev->dev_info; + info->dev_id = dev_id; + ret = ublk_ctrl_get_info(dev); + if (ret < 0) { + ublk_err("%s: can't get dev info from %d\n", __func__, dev_id); + goto fail; + } + + ret = ublk_ctrl_get_params(dev, &dev->tgt.params); + if (ret) { + ublk_err("dev %d set basic parameter failed %d\n", + dev->dev_info.dev_id, ret); + goto fail; + } + + dev->tgt.ops = ops; + dev->tgt.argc = argc; + dev->tgt.argv = argv; + ret = ublk_ctrl_start_user_recover(dev); + if (ret < 0) { + ublk_err("%s: can't start recovery for %d\n", __func__, dev_id); + goto fail; + } + + ret = ublk_start_daemon(dev, true); if (ret < 0) { ublk_err("%s: can't start daemon id %d, type %s\n", __func__, dev_id, tgt_type); @@ -1125,7 +1261,9 @@ static int cmd_dev_help(int argc, char *argv[]) printf("\t -a delete all devices -n delete specified device\n"); printf("%s list [-n dev_id] -a \n", argv[0]); printf("\t -a list all devices, -n list specified device, default -a \n"); - + printf("%s recover -t {null|loop} [-n dev_id] \n", argv[0]); + printf("\t -t loop -f backing_file \n"); + printf("\t -t null\n"); return 0; } @@ -1150,6 +1288,12 @@ static int ublk_null_tgt_init(struct ublk_dev *dev) return 0; } +static int ublk_null_tgt_recover(struct ublk_dev *dev) +{ + dev->tgt.dev_size = dev->tgt.params.basic.dev_sectors << 9; + return 0; +} + static int ublk_null_queue_io(struct ublk_queue *q, int tag) { const struct ublksrv_io_desc *iod = ublk_get_iod(q, tag); @@ -1264,15 +1408,17 @@ static int ublk_loop_tgt_init(struct ublk_dev *dev) } } - ublk_dbg(UBLK_DBG_DEV, "%s: file %s\n", __func__, file); - - if (!file) + if (!file) { + ublk_err( "%s: backing file is unset!\n", __func__); return -EINVAL; + } + + ublk_dbg(UBLK_DBG_DEV, "%s: file %s\n", __func__, file); fd = open(file, O_RDWR); if (fd < 0) { - ublk_err( "%s: backing file %s can't be opened\n", - __func__, file); + ublk_err("%s: backing file %s can't be opened: %s\n", + __func__, file, strerror(errno)); return -EBADF; } @@ -1301,7 +1447,8 @@ static int ublk_loop_tgt_init(struct ublk_dev *dev) if (fcntl(fd, F_SETFL, O_DIRECT)) { p.basic.logical_bs_shift = 9; p.basic.physical_bs_shift = 12; - ublk_log("%s: ublk-loop fallback to buffered IO\n", __func__); + ublk_log("%s: %s, ublk-loop fallback to buffered IO\n", + __func__, strerror(errno)); } dev->tgt.dev_size = bytes; @@ -1313,11 +1460,100 @@ static int ublk_loop_tgt_init(struct ublk_dev *dev) return 0; } +static int ublk_loop_tgt_recover(struct ublk_dev *dev) +{ + static const struct option lo_longopts[] = { + { "file", 1, NULL, 'f' }, + { NULL } + }; + unsigned long long bytes; + char **argv = dev->tgt.argv; + int argc = dev->tgt.argc; + struct ublk_params p = dev->tgt.params; + char *file = NULL; + int fd, opt; + unsigned int bs = 1 << 9, pbs = 1 << 12; + struct stat st; + + while ((opt = getopt_long(argc, argv, "-:f:", + lo_longopts, NULL)) != -1) { + switch (opt) { + case 'f': + file = strdup(optarg); + break; + } + } + + if (!file) { + ublk_err( "%s: backing file is unset!\n", __func__); + return -EINVAL; + } + + ublk_dbg(UBLK_DBG_DEV, "%s: file %s\n", __func__, file); + + fd = open(file, O_RDWR); + if (fd < 0) { + ublk_err( "%s: backing file %s can't be opened: %s\n", + __func__, file, strerror(errno)); + return -EBADF; + } + + if (fstat(fd, &st) < 0) { + close(fd); + return -EBADF; + } + + if (S_ISBLK(st.st_mode)) { + if (ioctl(fd, BLKGETSIZE64, &bytes) != 0) + return -EBADF; + if (ioctl(fd, BLKSSZGET, &bs) != 0) + return -1; + if (ioctl(fd, BLKPBSZGET, &pbs) != 0) + return -1; + } else if (S_ISREG(st.st_mode)) { + bytes = st.st_size; + } else { + bytes = 0; + } + + if (fcntl(fd, F_SETFL, O_DIRECT)) { + /* buffered I/O */ + ublk_log("%s: %s, ublk-loop fallback to buffered IO\n", + __func__, strerror(errno)); + } + else { + /* direct I/O */ + if (p.basic.logical_bs_shift != ilog2(bs)) { + ublk_err("%s: logical block size should be %d, I got %d\n", + __func__, 1 << p.basic.logical_bs_shift, bs); + return -1; + } + if (p.basic.physical_bs_shift != ilog2(pbs)) { + ublk_err("%s: physical block size should be %d, I got %d\n", + __func__, 1 << p.basic.physical_bs_shift, pbs); + return -1; + } + } + + if (p.basic.dev_sectors << 9 != bytes) { + ublk_err("%s: device size should be %lld, I got %lld\n", + __func__, p.basic.dev_sectors << 9, bytes); + return -1; + } + + dev->tgt.dev_size = bytes; + dev->fds[1] = fd; + dev->nr_fds += 1; + + return 0; +} + const struct ublk_tgt_ops tgt_ops_list[] = { { .name = "null", .init_tgt = ublk_null_tgt_init, .queue_io = ublk_null_queue_io, + .recover_tgt = ublk_null_tgt_recover, }, { @@ -1326,6 +1562,7 @@ const struct ublk_tgt_ops tgt_ops_list[] = { .deinit_tgt = ublk_loop_tgt_deinit, .queue_io = ublk_loop_queue_io, .tgt_io_done = ublk_loop_io_done, + .recover_tgt = ublk_loop_tgt_recover, }, }; @@ -1359,6 +1596,8 @@ int main(int argc, char *argv[]) ret = cmd_dev_list(argc, argv); else if (!strcmp(cmd, "help")) ret = cmd_dev_help(argc, argv); + else if (!strcmp(cmd, "recover")) + ret = cmd_dev_recover(argc, argv); out: if (ret) cmd_dev_help(argc, argv); From patchwork Fri May 5 03:28:08 2023 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Ziyang Zhang X-Patchwork-Id: 13232108 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id 0C77CC7EE2A for ; Fri, 5 May 2023 03:28:41 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S230038AbjEED2j (ORCPT ); Thu, 4 May 2023 23:28:39 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:52160 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S230034AbjEED2i (ORCPT ); Thu, 4 May 2023 23:28:38 -0400 Received: from out30-124.freemail.mail.aliyun.com (out30-124.freemail.mail.aliyun.com [115.124.30.124]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id C70A2869A for ; Thu, 4 May 2023 20:28:35 -0700 (PDT) X-Alimail-AntiSpam: AC=PASS;BC=-1|-1;BR=01201311R601e4;CH=green;DM=||false|;DS=||;FP=0|-1|-1|-1|0|-1|-1|-1;HT=ay29a033018046059;MF=ziyangzhang@linux.alibaba.com;NM=1;PH=DS;RN=4;SR=0;TI=SMTPD_---0VhnGAf0_1683257310; Received: from localhost.localdomain(mailfrom:ZiyangZhang@linux.alibaba.com fp:SMTPD_---0VhnGAf0_1683257310) by smtp.aliyun-inc.com; Fri, 05 May 2023 11:28:33 +0800 From: Ziyang Zhang To: shinichiro.kawasaki@wdc.com, ming.lei@redhat.com Cc: linux-block@vger.kernel.org, Ziyang Zhang Subject: [PATCH V2 blktests 2/2] tests: Add ublk tests Date: Fri, 5 May 2023 11:28:08 +0800 Message-Id: <20230505032808.356768-3-ZiyangZhang@linux.alibaba.com> X-Mailer: git-send-email 2.31.1 In-Reply-To: <20230505032808.356768-1-ZiyangZhang@linux.alibaba.com> References: <20230505032808.356768-1-ZiyangZhang@linux.alibaba.com> MIME-Version: 1.0 Precedence: bulk List-ID: X-Mailing-List: linux-block@vger.kernel.org It is very important to test ublk crash handling since the userspace part is not reliable. Especially we should test removing device, killing ublk daemons and user recovery feature. Add five new tests for ublk to cover these cases. Signed-off-by: Ziyang Zhang Reviewed-by: Ming Lei --- common/ublk | 10 +++++- tests/ublk/001 | 48 +++++++++++++++++++++++++++ tests/ublk/001.out | 2 ++ tests/ublk/002 | 63 +++++++++++++++++++++++++++++++++++ tests/ublk/002.out | 2 ++ tests/ublk/003 | 48 +++++++++++++++++++++++++++ tests/ublk/003.out | 2 ++ tests/ublk/004 | 50 ++++++++++++++++++++++++++++ tests/ublk/004.out | 2 ++ tests/ublk/005 | 79 +++++++++++++++++++++++++++++++++++++++++++ tests/ublk/005.out | 2 ++ tests/ublk/006 | 83 ++++++++++++++++++++++++++++++++++++++++++++++ tests/ublk/006.out | 2 ++ tests/ublk/rc | 15 +++++++++ 14 files changed, 407 insertions(+), 1 deletion(-) create mode 100755 tests/ublk/001 create mode 100644 tests/ublk/001.out create mode 100755 tests/ublk/002 create mode 100644 tests/ublk/002.out create mode 100755 tests/ublk/003 create mode 100644 tests/ublk/003.out create mode 100755 tests/ublk/004 create mode 100644 tests/ublk/004.out create mode 100755 tests/ublk/005 create mode 100644 tests/ublk/005.out create mode 100755 tests/ublk/006 create mode 100644 tests/ublk/006.out create mode 100644 tests/ublk/rc diff --git a/common/ublk b/common/ublk index 932c534..7a951eb 100644 --- a/common/ublk +++ b/common/ublk @@ -15,8 +15,16 @@ _remove_ublk_devices() { src/miniublk del -a } +__get_ublk_dev_state() { + src/miniublk list -n "$1" | grep "state" | awk '{print $11}' +} + +__get_ublk_daemon_pid() { + src/miniublk list -n "$1" | grep "pid" | awk '{print $7}' +} + _init_ublk() { - _remove_ublk_devices + _remove_ublk_devices > /dev/null 2>&1 modprobe -rq ublk_drv if ! modprobe ublk_drv; then diff --git a/tests/ublk/001 b/tests/ublk/001 new file mode 100755 index 0000000..36a43d7 --- /dev/null +++ b/tests/ublk/001 @@ -0,0 +1,48 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# Test ublk delete + +. tests/ublk/rc + +DESCRIPTION="test ublk delete" + +__run() { + local type=$1 + + if [ "$type" == "null" ]; then + ${ublk_prog} add -t null -n 0 > "$FULL" 2>&1 + else + truncate -s 1G "$TMPDIR/img" + ${ublk_prog} add -t loop -f "$TMPDIR/img" -n 0 > "$FULL" 2>&1 + fi + + udevadm settle + if ! ${ublk_prog} list -n 0 >> "$FULL" 2>&1; then + echo "fail to list dev" + fi + + _run_fio_rand_io --filename=/dev/ublkb0 --time_based --runtime=30 >> "$FULL" 2>&1 & + sleep 2 + + ${ublk_prog} del -n 0 >> "$FULL" 2>&1 +} + +test() { + local ublk_prog="src/miniublk" + + echo "Running ${TEST_NAME}" + + if ! _init_ublk; then + return 1 + fi + + for type in "null" "loop"; do + __run "$type" + done + + _exit_ublk + + echo "Test complete" +} diff --git a/tests/ublk/001.out b/tests/ublk/001.out new file mode 100644 index 0000000..0d070b3 --- /dev/null +++ b/tests/ublk/001.out @@ -0,0 +1,2 @@ +Running ublk/001 +Test complete diff --git a/tests/ublk/002 b/tests/ublk/002 new file mode 100755 index 0000000..e36589e --- /dev/null +++ b/tests/ublk/002 @@ -0,0 +1,63 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# Test ublk crash with delete after dead confirmation + +. tests/ublk/rc + +DESCRIPTION="test ublk crash with delete after dead confirmation" + +__run() { + local type=$1 + + if [ "$type" == "null" ]; then + ${ublk_prog} add -t null -n 0 > "$FULL" 2>&1 + else + truncate -s 1G "$TMPDIR/img" + ${ublk_prog} add -t loop -f "$TMPDIR/img" -n 0 > "$FULL" 2>&1 + fi + + udevadm settle + if ! ${ublk_prog} list -n 0 >> "$FULL" 2>&1; then + echo "fail to list dev" + fi + + _run_fio_rand_io --filename=/dev/ublkb0 --time_based --runtime=30 >> "$FULL" 2>&1 & + sleep 2 + + kill -9 "$(__get_ublk_daemon_pid 0)" + sleep 2 + + local secs=0 + local state="" + while [ $secs -lt 20 ]; do + state="$(__get_ublk_dev_state 0)" + [ "$state" == "DEAD" ] && break + sleep 1 + (( secs++ )) + done + + state="$(__get_ublk_dev_state 0)" + [ "$state" != "DEAD" ] && echo "device is $state after killing queue daemon" + + ${ublk_prog} del -n 0 >> "$FULL" 2>&1 +} + +test() { + local ublk_prog="src/miniublk" + + echo "Running ${TEST_NAME}" + + if ! _init_ublk; then + return 1 + fi + + for type in "null" "loop"; do + __run "$type" + done + + _exit_ublk + + echo "Test complete" +} diff --git a/tests/ublk/002.out b/tests/ublk/002.out new file mode 100644 index 0000000..93039b7 --- /dev/null +++ b/tests/ublk/002.out @@ -0,0 +1,2 @@ +Running ublk/002 +Test complete diff --git a/tests/ublk/003 b/tests/ublk/003 new file mode 100755 index 0000000..b256b09 --- /dev/null +++ b/tests/ublk/003 @@ -0,0 +1,48 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# Test mounting block device exported by ublk + +. tests/ublk/rc + +DESCRIPTION="test mounting block device exported by ublk" + +test() { + local ublk_prog="src/miniublk" + local ROOT_FSTYPE="$(findmnt -l -o FSTYPE -n /)" + local mnt="$TMPDIR/mnt" + + echo "Running ${TEST_NAME}" + + if ! _init_ublk; then + return 1 + fi + + truncate -s 1G "$TMPDIR/img" + ${ublk_prog} add -t loop -f "$TMPDIR/img" -n 0 > "$FULL" 2>&1 + + udevadm settle + if ! ${ublk_prog} list -n 0 >> "$FULL" 2>&1; then + echo "fail to list dev" + fi + + wipefs -a /dev/ublkb0 >> "$FULL" 2>&1 + mkfs.${ROOT_FSTYPE} /dev/ublkb0 >> "$FULL" 2>&1 + mkdir -p "$mnt" + mount /dev/ublkb0 "$mnt" >> "$FULL" 2>&1 + + local UBLK_FSTYPE="$(findmnt -l -o FSTYPE -n $mnt)" + if [ "$UBLK_FSTYPE" != "$ROOT_FSTYPE" ]; then + echo "got $UBLK_FSTYPE, should be $ROOT_FSTYPE" + fi + umount "$mnt" > /dev/null 2>&1 + + ${ublk_prog} del -n 0 >> "$FULL" 2>&1 + + _exit_ublk + + echo "Test complete" +} + + diff --git a/tests/ublk/003.out b/tests/ublk/003.out new file mode 100644 index 0000000..90a3bfa --- /dev/null +++ b/tests/ublk/003.out @@ -0,0 +1,2 @@ +Running ublk/003 +Test complete diff --git a/tests/ublk/004 b/tests/ublk/004 new file mode 100755 index 0000000..84e01d1 --- /dev/null +++ b/tests/ublk/004 @@ -0,0 +1,50 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# Test ublk crash with delete just after daemon kill + +. tests/ublk/rc + +DESCRIPTION="test ublk crash with delete just after daemon kill" + +__run() { + local type=$1 + + if [ "$type" == "null" ]; then + ${ublk_prog} add -t null -n 0 > "$FULL" 2>&1 + else + truncate -s 1G "$TMPDIR/img" + ${ublk_prog} add -t loop -f "$TMPDIR/img" -n 0 > "$FULL" 2>&1 + fi + + udevadm settle + if ! ${ublk_prog} list -n 0 >> "$FULL" 2>&1; then + echo "fail to list dev" + fi + + _run_fio_rand_io --filename=/dev/ublkb0 --time_based --runtime=30 >> "$FULL" 2>&1 & + sleep 2 + + kill -9 "$(__get_ublk_daemon_pid 0)" + + ${ublk_prog} del -n 0 >> "$FULL" 2>&1 +} + +test() { + local ublk_prog="src/miniublk" + + echo "Running ${TEST_NAME}" + + if ! _init_ublk; then + return 1 + fi + + for type in "null" "loop"; do + __run "$type" + done + + _exit_ublk + + echo "Test complete" +} diff --git a/tests/ublk/004.out b/tests/ublk/004.out new file mode 100644 index 0000000..a92cd50 --- /dev/null +++ b/tests/ublk/004.out @@ -0,0 +1,2 @@ +Running ublk/004 +Test complete diff --git a/tests/ublk/005 b/tests/ublk/005 new file mode 100755 index 0000000..f365fd6 --- /dev/null +++ b/tests/ublk/005 @@ -0,0 +1,79 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# Test ublk recovery with one time daemon kill: +# (1)kill all ubq_deamon, (2)recover with new ubq_daemon, +# (3)delete dev + +. tests/ublk/rc + +DESCRIPTION="test ublk recovery with one time daemon kill" + +__run() { + local type=$1 + + if [ "$type" == "null" ]; then + ${ublk_prog} add -t null -n 0 -r > "$FULL" 2>&1 + else + truncate -s 1G "$TMPDIR/img" + ${ublk_prog} add -t loop -f "$TMPDIR/img" -n 0 -r > "$FULL" 2>&1 + fi + + udevadm settle + if ! ${ublk_prog} list -n 0 >> "$FULL" 2>&1; then + echo "fail to list dev" + fi + + _run_fio_rand_io --filename=/dev/ublkb0 --time_based --runtime=30 >> "$FULL" 2>&1 & + sleep 2 + + kill -9 "$(__get_ublk_daemon_pid 0)" + sleep 2 + + local secs=0 + local state="" + while [ $secs -lt 20 ]; do + state="$(__get_ublk_dev_state 0)" + [ "$state" == "QUIESCED" ] && break + sleep 1 + (( secs++ )) + done + + state="$(__get_ublk_dev_state 0)" + [ "$state" != "QUIESCED" ] && echo "device is $state after killing queue daemon" + + if [ "$type" == "null" ]; then + ${ublk_prog} recover -t null -n 0 >> "$FULL" 2>&1 + else + ${ublk_prog} recover -t loop -f "$TMPDIR/img" -n 0 >> "$FULL" 2>&1 + fi + + while [ $secs -lt 20 ]; do + state="$(__get_ublk_dev_state 0)" + [ "$state" == "LIVE" ] && break + sleep 1 + (( secs++ )) + done + [ "$state" != "LIVE" ] && echo "device is $state after recovery" + + ${ublk_prog} del -n 0 >> "$FULL" 2>&1 +} + +test() { + local ublk_prog="src/miniublk" + + echo "Running ${TEST_NAME}" + + if ! _init_ublk; then + return 1 + fi + + for type in "null" "loop"; do + __run "$type" + done + + _exit_ublk + + echo "Test complete" +} diff --git a/tests/ublk/005.out b/tests/ublk/005.out new file mode 100644 index 0000000..20d7b38 --- /dev/null +++ b/tests/ublk/005.out @@ -0,0 +1,2 @@ +Running ublk/005 +Test complete diff --git a/tests/ublk/006 b/tests/ublk/006 new file mode 100755 index 0000000..0848939 --- /dev/null +++ b/tests/ublk/006 @@ -0,0 +1,83 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# Test ublk recovery with two times daemon kill: +# (1)kill all ubq_deamon, (2)recover with new ubq_daemon, +# (3)kill all ubq_deamon, (4)delete dev + +. tests/ublk/rc + +DESCRIPTION="test ublk recovery with two times daemon kill" + +__run() { + local type=$1 + + if [ "$type" == "null" ]; then + ${ublk_prog} add -t null -n 0 -r > "$FULL" 2>&1 + else + truncate -s 1G "$TMPDIR/img" + ${ublk_prog} add -t loop -f "$TMPDIR/img" -n 0 -r > "$FULL" 2>&1 + fi + + udevadm settle + if ! ${ublk_prog} list -n 0 >> "$FULL" 2>&1; then + echo "fail to list dev" + fi + + _run_fio_rand_io --filename=/dev/ublkb0 --time_based --runtime=30 >> "$FULL" 2>&1 & + sleep 2 + + kill -9 "$(__get_ublk_daemon_pid 0)" + sleep 2 + + local secs=0 + local state="" + while [ $secs -lt 20 ]; do + state="$(__get_ublk_dev_state 0)" + [ "$state" == "QUIESCED" ] && break + sleep 1 + (( secs++ )) + done + + state="$(__get_ublk_dev_state 0)" + [ "$state" != "QUIESCED" ] && echo "device is $state after killing queue daemon" + + if [ "$type" == "null" ]; then + ${ublk_prog} recover -t null -n 0 >> "$FULL" 2>&1 + else + ${ublk_prog} recover -t loop -f "$TMPDIR/img" -n 0 >> "$FULL" 2>&1 + fi + + secs=0 + while [ $secs -lt 20 ]; do + state="$(__get_ublk_dev_state 0)" + [ "$state" == "LIVE" ] && break + sleep 1 + (( secs++ )) + done + [ "$state" != "LIVE" ] && echo "device is $state after recovery" + + kill -9 "$(__get_ublk_daemon_pid 0)" + + ${ublk_prog} del -n 0 >> "$FULL" 2>&1 +} + +test() { + local ublk_prog="src/miniublk" + + echo "Running ${TEST_NAME}" + + if ! _init_ublk; then + return 1 + fi + + for type in "null" "loop"; do + __run "$type" + done + + _exit_ublk + + echo "Test complete" +} + diff --git a/tests/ublk/006.out b/tests/ublk/006.out new file mode 100644 index 0000000..6d2a530 --- /dev/null +++ b/tests/ublk/006.out @@ -0,0 +1,2 @@ +Running ublk/006 +Test complete diff --git a/tests/ublk/rc b/tests/ublk/rc new file mode 100644 index 0000000..8cbc757 --- /dev/null +++ b/tests/ublk/rc @@ -0,0 +1,15 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-3.0+ +# Copyright (C) 2023 Ziyang Zhang +# +# ublk tests. + +. common/rc +. common/ublk +. common/fio + +group_requires() { + _have_root + _have_ublk + _have_fio +}