Commit 909cc4fb authored by Jonathan Brassow's avatar Jonathan Brassow Committed by Alasdair G Kergon

dm log userspace: split flush queue

Split the 'flush_list', which contained a mix of both 'mark' and 'clear'
requests, into two distinct lists ('mark_list' and 'clear_list').

The device mapper log implementations (used by various DM targets) are
allowed to cache 'mark' and 'clear' requests until a 'flush' is
received.  Until now, these cached requests were kept in the same list.
They will now be put into distinct lists to facilitate group processing
of these requests (in the next patch).
Signed-off-by: default avatarJonathan Brassow <jbrassow@redhat.com>
Signed-off-by: default avatarMike Snitzer <snitzer@redhat.com>
Signed-off-by: default avatarAlasdair G Kergon <agk@redhat.com>
parent 8d35d3e3
...@@ -37,8 +37,15 @@ struct log_c { ...@@ -37,8 +37,15 @@ struct log_c {
*/ */
uint64_t in_sync_hint; uint64_t in_sync_hint;
/*
* Mark and clear requests are held until a flush is issued
* so that we can group, and thereby limit, the amount of
* network traffic between kernel and userspace. The 'flush_lock'
* is used to protect these lists.
*/
spinlock_t flush_lock; spinlock_t flush_lock;
struct list_head flush_list; /* only for clear and mark requests */ struct list_head mark_list;
struct list_head clear_list;
}; };
static mempool_t *flush_entry_pool; static mempool_t *flush_entry_pool;
...@@ -169,7 +176,8 @@ static int userspace_ctr(struct dm_dirty_log *log, struct dm_target *ti, ...@@ -169,7 +176,8 @@ static int userspace_ctr(struct dm_dirty_log *log, struct dm_target *ti,
strncpy(lc->uuid, argv[0], DM_UUID_LEN); strncpy(lc->uuid, argv[0], DM_UUID_LEN);
spin_lock_init(&lc->flush_lock); spin_lock_init(&lc->flush_lock);
INIT_LIST_HEAD(&lc->flush_list); INIT_LIST_HEAD(&lc->mark_list);
INIT_LIST_HEAD(&lc->clear_list);
str_size = build_constructor_string(ti, argc - 1, argv + 1, &ctr_str); str_size = build_constructor_string(ti, argc - 1, argv + 1, &ctr_str);
if (str_size < 0) { if (str_size < 0) {
...@@ -362,14 +370,16 @@ static int userspace_flush(struct dm_dirty_log *log) ...@@ -362,14 +370,16 @@ static int userspace_flush(struct dm_dirty_log *log)
int r = 0; int r = 0;
unsigned long flags; unsigned long flags;
struct log_c *lc = log->context; struct log_c *lc = log->context;
LIST_HEAD(flush_list); LIST_HEAD(mark_list);
LIST_HEAD(clear_list);
struct flush_entry *fe, *tmp_fe; struct flush_entry *fe, *tmp_fe;
spin_lock_irqsave(&lc->flush_lock, flags); spin_lock_irqsave(&lc->flush_lock, flags);
list_splice_init(&lc->flush_list, &flush_list); list_splice_init(&lc->mark_list, &mark_list);
list_splice_init(&lc->clear_list, &clear_list);
spin_unlock_irqrestore(&lc->flush_lock, flags); spin_unlock_irqrestore(&lc->flush_lock, flags);
if (list_empty(&flush_list)) if (list_empty(&mark_list) && list_empty(&clear_list))
return 0; return 0;
/* /*
...@@ -379,7 +389,16 @@ static int userspace_flush(struct dm_dirty_log *log) ...@@ -379,7 +389,16 @@ static int userspace_flush(struct dm_dirty_log *log)
* do it one by one. * do it one by one.
*/ */
list_for_each_entry(fe, &flush_list, list) { list_for_each_entry(fe, &mark_list, list) {
r = userspace_do_request(lc, lc->uuid, fe->type,
(char *)&fe->region,
sizeof(fe->region),
NULL, NULL);
if (r)
goto fail;
}
list_for_each_entry(fe, &clear_list, list) {
r = userspace_do_request(lc, lc->uuid, fe->type, r = userspace_do_request(lc, lc->uuid, fe->type,
(char *)&fe->region, (char *)&fe->region,
sizeof(fe->region), sizeof(fe->region),
...@@ -397,7 +416,11 @@ static int userspace_flush(struct dm_dirty_log *log) ...@@ -397,7 +416,11 @@ static int userspace_flush(struct dm_dirty_log *log)
* Calling code will receive an error and will know that * Calling code will receive an error and will know that
* the log facility has failed. * the log facility has failed.
*/ */
list_for_each_entry_safe(fe, tmp_fe, &flush_list, list) { list_for_each_entry_safe(fe, tmp_fe, &mark_list, list) {
list_del(&fe->list);
mempool_free(fe, flush_entry_pool);
}
list_for_each_entry_safe(fe, tmp_fe, &clear_list, list) {
list_del(&fe->list); list_del(&fe->list);
mempool_free(fe, flush_entry_pool); mempool_free(fe, flush_entry_pool);
} }
...@@ -427,7 +450,7 @@ static void userspace_mark_region(struct dm_dirty_log *log, region_t region) ...@@ -427,7 +450,7 @@ static void userspace_mark_region(struct dm_dirty_log *log, region_t region)
spin_lock_irqsave(&lc->flush_lock, flags); spin_lock_irqsave(&lc->flush_lock, flags);
fe->type = DM_ULOG_MARK_REGION; fe->type = DM_ULOG_MARK_REGION;
fe->region = region; fe->region = region;
list_add(&fe->list, &lc->flush_list); list_add(&fe->list, &lc->mark_list);
spin_unlock_irqrestore(&lc->flush_lock, flags); spin_unlock_irqrestore(&lc->flush_lock, flags);
return; return;
...@@ -464,7 +487,7 @@ static void userspace_clear_region(struct dm_dirty_log *log, region_t region) ...@@ -464,7 +487,7 @@ static void userspace_clear_region(struct dm_dirty_log *log, region_t region)
spin_lock_irqsave(&lc->flush_lock, flags); spin_lock_irqsave(&lc->flush_lock, flags);
fe->type = DM_ULOG_CLEAR_REGION; fe->type = DM_ULOG_CLEAR_REGION;
fe->region = region; fe->region = region;
list_add(&fe->list, &lc->flush_list); list_add(&fe->list, &lc->clear_list);
spin_unlock_irqrestore(&lc->flush_lock, flags); spin_unlock_irqrestore(&lc->flush_lock, flags);
return; return;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment