md-cluster: Wake up suspended process

When the suspended_area is deleted, the suspended processes
must be woken up in order to complete their I/O.

Signed-off-by: Goldwyn Rodrigues <rgoldwyn@suse.com>
This commit is contained in:
Goldwyn Rodrigues 2015-10-09 11:27:01 -05:00
parent 099954119d
commit b8ca846e45
1 changed files with 5 additions and 2 deletions

View File

@ -366,11 +366,13 @@ static void __remove_suspend_info(struct md_cluster_info *cinfo, int slot)
} }
} }
static void remove_suspend_info(struct md_cluster_info *cinfo, int slot) static void remove_suspend_info(struct mddev *mddev, int slot)
{ {
struct md_cluster_info *cinfo = mddev->cluster_info;
spin_lock_irq(&cinfo->suspend_lock); spin_lock_irq(&cinfo->suspend_lock);
__remove_suspend_info(cinfo, slot); __remove_suspend_info(cinfo, slot);
spin_unlock_irq(&cinfo->suspend_lock); spin_unlock_irq(&cinfo->suspend_lock);
mddev->pers->quiesce(mddev, 2);
} }
@ -381,7 +383,7 @@ static void process_suspend_info(struct mddev *mddev,
struct suspend_info *s; struct suspend_info *s;
if (!hi) { if (!hi) {
remove_suspend_info(cinfo, slot); remove_suspend_info(mddev, slot);
return; return;
} }
s = kzalloc(sizeof(struct suspend_info), GFP_KERNEL); s = kzalloc(sizeof(struct suspend_info), GFP_KERNEL);
@ -397,6 +399,7 @@ static void process_suspend_info(struct mddev *mddev,
__remove_suspend_info(cinfo, slot); __remove_suspend_info(cinfo, slot);
list_add(&s->list, &cinfo->suspend_list); list_add(&s->list, &cinfo->suspend_list);
spin_unlock_irq(&cinfo->suspend_lock); spin_unlock_irq(&cinfo->suspend_lock);
mddev->pers->quiesce(mddev, 2);
} }
static void process_add_new_disk(struct mddev *mddev, struct cluster_msg *cmsg) static void process_add_new_disk(struct mddev *mddev, struct cluster_msg *cmsg)