summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorZhang Huan <zhanghuan@huayun.com>2017-08-15 10:42:44 -0500
committerDavid Teigland <teigland@redhat.com>2017-08-15 11:56:31 -0500
commit43305ae8da20ac8ab4390a2aa81618f2973753af (patch)
tree1537053f89bf6357da2a4fbc2bf23c3bfaef47af
parentaa75ca633285339a8be50ed5e5a661ea1654f8f7 (diff)
downloadlvm2-43305ae8da20ac8ab4390a2aa81618f2973753af.tar.gz
lvmlockd: reduce io impact for finding sanlock lv free lock offset
currently, lvcreate for sanlock find the free lock offset from the beginning of the lvmlock every time. after created thousands of lvs, it will issue thousands of read ios for lvcreate to find free lock offset. remeber the last free lock offset will greatly reduce the impact Signed-off-by: Zhang Huan <zhanghuan@huayun.com>
-rw-r--r--daemons/lvmlockd/lvmlockd-core.c1
-rw-r--r--daemons/lvmlockd/lvmlockd-sanlock.c26
2 files changed, 24 insertions, 3 deletions
diff --git a/daemons/lvmlockd/lvmlockd-core.c b/daemons/lvmlockd/lvmlockd-core.c
index 01259c0c3..aefa98a99 100644
--- a/daemons/lvmlockd/lvmlockd-core.c
+++ b/daemons/lvmlockd/lvmlockd-core.c
@@ -3304,7 +3304,6 @@ static int work_init_lv(struct action *act)
lm_type = ls->lm_type;
memcpy(vg_args, ls->vg_args, MAX_ARGS);
free_offset = ls->free_lock_offset;
- ls->free_lock_offset = 0;
}
pthread_mutex_unlock(&lockspaces_mutex);
diff --git a/daemons/lvmlockd/lvmlockd-sanlock.c b/daemons/lvmlockd/lvmlockd-sanlock.c
index aedd50699..a10d02f07 100644
--- a/daemons/lvmlockd/lvmlockd-sanlock.c
+++ b/daemons/lvmlockd/lvmlockd-sanlock.c
@@ -938,7 +938,9 @@ int lm_find_free_lock_sanlock(struct lockspace *ls, uint64_t *free_offset)
struct lm_sanlock *lms = (struct lm_sanlock *)ls->lm_data;
struct sanlk_resourced rd;
uint64_t offset;
+ uint64_t start_offset;
int rv;
+ int round = 0;
if (daemon_test) {
*free_offset = (1048576 * LV_LOCK_BEGIN) + (1048576 * (daemon_test_lv_count + 1));
@@ -951,9 +953,22 @@ int lm_find_free_lock_sanlock(struct lockspace *ls, uint64_t *free_offset)
rd.rs.num_disks = 1;
strncpy(rd.rs.disks[0].path, lms->ss.host_id_disk.path, SANLK_PATH_LEN-1);
- offset = lms->align_size * LV_LOCK_BEGIN;
+ if (ls->free_lock_offset)
+ offset = ls->free_lock_offset;
+ else
+ offset = lms->align_size * LV_LOCK_BEGIN;
+
+ start_offset = offset;
while (1) {
+ if (offset >= start_offset && round) {
+ /* This indicates the all space are allocated. */
+ log_debug("S %s init_lv_san read back to start offset %llu",
+ ls->name, (unsigned long long)offset);
+ rv = -EMSGSIZE;
+ return rv;
+ }
+
rd.rs.disks[0].offset = offset;
memset(rd.rs.name, 0, SANLK_NAME_LEN);
@@ -963,7 +978,14 @@ int lm_find_free_lock_sanlock(struct lockspace *ls, uint64_t *free_offset)
/* This indicates the end of the device is reached. */
log_debug("S %s find_free_lock_san read limit offset %llu",
ls->name, (unsigned long long)offset);
- return -EMSGSIZE;
+
+ /* remember the NO SPACE offset, if no free area left,
+ * search from this offset after extend */
+ *free_offset = offset;
+
+ offset = lms->align_size * LV_LOCK_BEGIN;
+ round = 1;
+ continue;
}
/*