[Devel] [PATCH RH8 18/22] ploop: Do fsync after bat page write

[Kirill Tkhai]

Signed-off-by: Kirill Tkhai <ktkhai at virtuozzo.com>
---
 drivers/md/dm-ploop-map.c |   21 ++++++++++++++++++++-
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/drivers/md/dm-ploop-map.c b/drivers/md/dm-ploop-map.c
index c48dc28691ea..6bd7bd087f4a 100644
--- a/drivers/md/dm-ploop-map.c
+++ b/drivers/md/dm-ploop-map.c
@@ -1477,16 +1477,35 @@ static int process_one_deferred_bio(struct ploop *ploop, struct pio *pio)
 	return 0;
 }
 
+static void md_fsync_endio(struct pio *pio, void *piwb_ptr, blk_status_t bi_status)
+{
+	struct ploop_index_wb *piwb = piwb_ptr;
+
+	ploop_bat_write_complete(piwb, bi_status);
+}
+
 static void md_write_endio(struct pio *pio, void *piwb_ptr, blk_status_t bi_status)
 {
 	struct ploop_index_wb *piwb = piwb_ptr;
 	struct ploop *ploop = piwb->ploop;
+	unsigned long flags;
 	u32 dst_clu;
 
 	dst_clu = POS_TO_CLU(ploop, (u64)piwb->page_id << PAGE_SHIFT);
 	track_dst_cluster(ploop, dst_clu);
 
-	ploop_bat_write_complete(piwb, bi_status);
+	if (bi_status) {
+		md_fsync_endio(pio, piwb, bi_status);
+	} else {
+		init_pio(ploop, REQ_OP_FLUSH, pio);
+		pio->endio_cb = md_fsync_endio;
+		pio->endio_cb_data = piwb;
+
+		spin_lock_irqsave(&ploop->deferred_lock, flags);
+		list_add_tail(&pio->list, &ploop->flush_pios);
+		spin_unlock_irqrestore(&ploop->deferred_lock, flags);
+		queue_work(ploop->wq, &ploop->fsync_worker);
+	}
 }
 
 void ploop_index_wb_submit(struct ploop *ploop, struct ploop_index_wb *piwb)